EventBridge PipeとStepFunctionsでS3イベント通知を設定してみる

S3---(S3イベント通知)--->EventBridge Rule---(入力トランスフォーマーで整形)--->SNS

    {
      "Sid": "s3-event-notification",
      "Effect": "Allow",
      "Principal": {
        "Service": "s3.amazonaws.com"
      },
      "Action": "SQS:SendMessage",
      "Resource": "arn:aws:sqs:{リージョン}:{アカウントID}:{SQSキュー名}",
      "Condition": {
        "StringEquals": {
          "AWS:SourceArn": [
            "{任意のS3バケットのARN}"
          ]
        }
      }
    }

{
  "Comment": "S3イベントごとに分岐処理するStep Functions",
  "StartAt": "ExtractFirstRecord",
  "States": {
    "ExtractFirstRecord": {
      "Type": "Pass",
      "Parameters": {
        "Record.$": "$[0].Record"
      },
      "Next": "CheckEventType"
    },
    "CheckEventType": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.Record.eventName",
          "StringMatches": "ObjectCreated:*",
          "Next": "HandleObjectCreated"
        },
        {
          "Variable": "$.Record.eventName",
          "StringMatches": "ObjectRemoved:*",
          "Next": "HandleObjectRemoved"
        },
        {
          "Variable": "$.Record.eventName",
          "StringMatches": "Replication:*",
          "Next": "HandleReplication"
        }
      ],
      "Default": "HandleUnknownEvent"
    },
    "HandleObjectCreated": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "{SNSトピックのARN}",
        "Subject": "オブジェクト作成通知",
        "Message.$": "States.Format('S3バケットイベント通知\n\nイベント詳細:\n- イベント名: {}\n- 発生時刻: {}\n- リージョン: {}\n\nバケット情報:\n- バケット名: {}\n- バケットARN: {}\n\nオブジェクト情報:\n- オブジェクトキー: {}\n- サイズ: {} バイト\n- ETag: {}\n- バージョンID: {}\n\n操作ユーザー: {}\nソースIP: {}', $.Record.eventName, $.Record.eventTime, $.Record.awsRegion, $.Record.s3.bucket.name, $.Record.s3.bucket.arn, $.Record.s3.object.key, $.Record.s3.object.size, $.Record.s3.object.eTag, $.Record.s3.object.versionId, $.Record.userIdentity.principalId, $.Record.requestParameters.sourceIPAddress)"
      },
      "End": true
    },
    "HandleObjectRemoved": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "{SNSトピックのARN}",
        "Subject": "オブジェクト削除通知",
        "Message.$": "States.Format('S3バケットイベント通知\n\nイベント詳細:\n- イベント名: {}\n- 発生時刻: {}\n- リージョン: {}\n\nバケット情報:\n- バケット名: {}\n- バケットARN: {}\n\nオブジェクト情報:\n- 削除されたオブジェクトキー: {}\n- ETag: {}\n- バージョンID: {}\n\n操作ユーザー: {}\nソースIP: {}', $.Record.eventName, $.Record.eventTime, $.Record.awsRegion, $.Record.s3.bucket.name, $.Record.s3.bucket.arn, $.Record.s3.object.key, $.Record.s3.object.eTag, $.Record.s3.object.versionId, $.Record.userIdentity.principalId, $.Record.requestParameters.sourceIPAddress)"
      },
      "End": true
    },
    "HandleReplication": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "{SNSトピックのARN}",
        "Subject": "レプリケーションイベント通知",
        "Message.$": "States.Format('S3レプリケーション失敗通知\n\nイベント詳細:\n- イベント名: {}\n- 発生時刻: {}\n- リージョン: {}\n\nバケット情報:\n- ソースバケット名: {}\n- ソースバケットARN: {}\n\nオブジェクト情報:\n- オブジェクトキー: {}\n- サイズ: {} バイト\n- ETag: {}\n- バージョンID: {}\n\nレプリケーション情報:\n- レプリケーションルールID: {}\n- 宛先バケット: {}\n- S3操作: {}\n- リクエスト時間: {}\n- 失敗理由: {}', $.Record.eventName, $.Record.eventTime, $.Record.awsRegion, $.Record.s3.bucket.name, $.Record.s3.bucket.arn, $.Record.s3.object.key, $.Record.s3.object.size, $.Record.s3.object.eTag, $.Record.s3.object.versionId, $.Record.replicationEventData.replicationRuleId, $.Record.replicationEventData.destinationBucket, $.Record.replicationEventData.s3Operation, $.Record.replicationEventData.requestTime, $.Record.replicationEventData.failureReason)"
      },
      "End": true
    },
    "HandleUnknownEvent": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "TopicArn": "{SNSトピックのARN}",
        "Subject": "未知のイベント通知",
        "Message.$": "States.Format('{}', $.Record)"
      },
      "End": true
    }
  }
}

{
  "Record": <$.body.Records[0]>
}