Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Berlangganan AWS Event Fork Pipelines ke topik Amazon SNS
Untuk mempercepat pengembangan aplikasi berbasis peristiwa, Anda dapat berlangganan pipeline penanganan acara—yang didukung oleh pipa Event AWS Fork— ke topik Amazon SNS. AWS Event Fork Pipelines adalah rangkaian [aplikasi bersarang sumber terbuka, berdasarkan Model Aplikasi AWS](https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-template-nested-applications.html) [Tanpa Server](https://aws.amazon.com/serverless/sam/) (AWS SAM), yang dapat Anda gunakan langsung dari [rangkaian AWS Event Fork Pipelines](https://serverlessrepo.aws.amazon.com/applications?query=aws-event-fork-pipelines) (pilih **Tampilkan aplikasi yang membuat peran IAM kustom** atau kebijakan sumber daya) ke akun Anda. AWS Untuk informasi selengkapnya, lihat [Bagaimana AWS Event Fork Pipelines bekerja](sns-fork-pipeline-as-subscriber.md#how-sns-fork-works).
Bagian ini menunjukkan bagaimana Anda dapat menggunakan Konsol Manajemen AWS untuk menyebarkan pipeline dan kemudian berlangganan AWS Event Fork Pipelines ke topik Amazon SNS. Sebelum Anda memulai, [buat topik Amazon SNS](sns-create-topic.md).
Untuk menghapus sumber daya yang terdiri dari pipeline, cari pipeline di halaman **Applications** di AWS Lambda konsol, perluas **bagian template SAM**, pilih **CloudFormationstack, lalu pilih Other** **Actions**, **Delete Stack**.
# 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](sns-firehose-as-subscriber.md). |
Halaman ini menunjukkan cara untuk men-deploy [Penyimpanan Peristiwa dan Alur Cadangan](sns-fork-pipeline-as-subscriber.md#sns-fork-event-storage-and-backup-pipeline) dan berlanggananlah ke topik Amazon SNS. Proses ini secara otomatis mengubah AWS SAM template yang terkait dengan pipeline menjadi 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](https://docs.aws.amazon.com/firehose/latest/APIReference/API_S3DestinationConfiguration.html)` 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](https://docs.aws.amazon.com/firehose/latest/dev/basic-create.html) di Panduan Pengembang Amazon *Data Firehose*.
Untuk informasi selengkapnya tentang filter peristiwa, lihat [Kebijakan filter langganan Amazon SNS](sns-subscription-filter-policies.md) dalam panduan ini.
1. Masuk ke [konsol AWS Lambda](https://console.aws.amazon.com/lambda/).
1. Pada panel navigasi, pilih **Fungsi** dan kemudian pilih **Buat fungsi**.
1. 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**.
1. Cari untuk `fork-event-storage-backup-pipeline` dan kemudian pilih aplikasi.
1. 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 CloudFormation tumpukan yang digunakan sebelumnya (bukan membuat yang baru).
1. (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 .
1. (Opsional) Untuk **DataTransformationFunctionArn**, masukkan ARN dari fungsi Lambda di mana peristiwa yang masuk diubah. Jika Anda tidak memasukkan nilai, pengubahan data dinonaktifkan.
1. (Opsional) Masukkan salah satu **LogLevel**pengaturan berikut untuk eksekusi fungsi Lambda aplikasi Anda:
+ `DEBUG`
+ `ERROR`
+ `INFO` (default)
+ `WARNING`
1. Untuk **TopicArn**, masukkan ARN dari topik Amazon SNS tempat instance pipa garpu ini akan berlangganan.
1. (Opsional) Untuk **StreamBufferingIntervalInSeconds**dan **StreamBufferingSizeInMBs**, masukkan nilai untuk mengonfigurasi buffering peristiwa yang masuk. Jika Anda tidak memasukkan nilai berapa pun, 300 detik dan 5 MB digunakan.
1. (Opsional) Masukkan salah satu **StreamCompressionFormat**pengaturan berikut untuk mengompresi peristiwa yang masuk:
+ `GZIP`
+ `SNAPPY`
+ `UNCOMPRESSED` (default)
+ `ZIP`
1. (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.
1. (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).
1. (Opsional) Untuk **SubscriptionFilterPolicyScope**, masukkan string `MessageBody` atau `MessageAttributes` untuk mengaktifkan pemfilteran pesan berbasis muatan atau atribut.
1. 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**, CloudFormation mulai membuat tumpukan dan menampilkan status **CREATE\$1IN\$1PROGRESS** untuk setiap sumber daya. Ketika proses selesai, CloudFormation menampilkan status **CREATE\$1COMPLETE**.
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.
# Menyebarkan dan berlangganan Event Search dan Analytics 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](sns-firehose-as-subscriber.md). |
Halaman ini menunjukkan cara untuk men-deploy [Pencarian Peristiwa dan Alur Analitik](sns-fork-pipeline-as-subscriber.md#sns-fork-event-search-and-analytics-pipeline) dan berlanggananlah ke topik Amazon SNS. Proses ini secara otomatis mengubah AWS SAM template yang terkait dengan pipeline menjadi CloudFormation tumpukan, dan kemudian menyebarkan tumpukan ke dalam file Anda Akun AWS. Proses ini juga membuat dan mengonfigurasi rangkaian sumber daya yang terdiri atas Pencarian Peristiwa dan Alur Analitik, termasuk yang berikut ini:
+ Antrean Amazon SQS
+ Fungsi Lambda
+ Aliran pengiriman Firehose
+ Domain OpenSearch Layanan Amazon
+ Bucket suta mati Amazon S3
Untuk informasi selengkapnya tentang mengonfigurasi aliran dengan indeks sebagai tujuan, lihat `[ElasticsearchDestinationConfiguration](https://docs.aws.amazon.com/firehose/latest/APIReference/API_ElasticsearchDestinationConfiguration.html)` di Referensi *Amazon Data Firehose API*.
Untuk informasi selengkapnya tentang mengubah peristiwa dan tentang mengonfigurasi buffering peristiwa, kompresi peristiwa, dan enkripsi peristiwa, lihat [Membuat Aliran Pengiriman](https://docs.aws.amazon.com/firehose/latest/dev/basic-create.html) di Panduan Pengembang Amazon *Data Firehose*.
Untuk informasi selengkapnya tentang filter peristiwa, lihat [Kebijakan filter langganan Amazon SNS](sns-subscription-filter-policies.md) dalam panduan ini.
1. Masuk ke [konsol AWS Lambda](https://console.aws.amazon.com/lambda/).
1. Pada panel navigasi, pilih **Fungsi** dan kemudian pilih **Buat fungsi**.
1. 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**.
1. Cari untuk `fork-event-search-analytics-pipeline` dan kemudian pilih aplikasi.
1. Pada halaman **fork-event-search-analytics-pipeline**, lakukan hal berikut:
1. Di bagian **Pengaturan aplikasi**, masukkan **Nama aplikasi**(sebagai contoh, `my-app-search`).
**catatan**
Untuk setiap deployment, nama aplikasi harus unik. Jika Anda menggunakan kembali nama aplikasi, penerapan hanya akan memperbarui CloudFormation tumpukan yang digunakan sebelumnya (bukan membuat yang baru).
1. (Opsional) Untuk **DataTransformationFunctionArn**, masukkan ARN dari fungsi Lambda yang digunakan untuk mengubah peristiwa yang masuk. Jika Anda tidak memasukkan nilai, pengubahan data dinonaktifkan.
1. (Opsional) Masukkan salah satu **LogLevel**pengaturan berikut untuk eksekusi fungsi Lambda aplikasi Anda:
+ `DEBUG`
+ `ERROR`
+ `INFO` (default)
+ `WARNING`
1. (Opsional) Untuk **SearchDomainArn**, masukkan ARN domain OpenSearch Layanan, klaster yang mengonfigurasi fungsionalitas komputasi dan penyimpanan yang diperlukan. Jika Anda tidak memasukkan nilai, domain baru dibuat dengan konfigurasi default.
1. Untuk **TopicArn**, masukkan ARN dari topik Amazon SNS tempat instance pipa garpu ini akan berlangganan.
1. Untuk **SearchIndexName**, masukkan nama indeks OpenSearch Layanan untuk pencarian acara dan analitik.
**catatan**
Kuota berikut ini berlaku untuk nama indeks:
Tidak dapat menyertakan huruf besar
Tidak dapat menyertakan karakter berikut ini: `\ / * ? " < > | ` , #`
Tidak dapat dimulai dengan karakter berikut ini: `- + _`
Tidak boleh sebagai berikut: `. ..`
Tidak boleh lebih dari 80 karakter
Tidak boleh lebih dari 255 byte
Tidak dapat berisi titik dua (dari OpenSearch Layanan 7.0)
1. (Opsional) Masukkan salah satu **SearchIndexRotationPeriod**pengaturan berikut untuk periode rotasi indeks OpenSearch Layanan:
+ `NoRotation` (default)
+ `OneDay`
+ `OneHour`
+ `OneMonth`
+ `OneWeek`
Rotasi indeks menambahkan timestamp untuk nama indeks, yang memfasilitasi kedaluwarsanya data lama.
1. Untuk **SearchTypeName**, masukkan nama jenis OpenSearch Layanan untuk mengatur acara dalam indeks.
**catatan**
OpenSearch Nama tipe layanan dapat berisi karakter apa pun (kecuali byte nol) tetapi tidak dapat dimulai dengan. `_`
Untuk OpenSearch Layanan 6.x, hanya ada satu jenis per indeks. Jika Anda menentukan tipe baru untuk indeks yang sudah ada yang sudah memiliki tipe lain, Firehose akan menampilkan error runtime.
1. (Opsional) Untuk **StreamBufferingIntervalInSeconds**dan **StreamBufferingSizeInMBs**, masukkan nilai untuk mengonfigurasi buffering peristiwa yang masuk. Jika Anda tidak memasukkan nilai berapa pun, 300 detik dan 5 MB digunakan.
1. (Opsional) Masukkan salah satu **StreamCompressionFormat**pengaturan berikut untuk mengompresi peristiwa yang masuk:
+ `GZIP`
+ `SNAPPY`
+ `UNCOMPRESSED` (default)
+ `ZIP`
1. (Opsional) Untuk **StreamPrefix**, masukkan awalan string untuk memberi nama file yang disimpan di bucket surat mati Amazon S3. Jika Anda tidak memasukkan nilai, prefiks tidak digunakan.
1. (Opsional) Untuk **StreamRetryDurationInSecons**, masukkan durasi coba lagi untuk kasus ketika Firehose tidak dapat mengindeks peristiwa dalam OpenSearch indeks Layanan. Jika Anda tidak memasukkan nilai, maka 300 detik akan digunakan.
1. (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).
1. 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-search*** page, Lambda menampilkan status **Aplikasi Anda sedang** di-deploy.
Di bagian **Sumber Daya**, CloudFormation mulai membuat tumpukan dan menampilkan status **CREATE\$1IN\$1PROGRESS** untuk setiap sumber daya. Ketika proses selesai, CloudFormation menampilkan status **CREATE\$1COMPLETE**.
Setelah deployment selesai, Lambda menampilkan status **Aplikasi Anda telah di-deploy**.
Pesan yang dipublikasikan ke topik Amazon SNS Anda diindeks dalam indeks OpenSearch Layanan yang disediakan oleh pipeline Event Search dan Analytics secara otomatis. Jika pipeline tidak dapat mengindeks suatu peristiwa, ia menyimpannya di ember surat mati Amazon S3.
# Menerapkan Pipeline Putar Ulang Acara dengan integrasi Amazon SNS
Halaman ini menunjukkan cara untuk men-deploy [Alur Ulangan Peirstiwa](sns-fork-pipeline-as-subscriber.md#sns-fork-event-replay-pipeline) dan berlanggananlah ke topik Amazon SNS. Proses ini secara otomatis mengubah AWS SAM template yang terkait dengan pipeline menjadi 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](sns-subscription-filter-policies.md) dalam panduan ini.
1. Masuk ke [konsol AWS Lambda](https://console.aws.amazon.com/lambda/).
1. Pada panel navigasi, pilih **Fungsi** dan kemudian pilih **Buat fungsi**.
1. 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**.
1. Cari untuk `fork-event-replay-pipeline` dan kemudian pilih aplikasi.
1. Pada **fork-event-replay-pipeline**halaman, 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 CloudFormation tumpukan yang digunakan sebelumnya (bukan membuat yang baru).
1. (Opsional) Masukkan salah satu **LogLevel**pengaturan berikut untuk eksekusi fungsi Lambda aplikasi Anda:
+ `DEBUG`
+ `ERROR`
+ `INFO` (default)
+ `WARNING`
1. (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.
1. Untuk **TopicArn**, masukkan ARN dari topik Amazon SNS tempat instance pipa garpu ini akan berlangganan.
1. Untuk **DestinationQueueName**, masukkan nama antrean Amazon SQS tempat fungsi replay Lambda meneruskan pesan.
1. (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).
1. 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**, CloudFormation mulai membuat tumpukan dan menampilkan status **CREATE\$1IN\$1PROGRESS** untuk setiap sumber daya. Ketika proses selesai, CloudFormation menampilkan status **CREATE\$1COMPLETE**.
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**.