Menyebarkan dan berlangganan Event Storage dan Backup Pipeline ke Amazon SNS - Amazon Simple Notification Service

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

Menyebarkan dan berlangganan Event Storage dan Backup Pipeline ke Amazon SNS

Untuk pengarsipan dan analitik acara, Amazon SNS sekarang merekomendasikan penggunaan integrasi aslinya dengan Amazon Data Firehose. Anda dapat berlangganan aliran pengiriman Firehose ke topik SNS, yang memungkinkan Anda mengirim pemberitahuan ke titik akhir pengarsipan dan analitik seperti bucket Amazon Simple Storage Service (Amazon S3), tabel Amazon Redshift, Amazon Service (Service), dan banyak lagi. OpenSearch OpenSearch Menggunakan Amazon SNS dengan aliran pengiriman Firehose adalah solusi yang dikelola sepenuhnya dan tanpa kode yang tidak mengharuskan Anda menggunakan fungsi. AWS Lambda Untuk informasi selengkapnya, lihat Aliran pengiriman Fanout ke Firehose.

Halaman ini menunjukkan cara untuk men-deploy Penyimpanan Peristiwa dan Alur Cadangan 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 Penyimpanan Peristiwa dan Alur Cadangan, termasuk yang berikut ini:

  • Antrean Amazon SQS

  • Fungsi Lambda

  • Aliran pengiriman Firehose

  • Bucket cadangan Amazon S3

Untuk informasi selengkapnya tentang mengonfigurasi streaming dengan bucket Amazon S3 sebagai tujuan, S3DestinationConfiguration lihat di Referensi API Amazon Data Firehose.

Untuk informasi selengkapnya tentang mengubah peristiwa dan tentang mengonfigurasi buffering peristiwa, kompresi peristiwa, dan enkripsi peristiwa, lihat Membuat Aliran Pengiriman Firehose Data Amazon di Panduan Pengembang Amazon Data Firehose.

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

  1. Masuk ke konsol AWS Lambda tersebut.

  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-storage-backup-pipeline dan kemudian pilih aplikasi.

  4. Pada halaman fork-event-storage-backup-pipeline, lakukan hal berikut:

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

      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) Untuk BucketArn, masukkan ARN bucket Amazon S3 tempat acara masuk dimuat. Jika Anda tidak memasukkan nilai, bucket Amazon S3 baru dibuat di akun Anda AWS .

    3. (Opsional) Untuk DataTransformationFunctionArn, masukkan ARN dari fungsi Lambda di mana peristiwa yang masuk diubah. Jika Anda tidak memasukkan nilai, pengubahan data dinonaktifkan.

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

      • DEBUG

      • ERROR

      • INFO (default)

      • WARNING

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

    6. (Opsional) Untuk StreamBufferingIntervalInSecondsdan StreamBufferingSizeInMBs, masukkan nilai untuk mengonfigurasi buffering peristiwa yang masuk. Jika Anda tidak memasukkan nilai berapa pun, 300 detik dan 5 MB digunakan.

    7. (Opsional) Masukkan salah satu StreamCompressionFormatpengaturan berikut untuk mengompresi peristiwa yang masuk:

      • GZIP

      • SNAPPY

      • UNCOMPRESSED (default)

      • ZIP

    8. (Opsional) Untuk StreamPrefix, masukkan awalan string untuk memberi nama file yang disimpan di bucket cadangan Amazon S3. Jika Anda tidak memasukkan nilai, prefiks tidak digunakan.

    9. (Opsional) Untuk SubscriptionFilterPolicy, masukkan kebijakan filter langganan Amazon SNS, dalam format JSON, yang akan digunakan untuk memfilter peristiwa yang masuk. Kebijakan filter menentukan peristiwa mana yang diindeks dalam indeks OpenSearch Layanan. Jika Anda tidak memasukkan nilai, tidak ada pemfilteran yang digunakan (semua peristiwa diindeks).

    10. (Opsional) Untuk SubscriptionFilterPolicyScope, masukkan string MessageBody atau MessageAttributes untuk mengaktifkan pemfilteran pesan berbasis muatan atau atribut.

    11. 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 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 dipublikasikan ke topik Amazon SNS Anda disimpan di bucket cadangan Amazon S3 yang disediakan oleh pipeline Penyimpanan Acara dan Pencadangan secara otomatis.