Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Mengelola pesan Amazon SNS di beberapa tujuan aliran pengiriman
[aliran pengiriman](sns-firehose-as-subscriber.md) memungkinkan Anda mengelola pesan Amazon SNS di beberapa tujuan, memungkinkan integrasi dengan Amazon S3, Layanan Amazon, Amazon Redshift, dan titik akhir HTTP untuk penyimpanan OpenSearch , pengindeksan, dan analisis. Dengan mengonfigurasi pemformatan dan pengiriman pesan dengan benar, Anda dapat menyimpan notifikasi Amazon SNS di Amazon S3 untuk diproses nanti, menganalisis data pesan terstruktur menggunakan Amazon Athena, mengindeks pesan untuk pencarian dan visualisasi waktu nyata, dan menyusun arsip OpenSearch di Amazon Redshift untuk kueri lanjutan.
# Menyimpan dan menganalisis pesan Amazon SNS di tujuan Amazon S3
Topik ini menjelaskan cara streaming pengiriman mempublikasikan data ke Amazon Simple Storage Service (Amazon S3).
![\[Integrasi dan alur kerja layanan Amazon untuk penanganan pesan. Ini menunjukkan bagaimana penerbit mengirim pesan ke topik Amazon SNS, yang kemudian mengirimkan pesan ke beberapa antrian Amazon SQS dan aliran pengiriman Data Firehose. Dari sana, pesan dapat diproses oleh fungsi Lambda atau disimpan secara persisten di bucket Amazon S3.\]](http://docs.aws.amazon.com/id_id/sns/latest/dg/images/firehose-architecture-s3.png)
**Topics**
+ [Memformat pemberitahuan untuk penyimpanan di tujuan Amazon S3](firehose-archived-message-format-S3.md)
+ [Menganalisis pesan yang disimpan di Amazon S3 menggunakan Athena](firehose-message-analysis-s3.md)
# Memformat notifikasi Amazon SNS untuk penyimpanan di tujuan Amazon S3
Contoh berikut menunjukkan notifikasi Amazon SNS yang dikirim ke bucket Amazon Simple Storage Service (Amazon S3), dengan lekukan agar mudah dibaca.
**catatan**
Dalam contoh ini, pengiriman pesan mentah dinonaktifkan untuk pesan yang diterbitkan. Ketika pengiriman pesan mentah dinonaktifkan, Amazon SNS menambahkan metadata JSON ke pesan, termasuk properti tersebut:
`Type`
`MessageId`
`TopicArn`
`Subject`
`Timestamp`
`UnsubscribeURL`
`MessageAttributes`
Untuk informasi selengkapnya tentang pengiriman mentah, lihat [Pengiriman pesan mentah Amazon SNS](sns-large-payload-raw-message-delivery.md).
```
{
"Type": "Notification",
"MessageId": "719a6bbf-f51b-5320-920f-3385b5e9aa56",
"TopicArn": "arn:aws:sns:us-east-1:333333333333:my-kinesis-test-topic",
"Subject": "My 1st subject",
"Message": "My 1st body",
"Timestamp": "2020-11-26T23:48:02.032Z",
"UnsubscribeURL": "https://sns.us-east-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-east-1:333333333333:my-kinesis-test-topic:0b410f3c-ee5e-49d8-b59b-3b4aa6d8fcf5",
"MessageAttributes": {
"myKey1": {
"Type": "String",
"Value": "myValue1"
},
"myKey2": {
"Type": "String",
"Value": "myValue2"
}
}
}
```
Contoh berikut menunjukkan tiga pesan SNS yang dikirim melalui aliran pengiriman ke bucket Amazon S3 yang sama. Buffering diterapkan, dan jeda baris memisahkan setiap pesan.
```
{"Type":"Notification","MessageId":"d7d2513e-6126-5d77-bbe2-09042bd0a03a","TopicArn":"arn:aws:sns:us-east-1:333333333333:my-kinesis-test-topic","Subject":"My 1st subject","Message":"My 1st body","Timestamp":"2020-11-27T00:30:46.100Z","UnsubscribeURL":"https://sns.us-east-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-east-1:313276652360:my-kinesis-test-topic:0b410f3c-ee5e-49d8-b59b-3b4aa6d8fcf5","MessageAttributes":{"myKey1":{"Type":"String","Value":"myValue1"},"myKey2":{"Type":"String","Value":"myValue2"}}}
{"Type":"Notification","MessageId":"0c0696ab-7733-5bfb-b6db-ce913c294d56","TopicArn":"arn:aws:sns:us-east-1:333333333333:my-kinesis-test-topic","Subject":"My 2nd subject","Message":"My 2nd body","Timestamp":"2020-11-27T00:31:22.151Z","UnsubscribeURL":"https://sns.us-east-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-east-1:313276652360:my-kinesis-test-topic:0b410f3c-ee5e-49d8-b59b-3b4aa6d8fcf5","MessageAttributes":{"myKey1":{"Type":"String","Value":"myValue1"}}}
{"Type":"Notification","MessageId":"816cd54d-8cfa-58ad-91c9-8d77c7d173aa","TopicArn":"arn:aws:sns:us-east-1:333333333333:my-kinesis-test-topic","Subject":"My 3rd subject","Message":"My 3rd body","Timestamp":"2020-11-27T00:31:39.755Z","UnsubscribeURL":"https://sns.us-east-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-east-1:313276652360:my-kinesis-test-topic:0b410f3c-ee5e-49d8-b59b-3b4aa6d8fcf5"}
```
# Menganalisis pesan Amazon SNS yang disimpan di Amazon S3 menggunakan Athena
Halaman ini menjelaskan cara menganalisis pesan Amazon SNS yang dikirim melalui aliran pengiriman ke tujuan Amazon Simple Storage Service (Amazon S3).
**Untuk menganalisis pesan SNS yang dikirim melalui aliran pengiriman Firehose ke tujuan Amazon S3**
1. Konfigurasi sumber daya Amazon S3 Anda. Untuk petunjuknya, lihat [Membuat bucket](https://docs.aws.amazon.com/AmazonS3/latest/userguide/CreatingABucket.html) di *Panduan Pengguna Layanan Penyimpanan Sederhana Amazon* dan [Bekerja dengan Bucket Amazon S3](https://docs.aws.amazon.com/AmazonS3/latest/userguide/UsingBucket.html) di Panduan Pengguna *Layanan Penyimpanan Sederhana Amazon*.
1. Konfigurasi aliran pengiriman Anda. Untuk petunjuknya, lihat [Memilih Amazon S3 untuk Tujuan Anda di Panduan](https://docs.aws.amazon.com/firehose/latest/dev/create-destination.html#create-destination-s3) Pengembang *Amazon Data Firehose*.
1. Gunakan [Amazon Athena](https://console.aws.amazon.com/athena) untuk kueri objek Amazon S3 menggunakan SQL standar. Untuk informasi selanjutnya, lihat [Memulai](https://docs.aws.amazon.com/athena/latest/ug/getting-started.html) dalam *Panduan Pengguna Amazon Athena*.
## Kueri contoh
Untuk kueri contoh ini, asumsikan berikut ini:
+ Pesan disimpan dalam tabel `notifications` di skema `default`.
+ Tabel `notifications` mencakup kolom `timestamp` dengan jenis `string`.
Kueri berikut ini mengembalikan semua pesan SNS yang diterima dalam rentang tanggal yang ditentukan:
```
SELECT *
FROM default.notifications
WHERE from_iso8601_timestamp(timestamp) BETWEEN TIMESTAMP '2020-12-01 00:00:00' AND TIMESTAMP '2020-12-02 00:00:00';
```
# Mengintegrasikan pesan Amazon SNS dengan tujuan Layanan Amazon OpenSearch
Bagian ini menjelaskan bagaimana aliran pengiriman mempublikasikan data ke OpenSearch Layanan Amazon (OpenSearch Layanan).
![\[Penerbit mengirim pesan ke topik Amazon SNS, yang kemudian mendistribusikan pesan-pesan ini ke beberapa antrian Amazon SQS. Pesan dari antrian ini dapat diproses oleh fungsi Lambda atau dikirim melalui aliran pengiriman Firehose Data ke OpenSearch Layanan Amazon, membuat indeks pesan yang dapat dicari. Pengaturan ini menunjukkan perutean pesan lanjutan dan skenario pemrosesan menggunakan. Layanan AWS\]](http://docs.aws.amazon.com/id_id/sns/latest/dg/images/firehose-architecture-es.png)
**Topics**
+ [Format pesan yang diarsipkan](firehose-archived-message-format-elasticsearch.md)
+ [Menganalisis pesan](firehose-message-analysis-elasticsearch.md)
# Menyimpan dan memformat Pemberitahuan OpenSearch Amazon SNS dalam indeks Layanan
Contoh berikut menunjukkan notifikasi Amazon SNS yang dikirim ke indeks Layanan OpenSearch Amazon OpenSearch (Layanan) yang disebut. `my-index` Indeks ini memiliki bidang filter waktu pada bidang `Timestamp`. Notifikasi SNS ditempatkan di properti `_source` dari muatan.
**catatan**
Dalam contoh ini, pengiriman pesan mentah dinonaktifkan untuk pesan yang diterbitkan. Ketika pengiriman pesan mentah dinonaktifkan, Amazon SNS menambahkan metadata JSON ke pesan, termasuk properti tersebut:
`Type`
`MessageId`
`TopicArn`
`Subject`
`Timestamp`
`UnsubscribeURL`
`MessageAttributes`
Untuk informasi selengkapnya tentang pengiriman mentah, lihat [Pengiriman pesan mentah Amazon SNS](sns-large-payload-raw-message-delivery.md).
```
{
"_index": "my-index",
"_type": "_doc",
"_id": "49613100963111323203250405402193283794773886550985932802.0",
"_version": 1,
"_score": null,
"_source": {
"Type": "Notification",
"MessageId": "bf32e294-46e3-5dd5-a6b3-bad65162e136",
"TopicArn": "arn:aws:sns:us-east-1:111111111111:my-topic",
"Subject": "Sample subject",
"Message": "Sample message",
"Timestamp": "2020-12-02T22:29:21.189Z",
"UnsubscribeURL": "https://sns.us-east-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-east-1:111111111111:my-topic:b5aa9bc1-9c3d-452b-b402-aca2cefc63c9",
"MessageAttributes": {
"my_attribute": {
"Type": "String",
"Value": "my_value"
}
}
},
"fields": {
"Timestamp": [
"2020-12-02T22:29:21.189Z"
]
},
"sort": [
1606948161189
]
}
```
# Menganalisis pesan Amazon SNS untuk tujuan Layanan OpenSearch
Topik ini menjelaskan cara menganalisis pesan Amazon SNS yang dikirim melalui aliran pengiriman ke tujuan OpenSearch Layanan Amazon (OpenSearch Layanan).
**Untuk menganalisis pesan SNS yang dikirim melalui aliran OpenSearch pengiriman Firehose ke tujuan Layanan**
1. Konfigurasikan sumber daya OpenSearch Layanan Anda. Untuk petunjuk, lihat [Memulai OpenSearch Layanan Amazon](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/es-gsg.html) di *Panduan Pengembang OpenSearch Layanan Amazon*.
1. Konfigurasi aliran pengiriman Anda. Untuk petunjuknya, lihat [Memilih OpenSearch Layanan untuk Tujuan Anda](https://docs.aws.amazon.com/firehose/latest/dev/create-destination.html#create-destination-elasticsearch) di Panduan *Pengembang Amazon Data Firehose*.
1. Jalankan kueri menggunakan kueri OpenSearch Layanan dan Kibana. Untuk informasi selengkapnya, lihat [Langkah 3: Cari Dokumen di Domain OpenSearch Layanan](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/es-gsg-search.html) dan [Kibana](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/es-kibana.html) di Panduan *Pengembang OpenSearch Layanan Amazon*.
## Kueri contoh
Contoh berikut ini membuat kueri untuk indeks `my-index` untuk semua pesan SNS yang diterima dalam rentang tanggal yang ditentukan:
```
POST https://search-my-domain.us-east-1.es.amazonaws.com/my-index/_search
{
"query": {
"bool": {
"filter": [
{
"range": {
"Timestamp": {
"gte": "2020-12-08T00:00:00.000Z",
"lte": "2020-12-09T00:00:00.000Z",
"format": "strict_date_optional_time"
}
}
}
]
}
}
}
```
# Mengonfigurasi pengiriman dan analisis pesan Amazon SNS di tujuan Amazon Redshift
Topik ini menjelaskan cara menyebarkan notifikasi Amazon SNS ke aliran pengiriman, yang kemudian menerbitkan data ke Amazon Redshift. Dengan pengaturan ini, Anda dapat terhubung ke database Amazon Redshift dan menggunakan alat kueri SQL untuk mengambil pesan Amazon SNS yang sesuai dengan kriteria tertentu.
![\[Pesan yang diterbitkan oleh pengirim ke topik Amazon SNS didistribusikan ke beberapa antrian Amazon SQS untuk diproses oleh fungsi Lambda, dan juga dikirim melalui aliran pengiriman Firehose Data ke cluster Amazon Redshift untuk penyimpanan dan analisis di gudang data pesan. Pengaturan ini menunjukkan penanganan pesan yang kuat dan arsitektur pergudangan data menggunakan. Layanan AWS\]](http://docs.aws.amazon.com/id_id/sns/latest/dg/images/firehose-architecture-rs.png)
**Topics**
+ [Menyusun arsip pesan di tabel Amazon Redshift](firehose-archive-table-structure-redshift.md)
+ [Menganalisis pesan yang disimpan di tujuan Amazon Redshift](firehose-message-analysis-redshift.md)
# Menata arsip pesan Amazon SNS di tabel Amazon Redshift
Untuk titik akhir Amazon Redshift, pesan Amazon SNS diarsipkan sebagai baris dalam tabel. Berikut adalah contoh bagaimana data disimpan:
**catatan**
Dalam contoh ini, pengiriman pesan mentah dinonaktifkan untuk pesan yang diterbitkan. Ketika pengiriman pesan mentah dinonaktifkan, Amazon SNS menambahkan metadata JSON ke pesan, termasuk properti tersebut:
`Type`
`MessageId`
`TopicArn`
`Subject`
`Message`
`Timestamp`
`UnsubscribeURL`
`MessageAttributes`
Untuk informasi selengkapnya tentang pengiriman mentah, lihat [Pengiriman pesan mentah Amazon SNS](sns-large-payload-raw-message-delivery.md).
Meskipun Amazon SNS menambahkan properti ke pesan menggunakan kapitalisasi yang ditampilkan dalam daftar ini, nama kolom di tabel Amazon Redshift muncul dalam semua karakter huruf kecil. Untuk mengubah metadata JSON untuk titik akhir Amazon Redshift, Anda dapat menggunakan perintah `COPY` SQL. Untuk informasi selengkapnya, lihat [Salin dari contoh JSON](https://docs.aws.amazon.com/redshift/latest/dg/r_COPY_command_examples.html#r_COPY_command_examples-copy-from-json) dan [Muat dari data JSON menggunakan opsi 'auto ignorecase'](https://docs.aws.amazon.com/redshift/latest/dg/r_COPY_command_examples.html#copy-from-json-examples-using-auto-ignorecase) di *Panduan Developer Basis Data Amazon Redshift*.
| jenis | messageid | topicarn | subjek | pesan | timestamp | unsubscribeurl | messageattributes |
| --- | --- | --- | --- | --- | --- | --- | --- |
| Notifikasi | ea544832-a0d8-581d-9275-108243c46103 | arn:aws:sns:us-east-1:111111111111:my-topic | Subjek sampel | Pesan sampel | 2020-12-02T00:33:32.272Z | https://sns.us-east-1.amazonaws.com/? Action=Berhenti berlangganan & =arn:aws:sns:us-east- 1:1111111111: SubscriptionArn my-topik:326deeeb-cbf4-45da-b92b-ca77a247813b | \$1\$1"my\$1attribute\$1":\$1\$1"Type\$1":\$1"String\$1",\$1"Value\$1":\$1"my\$1value\$1"\$1\$1 |
| Notifikasi | ab124832-a0d8-581d-9275-108243c46114 | arn:aws:sns:us-east-1:111111111111:my-topic | Subjek sampel 2 | Pesan sampel 2 | 2020-12-03T00:18:11.129Z | https://sns.us-east-1.amazonaws.com/? Action=Berhenti berlangganan & =arn:aws:sns:us-east- 1:1111111111: SubscriptionArn my-topik:326deeeb-cbf4-45da-b92b-ca77a247813b | \$1\$1"my\$1attribute2\$1":\$1\$1"Type\$1":\$1"String\$1",\$1"Value\$1":\$1"my\$1value\$1"\$1\$1 |
| Notifikasi | ce644832-a0d8-581d-9275-108243c46125 | arn:aws:sns:us-east-1:111111111111:my-topic | Subjek sampel 3 | Pesan sampel 3 | 2020-12-09T00:08:44.405Z | https://sns.us-east-1.amazonaws.com/? Action=Berhenti berlangganan & =arn:aws:sns:us-east- 1:1111111111: SubscriptionArn my-topik:326deeeb-cbf4-45da-b92b-ca77a247813b | \$1\$1"my\$1attribute3\$1":\$1\$1"Type\$1":\$1"String\$1",\$1"Value\$1":\$1"my\$1value\$1"\$1\$1 |
Untuk informasi selengkapnya tentang fan out notifikasi ke titik akhir Amazon Redshift, lihat [Mengonfigurasi pengiriman dan analisis pesan Amazon SNS di tujuan Amazon Redshift](firehose-redshift-destinations.md).
# Menganalisis pesan Amazon SNS yang disimpan di tujuan Amazon Redshift
Topik ini menjelaskan cara menganalisis pesan Amazon SNS yang dikirim melalui aliran pengiriman ke tujuan Amazon Redshift.
**Untuk menganalisis pesan SNS yang dikirim melalui aliran pengiriman Firehose ke tujuan Amazon Redshift**
1. Konfigurasi sumber daya Amazon Redshift. Untuk instruksi, lihat [Memulai dengan Amazon Redshift](https://docs.aws.amazon.com/redshift/latest/gsg/getting-started.html) di *Panduan Memulai Amazon Redshift*.
1. Konfigurasi aliran pengiriman Anda. Untuk petunjuknya, lihat [Memilih Amazon Redshift untuk Tujuan Anda di Panduan](https://docs.aws.amazon.com/firehose/latest/dev/create-destination.html#create-destination-redshift) Pengembang *Amazon Data Firehose*.
1. Jalankan kueri. Untuk informasi selengkapnya, lihat [Menanyakan database menggunakan editor kueri](https://docs.aws.amazon.com/redshift/latest/mgmt/query-editor.html) di Panduan Manajemen *Amazon Redshift*.
## Kueri contoh
Untuk kueri contoh ini, asumsikan berikut ini:
+ Pesan disimpan dalam tabel `notifications` di skema `public` default.
+ Properti `Timestamp` dari pesan SNS disimpan dalam kolom `timestamp` tabel dengan jenis data kolom `timestamptz`.
**catatan**
Untuk mengubah metadata JSON untuk titik akhir Amazon Redshift, Anda dapat menggunakan perintah `COPY` SQL. Untuk informasi selengkapnya, lihat [Salin dari contoh JSON](https://docs.aws.amazon.com/redshift/latest/dg/r_COPY_command_examples.html#r_COPY_command_examples-copy-from-json) dan [Muat dari data JSON menggunakan opsi 'auto ignorecase'](https://docs.aws.amazon.com/redshift/latest/dg/r_COPY_command_examples.html#copy-from-json-examples-using-auto-ignorecase) di *Panduan Developer Basis Data Amazon Redshift*.
Kueri berikut ini mengembalikan semua pesan SNS yang diterima dalam rentang tanggal yang ditentukan:
```
SELECT *
FROM public.notifications
WHERE timestamp > '2020-12-01T09:00:00.000Z' AND timestamp < '2020-12-02T09:00:00.000Z';
```
# Mengonfigurasi pengiriman pesan Amazon SNS ke tujuan HTTP menggunakan
Topik ini menjelaskan bagaimana aliran pengiriman mempublikasikan data ke titik akhir HTTP.
![\[Penerbit untuk topik Amazon SNS, yang kemudian mendistribusikan pesan ke beberapa antrian Amazon SQS. Pesan-pesan ini diproses oleh fungsi Lambda dan juga dikirim melalui aliran pengiriman Firehose Data ke titik akhir HTTP. Pengaturan ini menampilkan bagaimana Layanan AWS bekerja sama untuk memfasilitasi penanganan pesan dan integrasi dengan layanan HTTP eksternal.\]](http://docs.aws.amazon.com/id_id/sns/latest/dg/images/firehose-architecture-http.png)
**Topics**
+ [Format pemberitahuan untuk pengiriman ke tujuan HTTP](firehose-delivered-message-format-http.md)
# Format notifikasi Amazon SNS untuk pengiriman ke tujuan HTTP
Berikut adalah contoh badan permintaan HTTP POST dari Amazon SNS, dikirim melalui aliran pengiriman ke titik akhir HTTP. Notifikasi Amazon SNS dikodekan sebagai payload base64 dalam properti records.
**catatan**
Dalam contoh ini, pengiriman pesan mentah dinonaktifkan untuk pesan yang diterbitkan. Untuk informasi selengkapnya tentang pengiriman mentah, lihat [Pengiriman pesan mentah Amazon SNS](sns-large-payload-raw-message-delivery.md).
```
"body": {
"requestId": "ebc9e8b2-fce3-4aef-a8f1-71698bf8175f",
"timestamp": 1606255960435,
"records": [
{
"data": "eyJUeXBlIjoiTm90aWZpY2F0aW9uIiwiTWVzc2FnZUlkIjoiMjFkMmUzOGQtMmNhYi01ZjYxLTliYTItYmJiYWFhYzg0MGY2IiwiVG9waWNBcm4iOiJhcm46YXdzOnNuczp1cy1lYXN0LTE6MTExMTExMTExMTExOm15LXRvcGljIiwiTWVzc2FnZSI6IlNhbXBsZSBtZXNzYWdlIGZvciBBbWF6b24gS2luZXNpcyBEYXRhIEZpcmVob3NlIGVuZHBvaW50cyIsIlRpbWVzdGFtcCI6IjIwMjAtMTEtMjRUMjI6MDc6MzEuNjY3WiIsIlVuc3Vic2NyaWJlVVJMIjoiaHR0cHM6Ly9zbnMudXMtZWFzdC0xLmFtYXpvbmF3cy5jb20vP0FjdGlvbj1VbnN1YnNjcmliZSZTdWJzY3JpcHRpb25Bcm49YXJuOmF3czpzbnM6MTExMTExMTExMTExOm15LXRvcGljOjAxYjY5MTJjLTAwNzAtNGQ4Yi04YjEzLTU1NWJmYjc2ZTdkNCJ9"
}
]
}
```