Amazon S3 イベント通知の s3:TestEvent を処理する

Amazon S3 はイベント通知の設定時に s3:TestEvent メッセージを送信します。通常のイベント通知とは構造が異なるため、コンシューマー側で個別に処理する必要があります。

Takahiro Iwasa

2020-12-29

3 min read

S3 バケットにイベント通知を設定すると、Amazon S3 から s3:TestEvent メッセージが自動的に送信されます。通常の S3 イベント通知とは構造が異なるため、コンシューマー側で個別に処理する必要があります。

https://docs.aws.amazon.com/AmazonS3/latest/userguide/notification-content-structure.html

When you configure an event notification on a bucket, Amazon S3 sends a test message with the s3:TestEvent.

構築

CloudFormation スタックのテンプレートを作成します。

1
AWSTemplateFormatVersion: "2010-09-09"
2
Description: Example of CloudWatch events not queueing to SSE SQS
3
Resources:
4
  Bucket:
5
    Type: AWS::S3::Bucket
6
    Properties:
7
      BucketEncryption:
8
        ServerSideEncryptionConfiguration:
9
          - ServerSideEncryptionByDefault:
10
              SSEAlgorithm: AES256
11
      NotificationConfiguration:
12
        QueueConfigurations:
13
          - Event: 's3:ObjectCreated:Put'
14
            Queue: !GetAtt Queue.Arn
15
      PublicAccessBlockConfiguration:
16
        BlockPublicAcls: true
17
        BlockPublicPolicy: true
18
        IgnorePublicAcls: true
19
        RestrictPublicBuckets: true
20

21
  Queue:
22
    Type: AWS::SQS::Queue
23
    Properties:
24
      QueueName: s3-event-notification-test-queue
25
      ReceiveMessageWaitTimeSeconds: 20
26

27
  QueuePolicy:
28
    Type: AWS::SQS::QueuePolicy
29
    Properties:
30
      PolicyDocument:
31
        Version: '2008-10-17'
32
        Statement:
33
          - Effect: Allow
34
            Principal:
35
              Service: s3.amazonaws.com
36
            Action:
37
              - SQS:SendMessage
38
              - SQS:ReceiveMessage
39
            Resource: !GetAtt Queue.Arn
40
            Condition:
41
              StringEquals:
42
                aws:SourceAccount: !Ref AWS::AccountId
43
      Queues:
44
        - !Ref Queue

スタックをデプロイします。

aws cloudformation deploy \
  --template-file template.yaml \
  --stack-name s3-event-notification-test

テスト

SQS キューをポーリングし、通知設定が機能していることを確認します。

aws sqs receive-message \
  --queue-url https://sqs.ap-northeast-1.amazonaws.com/{AccountId}/s3-event-notification-test-queue

バケットにオブジェクトを一つも追加していなくても、出力の中に s3:TestEvent メッセージが確認できるはずです。

1
{
2
  "Messages": [
3
    {
4
      "MessageId": "...",
5
      "ReceiptHandle": "...",
6
      "MD5OfBody": "...",
7
      "Body": "{\"Service\":\"Amazon S3\",\"Event\":\"s3:TestEvent\",\"Time\":\"2020-12-29T18:53:47.874Z\",\"Bucket\":\"s3-event-notification-test-bucket-xxxxxxxx\",\"RequestId\":\"...\",\"HostId\":\"...\"}"
8
    }
9
  ]
10
}

後片付け

作業後はスタックを削除します。

aws cloudformation delete-stack --stack-name s3-event-notification-test

まとめ

SQS イベント通知を設定した S3 バケットをデプロイすると、オブジェクトをアップロードする前に s3:TestEvent メッセージが届きます。このテンプレートでは s3:ObjectCreated:Put だけを設定していますが、テストメッセージは通知設定の作成時に自動送信されます。通常の S3 イベント通知とは異なり、最上位に Service と Event フィールドがあり、Records 配列はありません。

このキューを消費する Lambda 関数やアプリケーションでは、s3:TestEvent を検出してスキップするか、明示的に処理してください。すべてのメッセージに Records が含まれると仮定すると、通知設定の作成直後に処理が失敗する可能性があります。

記事一覧に戻る