Amazon Connectで個人向け電話コンシェルジュを作る

少し前になりますが「若者は電話に出ない」問題という記事が話題になりました。

私はその年代では無いですが、社会人になりたての頃は電話の応対で何度か注意を受けたことがありましたので、気持ちはわからないでも無いですね。なおさら最近ではSNSを通じたコミュニケーションが主流ですから、電話での会話に慣れておらず気後れしてしまうのでしょう。

また仕事などに集中している際、電話が掛かってくると中断してしまい集中力が削がれてしまうという問題も。大した用件でもないときは別の手段を利用して欲しいですよね。

とはいえ、世代によっては電話というメディアは大切な手段です。
そこで、昨年より東京リージョンにリリースされたAmazon Connectを利用し電話コンシェルジュサービスを立ち上げ、用件をLINEに通知できないかと考えてみました。

実現できること
アーキテクチャ
設定方法
動作確認／まとめ

実現できること

今回は以下のシナリオを実現することとします。

Amazon Connectの電話番号で個人用コンタクトセンターを立ち上げる
電話にて自分のステータス（仕事中/移動中/休憩中）を知らせることができる
代理で用件を受け付け、自分のLINEに通知できる
ステータスが休憩中のときのみ、電話の転送を受ける

ステータスの変更はいちいち面倒なので、今回もSORACOM LTE-M Button Powered by AWSを用いてボタン入力できるようにしてみます。

ざっくりフローはこんな感じ。
私専用の電話番号で一旦電話を受け、以下の処理ができるようにします。

状態を確認する（仕事中/移動中/休憩中)
メッセージを送る（元気/孤独/愛）
折り返しを希望する（本日中/明日/いつでも)
電話を転送する（休憩中のときのみ）

アーキテクチャ

アーキテクチャとしてはこのようになります。
電話の受電及び入力受付等（問い合わせフロー）をAmazon Connectが担当します。
また、以下３つのLambda関数を作成しました。

Amazon Connectでの入力に基づきLINE通知を行うもの
ボタンの入力に基づき自身の状態を変更するもの
自身の状態を取得するもの

なお自身の状態を保持するしくみには、自身を「モノ」と見立ててAWS IoT Coreのデバイスシャドウを用いました。（これが最も手っ取り早くて廉価と思います）

設定方法

設定方法を順を追って説明します。

Amazon Connectの初期設定

インスタンス作成

AWS マネジメントコンソールを開き、Amazon Connectのコンソールを開きます。
なお、東京リージョンであることを確認して下さい（日本の電話番号は東京リージョンに作成したインスタンスでしか利用できないため）

初回アクセス時には以下のような画面が出ますので「今すぐ始める」をクリックします。

まず「Amazon Connect内にユーザを保存」を指定し、Amazon ConnectのインスタンスURLを入力します。このURLは次章以降で開くコンソールのログインURLとなりますので、任意の名前を指定します。入力が終わったら「次のステップ」をクリックします。

管理者の名前を決めて入力します。自身の名前とユーザ名・パスワード・電子メールアドレスを入力し、「次のステップ」をクリックします。パスワードは大文字・小文字・数字を含み8文字以上とする必要があります。

本インスタンスで電話の発信・着信処理を行うかどうかの選択を行います。
両方にチェックを入れ「次のステップ」をクリックします。

本記事のしくみでは発信処理は行いませんので「着信通話」のみでも問題ありません。

データストレージを指定します。問い合わせフローのログやデータの保存先はAWSアカウントに紐付くS3バケットとなります。デフォルトで問題ありませんので、そのまま「次のステップ」をクリックします。

確認画面が表示されます。確認し「インスタンスの作成」を選択します。

インスタンスの作成には1～2分程度の時間が掛かります。

作成が完了したら「今すぐ始める」をクリックし、次項に進んでください。

電話番号の取得

続けて電話番号の取得を行います。
前項で作成したAmazon Connectインスタンスの開始画面に切り替わるので「今すぐ始める」をクリックします。

電話番号の取得を行います。「国/地域」からJapan(+81)を選択、タイプとして「Direct Dial」を選択すると、電話番号の欄に電話番号の候補が表示されます。お好みの電話番号を選択し「次へ」をクリックします。

Toll Free Dial（いわゆる0120/0800のフリーダイアル）も選択可能ですが、費用が異なります。
詳しくはこちらへ

電話番号が取得できました。
発信のテスト画面が表示されますが、ここではスキップして問題ありません。

Lambda関数の設置

準備① LINE notifyのトークン取得

LINEにメッセージを送信できるよう、LINE notifyのトークンを取得します。
こちらの記事を参考にしました。

[超簡単]LINE notify を使ってみる - Qiita

LINE notify を使ってみる概要簡単にトークルームにメッセージを送信できる特定のトークルームに一方的に通知するだけのシンプルな機能通知してくれるアカウント名などはカスタマイズできず、…

今回の主旨では自身のみ宛先のトークルームでよいと思いますが、グループで受けることも可能です。

準備② AWS IoT Coreの”モノ”作成

自身の状態を保存できるよう、AWS IoT Coreに”モノ”を作成します。
AWS マネジメントコンソールのAWS IoT Coreコンソールをから、「管理」→「モノ」を開きます。
続いて作成→単一のモノを作成するボタンをたどります。

作成画面にて名前を入力し登録を行います。

関数① LINEへの通知関数設置

電話をかけてきた方の入力をもとにLINEに通知する関数で、メッセージとスタンプを選択しています。
なお、LINE Notify経由で送信できるスタンプは標準提供のもののみであり、購入したスタンプは利用できません。

https://devdocs.line.me/files/sticker_list.pdf

import requests
import json
line_notify_url='https://notify-api.line.me/api/notify'
line_notify_token='(LINE NotifyのToken)'

def lambda_handler(event, context):
    # 入力値処理
    customerNumber = event['Details']['ContactData']['CustomerEndpoint']['Address']
    menu1 = event['Details']['Parameters']['menu1']
    menu2 = event['Details']['Parameters']['menu2']

    # 判断
    if menu1 == '.2':
        # メッセージを伝える
        if menu2 == '.1':
            # 元気を伝える
            comment = '元気を伝えるメッセージがありました'
            stamppkgid = 2
            stampid = 516
        elif menu2 == '.2':
            # 孤独を伝える
            comment = '孤独を伝えるメッセージがありました'
            stamppkgid = 2
            stampid = 18
        elif menu2 == '.3':
            # 愛を伝える
            comment = '愛を伝えるメッセージがありました'
            stamppkgid = 2
            stampid = 36
        elif menu2 == '.4':
            # 助けを求める
            comment = '助けを求めるメッセージがありました'
            stamppkgid = 1
            stampid = 104
    elif menu1 == '.3':
        # 折り返しを希望する
        stamppkgid = 2
        stampid = 47

        if menu2 == '.1':
            # 今日折り返しを希望
            comment = '今日中の電話折り返し希望がありました'
        elif menu2 == '.2':
            # 明日折り返しを希望
            comment = '明日の電話折り返し希望がありました'
        elif menu2 == '.3':
            # いつでもよい
            comment = '電話折り返し希望がありました'

    message = str(customerNumber) + 'から' + comment
    data = push_line(message,stamppkgid,stampid)

    return data
    
def push_line(message,stickerPackageId,stickerId):
    payload = {'message': message,'stickerPackageId': stickerPackageId, 'stickerId': stickerId}
    headers = {'Authorization': 'Bearer ' + line_notify_token}
    line_notify = requests.post(line_notify_url, data=payload, headers=headers).text
    data = json.loads(line_notify)
    return data

関数② ボタンからの入力受付関数設置

デバイスシャドウの内容を取得するだけの内容です。以下のような内容としました。
ロールにはAWSIoTDataAccessのポリシーが付与されている必要があります。

import requests
import json
import boto3
iot = boto3.client('iot-data')

thingName = 'human' 
line_notify_url='https://notify-api.line.me/api/notify'
line_notify_token='(LINE NotifyのToken)'

def lambda_handler(event, context):
    # 入力値取得
    clickType = event['deviceEvent']['buttonClicked']['clickType']
    status_single = event['placementInfo']['attributes']['status_single']
    status_double = event['placementInfo']['attributes']['status_double']
    status_long = event['placementInfo']['attributes']['status_long']

    # ボタンの入力タイプを取得し、ステータスを設定
    if clickType == "SINGLE":
        thingDesired = status_single
    elif clickType == "DOUBLE":
        thingDesired = status_double
    else:
        thingDesired = status_long
    
    # Shadowの状態を取得
    shadowStream = iot.get_thing_shadow(thingName = thingName)
    shadowString = json.loads(shadowStream['payload'].read().decode('utf-8'))
    thingStatus = shadowString['state']['reported']['status']

    if thingDesired != thingStatus:
        # IoT シャドウを更新
        payload = {"state": {"reported": {"status": thingDesired }}}
        response = iot.update_thing_shadow(
            thingName = thingName,
            payload = json.dumps(payload)
        )
        # LINEに通知
        message = 'ステータスを' + thingDesired + 'に設定しました'
        data = push_line(message)

    return data

def push_line(message):
    payload = {'message': message }
    headers = {'Authorization': 'Bearer ' + line_notify_token}
    line_notify = requests.post(line_notify_url, data=payload, headers=headers).text
    data = json.loads(line_notify)
    return data

関数③ デバイスシャドウ読み込み関数設置

デバイスシャドウの内容を取得するだけの内容です。以下のような内容としました。
こちらもロールにはAWSIoTDataAccessのポリシーが付与されている必要があります。

import json
import boto3
iot = boto3.client('iot-data')
thingName = 'human' 

def lambda_handler(event, context):
    # Shadowの状態を取得
    shadowStream = iot.get_thing_shadow(thingName = thingName)
    shadowString = json.loads(shadowStream['payload'].read().decode('utf-8'))
    thingStatus = shadowString['state']['reported']

    return thingStatus