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

2021年11月3日2022年11月3日

【前回】AmazonConnectによる自動電話通知（7.複数連絡先への電話通知〈構築④〉）
【次回】AmazonConnectによる自動電話通知（7.複数連絡先への電話通知〈構築⑥〉）
【簡易版】AmazonConnectによる自動電話通知（まとめ）

監視サーバーで障害を検知した際に、自動で電話通知できるようにしていきます。ネットワークエンジニアも利用することの多い監視サーバー(Zabbix)で障害検知し、AWS上のAmazonConnectを利用し自動電話を発信します。

今回は下記の条件を満たせるようにAWSの各サービスを利用して自動電話通知の仕組みを導入します。

前提条件

複数の通知先を登録した連絡先リストを持たせる。
連絡先リストに優先度(通知順)を設定する。
優先度が高い人に最初に電話する。
応答が無かった場合、次の優先度の人に順番に電話する。
連絡先リストの最後まで電話しても応答が無かった場合、最初に戻って継続する。

自動電話通知フロー

電話に応答した場合のフロー

EC2上の監視サーバーで障害を検知し、S3へトリガーファイルを格納
S3のイベント通知機能で、SQS_1にメッセージを送信
SQS_1をトリガーとして、Lambda_1を起動
Lambda_1がDynamoDB_1から連絡先を取得し、AmazonConnectを起動
Lambda_1がAmazonConnectを起動すると同時に、SQS_2へメッセージを送信
AmazonConnectがユーザーへ自動電話通知を実施
ユーザが正常応答し、AmazonConnectがLambda_2を起動
Lambda_2が応答結果をDynamoDB_2に保存(応答OK)
60秒後にSQS_2をトリガーとしてLambda_3を起動
Lambda_3がDynamoDB_2の応答結果を確認(正常応答しているため、何もせずに処理完了)

電話に応答しなかった場合のフロー

EC2上の監視サーバーで障害を検知し、S3へトリガーファイルを格納
S3のイベント通知機能で、SQS_1にメッセージを送信
SQS_1をトリガーとして、Lambda_1を起動
Lambda_1がDynamoDB_1から連絡先を取得し、AmazonConnectを起動
Lambda_1がAmazonConnectを起動すると同時に、SQS_2へメッセージを送信
AmazonConnectがユーザーへ自動電話通知を実施
ユーザが正常応答せず、AmazonConnectがLambda_2を起動
Lambda_2が応答結果をDynamoDB_2に保存(応答NG ※実際にはステータスを変更しない)
60秒後にSQS_2をトリガーとしてLambda_3を起動
Lambda_3がDynamoDB_2の応答結果を確認
正常応答していないため、再度AmazonConnectを起動(以降、5から繰り返し)

DynamoDB_2を作成(通知結果を保存するDB)

DynamoDBの「テーブルの作成」をクリックします。

下記の通り入力し、「テーブルの作成」をクリックします。

テーブル名：：任意の名前を入力 ※ここでは、”amazonconnect-response-status”としています。
パーティションキー：「No」と入力し、「数値」を選択
ソートキー：「Name」と入力し、「文字列」を選択

テーブルが作成されたことを確認し、テーブル名をクリックします。

「項目を表示」をクリックします。

「項目の作成」をクリックします。

Noの値は「1」を、Nameの値は「Response」を入力します。

「新しい属性の追加」から「文字列」を追加します。

属性名に「CallStatus」と入力し、値に「NG」を入力します。入力が完了したら、「項目の作成」をクリックします。

項目が追加されたことを確認します。

Lambda_2を作成(AmazonConnectの通知結果を保存する関数)

関数の作成

Lambdaの「関数の作成」をクリックします。

下記の通り入力し、「関数の作成」をクリックします。

オプション：一から作成を選択
関数名：任意の名前を入力 ※ここでは、”amazonconnect-status-save”としています。
ランタイム：Pythonを選択 ※ここでは、最新版の”Python 3.9″を選択しています。

関数が作成されたことを確認します。

アクセス権の追加（ロールの設定）

作成された関数の設定タブに移動し、実行ロールをクリックします。

「ポリシーをアタッチします」をクリックします。

“dynamo”で検索し、「AmazonDynamoDBFullAccess」にチェックを入れ、「ポリシーのアタッチ」をクリックします。

ポリシーがアタッチされたことを確認します。

コードの記述

Lambdaのコードを記述します。

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):
    
    # CallStatusを"OK"に変更
    status_ok()
    
    return {
        'statusCode': 200
    }