import datetime
import decimal
import boto3
# クライアントの作成
dynamodb = boto3.resource('dynamodb')
client = boto3.client('sns')

# DynamoDBテーブル名を指定
table = dynamodb.Table("phoneInfoDemo")

# Lambdaのメイン関数
def lambda_handler(event, context):

    print(event)

    # 顧客の電話番号をイベントから取得
    #phoneNumber = event["Details"]["ContactData"]["CustomerEndpoint"]["Address"]

    # DynamoDBからデータを取得
    response = table.get_item(Key={'phoneNumber': phoneNumber })
    item = response.get('Item')

    # SNS通知用のメッセージとパラメータを設定
    params = {
        'TopicArn': 'arn:aws:sns:ap-northeast-1:xxx:AmazonConnectInovationLabNotification',
        'Message': item["customerName"] + "\n" + item["phoneNumber"]
    }
    
    # SNSメッセージを送信
    client.publish(**params)
    
    # レスポンスとして routingPhoneNumber を返して Amazon Connect に発信させる
    return {"routingPhoneNumber": item["routingPhoneNumber"]}

{
    "Details": {
        "ContactData": {
            "Attributes": {
               "exampleAttributeKey1": "exampleAttributeValue1"
              },
            "Channel": "VOICE",
            "ContactId": "4a573372-1f28-4e26-b97b-XXXXXXXXXXX",
            "CustomerEndpoint": {
                // 発信者の電話番号
                "Address": "+1234567890",
                "Type": "TELEPHONE_NUMBER"
            },
            "CustomerId": "someCustomerId",
            "Description": "someDescription",
            "InitialContactId": "4a573372-1f28-4e26-b97b-XXXXXXXXXXX",
            "InitiationMethod": "INBOUND | OUTBOUND | TRANSFER | CALLBACK",
            "InstanceARN": "arn:aws:connect:aws-region:1234567890:instance/c8c0e68d-2200-4265-82c0-XXXXXXXXXX",
            "LanguageCode": "en-US",
            "MediaStreams": {
                "Customer": {
                    "Audio": {
                        "StreamARN": "arn:aws:kinesisvideo::eu-west-2:111111111111:stream/instance-alias-contact-ddddddd-bbbb-dddd-eeee-ffffffffffff/9999999999999",
                        "StartTimestamp": "1571360125131", // Epoch time value
                        "StopTimestamp": "1571360126131",
                        "StartFragmentNumber": "100" // Numberic value for fragment number 
                    }
                }
            },
            "Name": "ContactFlowEvent",
            "PreviousContactId": "4a573372-1f28-4e26-b97b-XXXXXXXXXXX",
            "Queue": {
                   "ARN": "arn:aws:connect:eu-west-2:111111111111:instance/cccccccc-bbbb-dddd-eeee-ffffffffffff/queue/aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
                 "Name": "PasswordReset"
                "OutboundCallerId": {
                    "Address": "+12345678903",
                    "Type": "TELEPHONE_NUMBER"
                }
            },
            "References": {
                "key1": {
                    "Type": "url",
                    "Value": "urlvalue"
                }
            },
            "SystemEndpoint": {
                "Address": "+1234567890",
                "Type": "TELEPHONE_NUMBER"
            }
        },
        "Parameters": {"exampleParameterKey1": "exampleParameterValue1",
               "exampleParameterKey2": "exampleParameterValue2"
        }
    },
    "Name": "ContactFlowEvent"
}