【Amazon Connect】エラー時の顧客情報をメール通知してみた

aws dynamodb put-item \
  --table-name <DynamoDB名> \
  --item '{
    "phonenumber": {"S": "+817012345678"},
    "customername": {"S": "YAMADA TARO"}
  }'

{
  "Comment": "Amazon Connect コンタクトタグ error=true を検知 -> DescribeContact の CustomerEndpoint.Address で電話番号を取得 -> DynamoDB 顧客情報照会 -> SNS メール通知",
  "StartAt": "コンタクト情報取得",
  "States": {
    "コンタクト情報取得": {
      "Type": "Task",
      "Resource": "arn:aws:states:::aws-sdk:connect:describeContact",
      "Parameters": {
        "InstanceId": "<ConnectインスタンスID>",
        "ContactId.$": "$.detail.contactId"
      },
      "ResultPath": "$.contactInfo",
      "Retry": [
        {
          "ErrorEquals": ["Connect.InternalServiceException", "States.Timeout"],
          "IntervalSeconds": 2,
          "MaxAttempts": 3,
          "BackoffRate": 2
        }
      ],
      "Catch": [
        {
          "ErrorEquals": ["States.ALL"],
          "ResultPath": "$.error",
          "Next": "エラー通知"
        }
      ],
      "Next": "電話番号存在チェック"
    },
    "電話番号存在チェック": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.contactInfo.Contact.CustomerEndpoint.Address",
          "IsPresent": true,
          "Next": "DynamoDB検索"
        }
      ],
      "Default": "電話番号未取得"
    },
    "電話番号未取得": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "arn:aws:sns:ap-northeast-1:<AWSアカウントID>:<SNSトピック名>",
        "Subject": "Amazon Connect 通知エラー: 電話番号未取得",
        "Message.$": "States.Format('ContactId: {} の CustomerEndpoint.Address が取得できませんでした。', $.detail.contactId)"
      },
      "End": true
    },
    "DynamoDB検索": {
      "Type": "Task",
      "Resource": "arn:aws:states:::dynamodb:getItem",
      "Parameters": {
        "TableName": "<DynamoDB名>",
        "Key": {
          "phonenumber": {
            "S.$": "$.contactInfo.Contact.CustomerEndpoint.Address"
          }
        }
      },
      "ResultPath": "$.dynamoItem",
      "Retry": [
        {
          "ErrorEquals": [
            "DynamoDB.ProvisionedThroughputExceededException",
            "DynamoDB.RequestLimitExceeded"
          ],
          "IntervalSeconds": 2,
          "MaxAttempts": 3,
          "BackoffRate": 2
        }
      ],
      "Catch": [
        {
          "ErrorEquals": ["States.ALL"],
          "ResultPath": "$.error",
          "Next": "エラー通知"
        }
      ],
      "Next": "顧客情報存在チェック"
    },
    "顧客情報存在チェック": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.dynamoItem.Item",
          "IsPresent": true,
          "Next": "顧客名設定"
        }
      ],
      "Default": "顧客名未設定"
    },
    "顧客名設定": {
      "Type": "Pass",
      "Parameters": {
        "value.$": "$.dynamoItem.Item.customername.S"
      },
      "ResultPath": "$.customerName",
      "Next": "メール通知"
    },
    "顧客名未設定": {
      "Type": "Pass",
      "Parameters": {
        "value": "未登録"
      },
      "ResultPath": "$.customerName",
      "Next": "メール通知"
    },
    "メール通知": {
      "Type": "Task",
      "QueryLanguage": "JSONata",
      "Resource": "arn:aws:states:::sns:publish",
      "Arguments": {
        "TopicArn": "arn:aws:sns:ap-northeast-1:<AWSアカウントID>:<SNSトピック名>",
        "Subject": "Amazon Connect エラー通知",
        "Message": "{% 'ContactId:' & $states.input.detail.contactId & '\n発生時刻:' & $fromMillis($toMillis($states.input.time), '[Y0001]-[M01]-[D01] [H01]:[m01]:[s01]', '+0900') & ' JST\n\n顧客名:' & $states.input.customerName.value & '\n電話番号:' & $states.input.contactInfo.Contact.CustomerEndpoint.Address & '\n\n予期しないエラーが発生しました。担当者は折り返しの電話を実施してください。' %}"
      },
      "End": true
    },
    "エラー通知": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "arn:aws:sns:ap-northeast-1:<AWSアカウントID>:<SNSトピック名>",
        "Subject": "connect-error-test-sfn 実行失敗",
        "Message.$": "States.Format('ステートマシンの処理中にエラーが発生しました。Error: {}', $.error.Error)"
      },
      "Next": "処理失敗"
    },
    "処理失敗": {
      "Type": "Fail",
      "Error": "ProcessingFailed",
      "Cause": "DescribeContact または DynamoDB GetItem でエラーが発生しました。"
    }
  }
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "connect:DescribeContact",
            "Resource": "arn:aws:connect:ap-northeast-1:*:instance/*/contact/*"
        }
    ]
}

{
  "source": ["aws.connect"],
  "detail-type": ["Amazon Connect Contact Event"],
  "detail": {
    "eventType": ["COMPLETED"],
    "tags": {
      "error": ["true"]
    }
  }
}