AmazonConnectによる自動電話通知（7.複数連絡先への電話通知〈構築⑧〉）

import json
import boto3
from boto3.dynamodb.conditions import Key, Attr

# boto3からDynamoDBへアクセスするためのオブジェクトを取得
dynamodb = boto3.resource('dynamodb')

# "amazonconnect-contact-list"へアクセスするためのオブジェクトを取得
contactlist = dynamodb.Table("amazonconnect-contact-list")

# "amazonconnect-response-status"へアクセスするためのオブジェクトを取得
responsestatus = dynamodb.Table("amazonconnect-response-status")

# CallStatusを"NG"に変更する関数
def status_ng():
    response = responsestatus.update_item(
        Key={
            'No': 1,
            'Name': "Response"
        },
        UpdateExpression="set CallStatus=:c",
        ExpressionAttributeValues={
            ':c': "NG"
        },
        ReturnValues="UPDATED_NEW"
    )
    return response


# "amazonconnect-contact-list"の内容を返す関数
def operation_scan():

    scanData = contactlist.scan()
    items=scanData['Items']

    return scanData["Items"]


# 指定されたプライオリティの電話番号を返す関数
def get_phone_number(json_contactinfo, now_priority):
    
    for line in json_contactinfo:
        if line['Priority']==now_priority:
            phone_number = line['Phone']

    return phone_number


def lambda_handler(event, context):
    
    # 応答結果を初期化
    status_ng()
    
    # 電話番号リストを取得
    contactinfo = operation_scan()

    # 初回のプライオリティを"1"に設定
    priority = 1

    # 指定したプライオリティの電話番号を取得
    phone_number = get_phone_number(contactinfo, priority)

    # boto3からAmazonConnectへアクセスするためのオブジェクトを取得
    connect = boto3.client('connect')

    # AmzaonConnectの問い合わせフローを呼び出し電話発信
    connect.start_outbound_voice_contact(
        DestinationPhoneNumber=phone_number,
        ContactFlowId='************************************',
        InstanceId='************************************',
        SourcePhoneNumber='+81**********',
    )

    # boto3からSQSへアクセスするためのオブジェクトを取得
    sqs = boto3.resource('sqs')

    # "amazonconnect-queue-confirm"へアクセスするためのオブジェクトを取得
    name = 'amazonconnect-queue-confirm'
    queue = sqs.get_queue_by_name(QueueName=name)

    # 現在のプライオリティをセットしてステータス確認用のキューにメッセージ送信
    response = queue.send_message(MessageBody=json.dumps({"priority": priority}))

import boto3
import json
from boto3.dynamodb.conditions import Key, Attr

# boto3からDynamoDBへアクセスするためのオブジェクトを取得
dynamodb = boto3.resource('dynamodb')

# "amazonconnect-response-status"へアクセスするためのオブジェクトを取得
responsestatus = dynamodb.Table("amazonconnect-response-status")

# CallStatusを"OK"に変更する関数
def status_ok():
    response = responsestatus.update_item(
        Key={
            'No': 1,
            'Name': "Response"
        },
        UpdateExpression="set CallStatus=:c",
        ExpressionAttributeValues={
            ':c': "OK"
        },
        ReturnValues="UPDATED_NEW"
    )
    return response


def lambda_handler(event, context):
    
    # 通知先の電話番号を取得
    destphone = event['Details']['ContactData']['CustomerEndpoint']['Address']

    # ユーザーの応答結果を取得
    pressnum = event['Details']['ContactData']['Attributes']['pressnum']

    # ユーザーの応答結果がOKの場合、CallStatusをOKに変更し、通知成功のログを出力
    if pressnum == "1":
        status_ok()
        print(destphone + "への通知に成功しました。")

    # ユーザーの応答結果がOKの場合、通知失敗のログを出力
    else:
        print(destphone + "への通知に失敗しました。")

    return {
        'statusCode': 200
    }

import json
import boto3
from boto3.dynamodb.conditions import Key, Attr

# boto3からDynamoDBへアクセスするためのオブジェクトを取得
dynamodb = boto3.resource('dynamodb')

# "amazonconnect-contact-list"へアクセスするためのオブジェクトを取得
contactlist = dynamodb.Table("amazonconnect-contact-list")

# "amazonconnect-response-status"へアクセスするためのオブジェクトを取得
responsestatus = dynamodb.Table("amazonconnect-response-status")

# "amazonconnect-response-status"の内容を返す関数
def status_scan():
    
    scanData = responsestatus.scan()
    items=scanData['Items']

    return scanData["Items"]


# "amazonconnect-contact-list"の内容を返す関数
def operation_scan():

    scanData = contactlist.scan()
    items=scanData['Items']

    return scanData["Items"]


# 電話番号リストの行数を返す関数
def get_contactinfo_item_number(json_contactinfo):

    count = 0
    
    for line in json_contactinfo:
        count += 1

    return count


# 前回のプライオリティを返す関数
def get_before_priority(sqs_event):

    record = sqs_event['Records'][0]
    json_record = json.loads(record["body"])
    priority = json_record["priority"]

    return priority


# 指定されたプライオリティの電話番号を返す関数
def get_phone_number(json_contactinfo, now_priority):
    
    for line in json_contactinfo:
        if line['Priority']==now_priority:
            phone_number = line['Phone']

    return phone_number


def lambda_handler(event, context):

    # 応答結果を確認
    statustinfo = status_scan()

    # 応答結果がNGの場合
    if statustinfo[0]['CallStatus'] == "NG":
        
        # 電話番号リストを取得
        contactinfo = operation_scan()

        # 電話番号リストの行数を取得
        contactinfo_item_number = get_contactinfo_item_number(contactinfo)

        # 前回のプライオリティを取得
        before_priority = get_before_priority(event)

        # 前回のプラオリティが電話番号リストの行数と同じ場合(リストの最後まで通知した場合)
        if before_priority == contactinfo_item_number:
            
            # プライオリティを1に設定(最初に戻る)
            priority = 1

        # 前回のプラオリティが電話番号リストの行数と異なる場合(リストの最後まで通知していない場合)
        else:

            # プライオリティに1を足す(次のプライオリティを設定)
            priority = before_priority + 1

        # 指定したプライオリティの電話番号を取得
        phone_number = get_phone_number(contactinfo, priority)

        # boto3からAmazonConnectへアクセスするためのオブジェクトを取得
        connect = boto3.client('connect')

        # AmzaonConnectの問い合わせフローを呼び出し電話発信
        connect.start_outbound_voice_contact(
            DestinationPhoneNumber=phone_number,
            ContactFlowId='************************************',
            InstanceId='************************************',
            SourcePhoneNumber='+81**********',
        )

        # boto3からSQSへアクセスするためのオブジェクトを取得    
        sqs = boto3.resource('sqs')

        # "amazonconnect-queue-confirm"へアクセスするためのオブジェクトを取得
        name = 'amazonconnect-queue-confirm'    
        queue = sqs.get_queue_by_name(QueueName=name)

        # 現在のプライオリティをセットしてステータス確認用のキューにメッセージ送信        
        response = queue.send_message(MessageBody=json.dumps({"priority": priority}))