Menerapkan Pipeline Putar Ulang Acara dengan integrasi Amazon SNS

Halaman ini menunjukkan cara untuk men-deploy Alur Ulangan Peirstiwa dan berlanggananlah ke topik Amazon SNS. Proses ini secara otomatis mengubah AWS SAM template yang terkait dengan pipeline menjadi AWS CloudFormation tumpukan, dan kemudian menyebarkan tumpukan ke dalam file Anda Akun AWS. Proses ini juga menciptakan dan mengonfigurasi rangkaian sumber daya yang terdiri atas Alur Ulangan Peristiwa, termasuk antrean Amazon SQS dan fungsi Lambda.

Untuk informasi selengkapnya tentang filter peristiwa, lihat Kebijakan filter langganan Amazon SNS dalam panduan ini.

1. Masuk ke konsol AWS Lambda.

2. Pada panel navigasi, pilih Fungsi dan kemudian pilih Buat fungsi.

3. Pada halaman Buat fungsi, lakukan hal berikut ini:

   1. Pilih Jelajahi repositori aplikasi nirserver, Aplikasi publik, Tampilkan aplikasi yang membuat IAM role khusus atau kebijakan sumber daya.

   2. Cari untuk fork-event-replay-pipeline dan kemudian pilih aplikasi.

4. Pada fork-event-replay-pipelinehalaman, lakukan hal berikut:

   1. Di bagian Pengaturan aplikasi, masukkan Nama aplikasi(sebagai contoh, my-app-replay).

      catatan

      Untuk setiap deployment, nama aplikasi harus unik. Jika Anda menggunakan kembali nama aplikasi, penerapan hanya akan memperbarui AWS CloudFormation tumpukan yang digunakan sebelumnya (bukan membuat yang baru).

   2. (Opsional) Masukkan salah satu LogLevelpengaturan berikut untuk eksekusi fungsi Lambda aplikasi Anda:

      • DEBUG

      • ERROR

      • INFO (default)

      • WARNING

   3. (Opsional) Untuk ReplayQueueRetentionPeriodInSeconds, masukkan jumlah waktu, dalam detik, di mana antrean pemutaran ulang Amazon SQS menyimpan pesan. Jika Anda tidak memasukkan nilai, 1.209.600 detik (14 hari) akan digunakan.

   4. Untuk TopicArn, masukkan ARN dari topik Amazon SNS tempat instance pipa garpu ini akan berlangganan.

   5. Untuk DestinationQueueName, masukkan nama antrean Amazon SQS tempat fungsi replay Lambda meneruskan pesan.

   6. (Opsional) Untuk SubscriptionFilterPolicy, masukkan kebijakan filter langganan Amazon SNS, dalam format JSON, yang akan digunakan untuk memfilter peristiwa yang masuk. Kebijakan filter memutuskan peristiwa mana yang akan dibuffer untuk ulangan. Jika Anda tidak memasukkan nilai, tidak ada pemfilteran digunakan (semua peristiwa dibuffer untuk ulangan).

   7. Pilih Saya mengakui bahwa aplikasi ini menciptakan IAM role kustom, kebijakan sumber daya dan men-deploy aplikasi bersarang. dan kemudian pilih Deploy.

Pada status Deployment for my-app-replay page, Lambda menampilkan status Aplikasi Anda sedang di-deploy.

Di bagian Sumber Daya, AWS CloudFormation mulai membuat tumpukan dan menampilkan status CREATE_IN_PROGRESS untuk setiap sumber daya. Ketika proses selesai, AWS CloudFormation menampilkan status CREATE_COMPLETE.

Setelah deployment selesai, Lambda menampilkan status Aplikasi Anda telah di-deploy.

Pesan yang diterbitkan ke topik Amazon SNS Anda dibuffer untuk ulangan di antrean Amazon SQS yang ditetapkan oleh Alur Ulangan Peristiwa secara otomatis.

catatan

Secara default, ulangan dinonaktifkan. Untuk mengaktifkan ulangan, navigasikan ke halaman fungsi pada konsol Lambda, perluas bagian Desainer, pilih tile SQS dan kemudian, dalam bagian SQS, pilih Diaktifkan.