【運用自動化】Amazon Connectでシステム障害を即座に音声通知する仕組みを作ってみた

aws dynamodb put-item \
    --table-name <DynamoDBテーブル名> \
    --item '{
      "instance_id": {"S": "<EC2インスタンスID>"},
      "phonenumber": {"S": "<電話番号>"},
      "sns_arn": {"S": "<SNSトピックARN>"}
    }'

{
  "Comment": "EC2 インスタンス障害通知ワークフロー",
  "StartAt": "DynamoDB から情報取得",
  "States": {
    "DynamoDB から情報取得": {
      "Type": "Task",
      "Resource": "arn:aws:states:::dynamodb:getItem",
      "Parameters": {
        "TableName": "<DynamoDBテーブル名>",
        "Key": {
          "instance_id": {
            "S.$": "$.detail.configuration.metrics[0].metricStat.metric.dimensions.InstanceId"
          }
        }
      },
      "ResultPath": "$.dynamodb_result",
      "Next": "インスタンス情報が存在するか確認",
      "Catch": [
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "Next": "エラー処理",
          "ResultPath": "$.error"
        }
      ]
    },
    "インスタンス情報が存在するか確認": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.dynamodb_result.Item",
          "IsPresent": true,
          "Next": "メッセージ作成"
        }
      ],
      "Default": "インスタンス情報なし"
    },
    "メッセージ作成": {
      "Type": "Pass",
      "Parameters": {
        "instance_id.$": "$.detail.configuration.metrics[0].metricStat.metric.dimensions.InstanceId",
        "alarm_name.$": "$.detail.alarmName",
        "state.$": "$.detail.state.value",
        "reason.$": "$.detail.state.reason",
        "timestamp.$": "$.detail.state.timestamp",
        "sns_arn.$": "$.dynamodb_result.Item.sns_arn.S"
      },
      "ResultPath": "$.message_data",
      "Next": "SNS 通知送信"
    },
    "SNS 通知送信": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn.$": "$.message_data.sns_arn",
        "Subject": "【緊急】EC2 インスタンス障害通知",
        "Message.$": "States.Format('EC2 インスタンスで障害が発生しました。\n\n【詳細情報】\nインスタンスID: {}\nアラーム名: {}\n状態: {}\n理由: {}\n発生時刻: {}\n\n至急ご確認ください。', $.message_data.instance_id, $.message_data.alarm_name, $.message_data.state, $.message_data.reason, $.message_data.timestamp)"
      },
      "ResultPath": "$.sns_result",
      "Next": "Amazon Connect 発信"
    },
    "Amazon Connect 発信": {
      "Type": "Task",
      "Resource": "arn:aws:states:::aws-sdk:connect:startOutboundVoiceContact",
      "Parameters": {
        "InstanceId": "<AmazonConnectインスタンスID>",
        "ContactFlowId": "<AmazonConnectフローID>",
        "SourcePhoneNumber": "<AmazonConnectに登録した電話番号>",
        "DestinationPhoneNumber.$": "$.dynamodb_result.Item.phonenumber.S"
      },
      "ResultPath": "$.connect_result",
      "Next": "成功",
      "Catch": [
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "Next": "成功",
          "ResultPath": "$.connect_error"
        }
      ]
    },
    "成功": {
      "Type": "Succeed"
    },
    "インスタンス情報なし": {
      "Type": "Fail",
      "Error": "InstanceNotFound",
      "Cause": "指定されたインスタンスIDが DynamoDB に登録されていません"
    },
    "エラー処理": {
      "Type": "Fail",
      "Error": "WorkflowError",
      "Cause": "ワークフロー実行中にエラーが発生しました"
    }
  }
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "connect:StartOutboundVoiceContact",
            "Resource": "arn:aws:connect:ap-northeast-1:<AWSアカウントID>:instance/*/contact/*"
        }
    ]
}

{
  "source": ["aws.cloudwatch"],
  "detail-type": ["CloudWatch Alarm State Change"],
  "detail": {
    "alarmName": ["<CloudWatchアラーム名>"],
    "state": {
      "value": ["ALARM"]
    }
  }
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "states:StartExecution"
            ],
            "Resource": [
                "arn:aws:states:ap-northeast-1:<AWSアカウントID>:stateMachine:<StepFunctions名>"
            ]
        }
    ]
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": "events.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
        }
    ]
}

$ stress --cpu 2 --timeout 300s

{
    (...省略)
    "Parameters": {
        "TextToSpeechType": "text",
        "Text": "只今、システム障害が発生しました。\n詳細はメールにてご案内しております。",
        "Voice": "Kazuha"
    }
}