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 di Panduan Pengguna Layanan Penyimpanan Sederhana Amazon dan Bekerja dengan Bucket Amazon S3 di Panduan Pengguna Layanan Penyimpanan Sederhana Amazon.

2. Konfigurasi aliran pengiriman Anda. Untuk petunjuknya, lihat Memilih Amazon S3 untuk Tujuan Anda di Panduan Pengembang Amazon Data Firehose.

3. Gunakan Amazon Athena untuk kueri objek Amazon S3 menggunakan SQL standar. Untuk informasi selanjutnya, lihat Memulai 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';