FIFO トピック所有者の Amazon SNS メッセージアーカイブ

メッセージのアーカイブでは、トピックに発行されたすべてのメッセージの 1 つのコピーをアーカイブできます。トピックのメッセージアーカイブポリシーを有効にすることで、発行されたメッセージをトピック内に保存できます。これにより、そのトピックにリンクされているすべてのサブスクリプションのメッセージアーカイブが有効になります。メッセージのアーカイブ期間は、最短で 1 日、最長で 365 日です。

アーカイブポリシーを設定すると、追加料金がかかります。料金については、「Amazon SNS 料金」を参照してください。

AWS Management Console を使用するメッセージアーカイブポリシーを作成する

メッセージアーカイブトピックポリシーを表示、編集、非アクティブ化するには

API を使用するメッセージアーカイブポリシーを作成する

API を使用するメッセージアーカイブポリシーを作成するには、属性 ArchivePolicy をトピックに追加する必要があります。ArchivePolicy は、API アクション CreateTopic と SetTopicAttributes を使用して設定できます。 ArchivePolicy には Amazon SNS がメッセージを保持する日数を表す単一の値 MessageRetentionPeriod が含まれています。トピックのメッセージアーカイブを有効にするには、MessageRetentionPeriod を 0 より大きい整数値に設定します。たとえば、メッセージをアーカイブに 30 日間保持するには、ArchivePolicy を次のように設定します。

{
    "ArchivePolicy": {
        "MessageRetentionPeriod": "30"
    }
}

トピックのメッセージアーカイブを無効にしてアーカイブを消去するには、次のように ArchivePolicy の設定を解除します。

{}

SDK を使用するメッセージアーカイブポリシーを作成する

AWS SDK を使用するには、認証情報を使用して設定する必要があります。詳細については、『AWS SDK とツールのリファレンスガイド』の「config ファイルおよび credentials ファイル」を参照してください。

次のコード例は、Amazon SNS トピック用にそのトピックに発行されたすべてのメッセージを 30 日間保持するように ArchivePolicy を設定する方法を示しています。

// Specify the ARN of the Amazon SNS topic to set the ArchivePolicy for.
String topicArn =
    "arn:aws:sns:us-east-2:123456789012:MyArchiveTopic.fifo";

// Set the MessageRetentionPeriod to 30 days for the ArchivePolicy.
String archivePolicy =
    "{\"MessageRetentionPeriod\":\"30\"}";

// Set the ArchivePolicy for the Amazon SNS topic
SetTopicAttributesRequest request = new SetTopicAttributesRequest()
    .withTopicArn(topicArn)
    .withAttributeName("ArchivePolicy")
    .withAttributeValue(archivePolicy);
sns.setTopicAttributes(request);

AWS CloudFormation を使用するメッセージアーカイブポリシーを作成する

AWS CloudFormation を使用するアーカイブポリシーを作成するには、『AWS CloudFormation ユーザーガイド』の 「AWS::SNS::Topic」を参照してください。

暗号化されたアーカイブにアクセス権を付与する

暗号化されたトピックからのメッセージのリプレイをサブスクライバーが開始する前に、次の手順を完了する必要があります。過去のメッセージがリプレイされるため、Amazon SNS では、アーカイブ内のメッセージの暗号化に使用された KMS キーへの Decrypt アクセス権がプロビジョニングされている必要があります。

Amazon SNS に復号のアクセス権限を付与する

Amazon SNS がトピックのアーカイブ内の暗号化されたメッセージにアクセスし、サブスクライブされたエンドポイントにリプレイするには、Amazon SNS サービスプリンシパルでこれらのメッセージを復号する必要があります。

トピック内からの履歴メッセージのリプレイ中に、保存されたメッセージを Amazon SNS サービスプリンシパルが復号することを許可するために必要なポリシーの例を次に示します。

{
    "Sid": "Allow SNS to decrypt archived messages",
    "Effect": "Allow",
    "Principal": {
        "Service": "sns.amazonaws.com"
    },
    "Action": [
        "kms:Decrypt",
        "kms:GenerateDataKey"
    ],
    "Resource": "*"
}

Amazon CloudWatch を使用してメッセージアーカイブメトリクスをモニタリングする

Amazon CloudWatch では、以下のメトリックスを使用してアーカイブされたメッセージをモニタリングできます。ワークロードの異常を通知し、影響を回避するのに役立てるために、これらのメトリクスに Amazon CloudWatch アラームを設定できます。詳細については、「Amazon SNS でのログ記録とモニタリング」を参照してください。

GetTopicAttributes API には、購読者がリプレイを開始できる最も古いタイムスタンプを表す BeginningArchiveTime プロパティが含まれています。以下に、この API アクションのレスポンスの例を示します。

{
 "ArchivePolicy": {
    "MessageRetentionPeriod": "<integer>"
  },
  "BeginningArchiveTime": "<timestamp>",
  ...
}