Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Putar ulang SNS pesan Amazon untuk pelanggan FIFO topik

Amazon SNS replay memungkinkan pelanggan topik mengambil pesan yang diarsipkan dari penyimpanan data topik dan mengirimkan ulang (atau memutar ulang) mereka ke titik akhir berlangganan. Pesan dapat diputar ulang segera setelah langganan dibuat. Pesan yang diputar ulang memiliki konten yang samaMessageId, dan Timestamp sebagai salinan asli, dan juga berisi atributReplayed, untuk membantu Anda mengidentifikasi bahwa itu adalah pesan yang diputar ulang. Untuk hanya memutar ulang pesan tertentu, Anda dapat menambahkan kebijakan filter ke langganan Anda. Untuk informasi lebih lanjut tentang memfilter pesan, lihatFilter pesan yang diputar ulang.

Membuat kebijakan pemutaran ulang pesan menggunakan AWS Management Console

Gunakan opsi ini untuk membuat kebijakan replay baru menggunakan. AWS Management Console

Untuk melihat dan mengedit kebijakan pemutaran ulang pesan

Anda dapat melakukan tindakan berikut dari halaman Detail langganan:

Tambahkan kebijakan pemutaran ulang ke langganan menggunakan API

Untuk memutar ulang pesan yang diarsipkan, gunakan atribut. ReplayPolicy ReplayPolicydapat digunakan dengan Subscribe dan SetSubscriptionAttributes API tindakan. Kebijakan ini memiliki nilai-nilai berikut:

Misalnya, untuk memulihkan dari kegagalan hilir dan mengirim ulang semua pesan untuk jangka waktu dua jam pada 1 Oktober 2023, gunakan SetSubscriptionAttributes API tindakan untuk menetapkan sebagai ReplayPolicy berikut:

{
  "PointType":"Timestamp", 
  "StartingPoint":"2023-10-01T10:00:00.000Z", 
  "EndingPoint":"2023-10-01T12:00:00.000Z"
}

Untuk memutar ulang semua pesan yang dikirim ke topik per 1 Oktober 2023, dan terus menerima semua pesan yang baru diterbitkan ke topik Anda, gunakan SetSubscriptionAttributes API tindakan untuk menetapkan langganan Anda sebagai berikut: ReplayPolicy

{
  "PointType":"Timestamp",
  "StartingPoint":"2023-10-01T00:00:00.000Z"
}

Untuk memverifikasi bahwa pesan telah diputar ulang, atribut boolean ditambahkan ke setiap pesan yang Replayed diputar ulang.

Tambahkan kebijakan pemutaran ulang ke langganan menggunakan SDK

Untuk menggunakan AWS SDK, Anda harus mengkonfigurasinya dengan kredensil Anda. Untuk informasi selengkapnya, lihat Berbagi config dan credentials file di Panduan Referensi Alat AWS SDKs dan Alat.

Contoh kode berikut menunjukkan cara menyetel langganan untuk mengirim ulang pesan dari arsip SNS FIFO topik Amazon untuk jangka waktu 2 jam pada 1 Oktober 2023. ReplayPolicy

// Specify the ARN of the Amazon SNS subscription to initiate the ReplayPolicy on.
String subscriptionArn =
    "arn:aws:sns:us-east-2:123456789012:MyArchiveTopic.fifo:1d2a3e9d-7f2f-447c-88ae-03f1c68294da";

// Set the ReplayPolicy to replay messages from the topic's archive 
// for a 2 hour time period on October 1st 2023 between 10am and 12pm UTC.
String replayPolicy =
    "{\"PointType\":\"Timestamp\",\"StartingPoint\":\"2023-10-01T10:00:00.000Z\",\"EndingPoint\":\"2023-10-01T12:00:00.000Z\"}";

// Set the ArchivePolicy for the Amazon SNS topic
SetSubscriptionAttributesRequest request = new SetSubscriptionAttributesRequest()
    .withSubscriptionArn(subscriptionArn)
    .withAttributeName("ReplayPolicy")
    .withAttributeValue(replayPolicy);
sns.setSubscriptionAttributes(request);

Memahami EndingPoint

Saat Anda menerapkan SNS langganan Amazon ReplayPolicy ke, EndingPoint nilainya opsional. Jika tidak EndingPoint disediakan, pemutaran ulang akan dimulai dari yang ditentukan StartingPoint dan berlanjut hingga mengikuti waktu saat ini, termasuk memproses pesan yang baru diterbitkan. Setelah tertangkap, langganan akan berfungsi sebagai langganan reguler, menerima pesan baru saat dipublikasikan.

Jika EndingPoint ditentukan, layanan akan memutar ulang pesan dari StartingPoint atas ke EndingPoint dan kemudian berhenti. Tindakan ini secara efektif menghentikan langganan. Saat langganan dijeda, pesan yang baru diterbitkan tidak akan dikirimkan ke titik akhir berlangganan.

Untuk melanjutkan pengiriman pesan, terapkan yang baru ReplayPolicy tanpa memberikanEndingPoint, dan atur StartingPoint ke titik waktu yang diinginkan untuk terus menerima pesan. Misalnya, untuk melanjutkan langganan dari tempat pemutaran ulang sebelumnya selesai, atur yang baru StartingPoint ke yang disediakan EndingPoint sebelumnya.

Filter pesan yang diputar ulang

Pemfilteran SNS pesan Amazon memungkinkan Anda mengontrol pesan yang diputar ulang yang SNS diputar ulang Amazon ke titik akhir pelanggan Anda. Saat pemfilteran pesan dan pengarsipan pesan diaktifkan, Amazon SNS pertama-tama mengambil pesan dari penyimpanan data topik, lalu menerapkan pesan terhadap langganan. FilterPolicy Pesan dikirim ke titik akhir berlangganan saat ada kecocokan, jika tidak, pesan akan disaring. Untuk informasi selengkapnya, lihat Kebijakan filter SNS langganan Amazon.

Pantau metrik pemutaran ulang pesan menggunakan Amazon CloudWatch

Anda dapat memantau pesan replay menggunakan Amazon CloudWatch menggunakan metrik berikut. Agar diberi tahu tentang anomali pada beban kerja Anda dan membantu menghindari dampak, Anda dapat mengonfigurasi CloudWatch alarm Amazon pada metrik ini. Untuk detail selengkapnya, lihat Pencatatan dan pemantauan di Amazon SNS.