Amazon Connectのちょっと便利な使い方！対応確認ができる自動電話通知

import json
import boto3
import os
import time

from boto3.dynamodb.conditions import Key

dynamodb = boto3.resource("dynamodb")
clientLambda = boto3.client("lambda")
connect = boto3.client("connect")

def lambda_handler(event, context):

    print(json.dumps(event))
    # *****処理1*****
    # 環境変数に適宜必要となる情報を設定しておき、取得する
    connectInstanceId = os.environ["CONNECT_INSTANCE_ID"]  # Amazon ConnectのインスタンスID
    connectContactFlowId = os.environ["CONNECT_CONTACTFLOW_ID"]  # Amazon ConnectのコンタクトフローID
    callerPhoneNumber = os.environ["CALLER_PHONE_NUMBER"]  # 発信元の電話番号
    callStartMessage = os.environ["callStartMessage"]  # 電話開始時の音声 例）<speak>アラームが発生しました。対応する場合は、ダイヤル1を押してください<speak>
    callConnectMessage = os.environ["callConnectMessage"]  # ダイヤル1が押されたときの時の音声 例）<speak>対応を確認しました<speak>
    callNotConnectMessage = os.environ["callNotConnectMessage"]  # 電話が繋がらなかったときの音声 例）<speak>次の人へお繋します<speak>
    callGroup = os.environ["call_group"]  # 電話を掛ける対象のグループ
    nextLambda = os.environ["lambda_name"]  # 次に実行するLambdaの名前。このLambdaを再帰的に呼び出すために使用
    # DynamoDBのテーブル名を取得
    phoneTable_name = os.environ["phoneTable_name"] # 連絡先電話番号テーブル
    contactTable_name = os.environ["contactTable_name"] # 電話結果格納テーブル
    phoneTable = dynamodb.Table(phoneTable_name)
    contactTable = dynamodb.Table(contactTable_name)

    # *****処理2*****
    # 何周目の何番目に登録の人に電話通知したいのかを判定。初回実行の場合は初期値を設定し、2回目以降は前回の情報を引き継ぐ
    # 2回目以降の実行の場合は、前回の情報を引き継ぐ
    if "processId" in event.keys():
        processId = event["processId"]
        callLoop = int(event["call_loop"]) # 何周目か
        lastPhoneOrder = int(event["phone_order"])  # 前回は何番目の人に電話をかけたのか

    # 初回実行の場合（processIdが存在しない場合）は初期値を設定
    else:
        processId = context.aws_request_id # lambdaのRequestIdをプロセスIDに設定
        callLoop = 1  # 初回なので1周目とする
        lastPhoneOrder = 0  # 初回なので0番目(前回はいない)とする

    # *****処理3*****
    # 電話を掛ける対象のグループ（１周）が何人なのか、何周目かを判定し、周回上限を超えるまでは次にかける電話番号を取得する
    try:
        phoneTableQueryResponse = phoneTable.query(
            KeyConditionExpression=Key("call_group").eq(callGroup)
        )
        # call_group内の電話番号の数
        maxPhoneOrder = phoneTableQueryResponse["Count"]

    except Exception as error:
        print("[ERROR]連絡先電話番号テーブルから通知先電話番号数の取得に失敗")
        print(error)
        return {'statusCode': 400 }

    nextPhoneOrder = lastPhoneOrder + 1 # 次にかける電話番号の順番
    # 次にかける電話番号の順番がcall_group内の通知先電話番号の数を超えていた場合は１番目に戻し、周回数を＋１する
    if nextPhoneOrder > maxPhoneOrder:
        nextPhoneOrder = 1
        callLoop += 1

    # 周回数が３以上になったら終了させる（２周まで電話をかけるとします）
    if callLoop >= 3:
        print("[INFO]上限周回数まで電話をかけ続けましたので、処理を終了します")
        return {'statusCode': 200 }
    # 連絡先電話番号テーブルから次かける電話番号を取得
    try:
        phoneTableGetResponse = phoneTable.get_item(
            Key={"call_group": callGroup, "priority": nextPhoneOrder}
        )
        phoneNumber = phoneTableGetResponse["Item"]["phone_number"] # 次にかける電話番号

    except Exception as error:
        print("[ERROR]電話番号テーブルから次の電話番号の取得に失敗")
        print(error)
        return {'statusCode': 400 }

    # *****処理4*****
    # Step3で作成するコンタクトフローを指定して電話を掛ける
    try:
        connectResponse = connect.start_outbound_voice_contact(
            DestinationPhoneNumber=phoneNumber,  # 送信先の電話番号
            ContactFlowId=connectContactFlowId,
            InstanceId=connectInstanceId,
            SourcePhoneNumber=callerPhoneNumber,
            Attributes={
                "callStartMessage": callStartMessage,
                "callConnectMessage": callConnectMessage,
                "callNotConnectMessage": callNotConnectMessage,
            },
        )

    except Exception as error:
        print("[ERROR]Amazon Connectへの連係に失敗")
        print(error)
        return {'statusCode': 400 }

    contactId = connectResponse["ContactId"]  # 発信のContactID

    # *****処理5****
    # 電話結果格納テーブルに通話開始を登録し、結果が格納されるのを待つ
    try:
        contactTabelputResponse = contactTable.put_item(
            Item={
                "contact_id": contactId,  # 発信のContactID
                "call_flag": 0,  # 電話繋がったかフラグ 繋がれば1になる
            }
        )

    except Exception as error:
        print("[ERROR]電話結果格納テーブルへのコールフラグの準備に失敗")
        print(error)
        return {'statusCode': 400 }

    # 応答があり電話結果格納テーブルが更新されるまで待機
    time.sleep(60)

    # 電話結果格納テーブルからcall_flagの情報を取得
    try:
        contactTableGetResponse = contactTable.get_item(
            Key={
                "contact_id": contactId,
            }
        )
        callFlag = contactTableGetResponse["Item"]["call_flag"]  # 電話繋がったかフラグ

    except Exception as error:
        print("[ERROR]電話結果格納テーブルからコール結果の取得に失敗")
        print(error)
        return {'statusCode': 400 }

    # *****処理6*****
    # 電話応答の結果から、つながっていれば処理を終了し、つながっていなければ次の人に電話をかける
    if callFlag == 0:
        try:
            passEvent = {
                "processId": processId,
                "phone_order": nextPhoneOrder,
                "call_loop": callLoop,
            }

            lambda_responce = clientLambda.invoke(
                FunctionName=nextLambda,
                InvocationType="Event",  # 非同期的に呼び出す
                Payload=json.dumps(passEvent),
            )

            # 呼び出しタイプがEventの場合はステータスコードが202が正常
            lambdaStatusCode = lambda_responce["StatusCode"]
            if lambdaStatusCode == 202:
                print(f"[INFO]{nextLambda}にステータスコード「{str(lambdaStatusCode)}」で正常に連携されました")
            else:
                print(f"[ERROR]{nextLambda}にステータスコード「{str(lambdaStatusCode)}」で正常に連携されませんでした。")

        except Exception as error:
            print("[ERROR]次のLambda呼び出しに失敗")
            print(error)
            return {'statusCode': 400 }

    # 電話が繋がっていれば終了
    elif callFlag == 1:
        print("[INFO]受電を確認したため架電を終了")

    print(f"[INFO]{context.function_name}を正常に終了")
    return {"statusCode": 200}

import json
import boto3
import os

def lambda_handler(event, context):
    print(json.dumps(event))

    # 環境変数に電話結果格納用DynamoDBのテーブル名を設定しておき、取得する
    table_name = os.environ["contactTable_name"]
    dynamodb = boto3.resource("dynamodb")
    table = dynamodb.Table(table_name)

    try:
        # contactidを取得して、電話結果格納用DynamoDBのcall_flagを更新
        contactId = event["Details"]["ContactData"]["ContactId"]
        response = table.update_item(
            Key={
                "contact_id": contactId,
            },
            UpdateExpression="set call_flag=:a",
            ExpressionAttributeValues={":a": 1},
        )

    except Exception as error:
        print("[ERROR]コールフラグの変更に失敗")
        print(error)
        return {"statusCode": 400}

    return {"statusCode": 200}