Langkah 4: Pembuatan Aplikasi Amazon Kinesis Data Analytics

Sekarang setelah Anda menyiapkan penerbitan peristiwa dengan Amazon SES, Anda dapat mengonfigurasi Amazon Kinesis Data Analytics untuk menangkap data peristiwa pengiriman email dari aliran pengiriman Amazon Kinesis Data Firehose Anda. Untuk melakukannya, Anda perlu membuat aplikasi Amazon Kinesis Data Analytics.

Prosedur berikut menunjukkan cara menggunakan konsol Amazon Kinesis Data Analytics untuk membuat aplikasi yang menangkap data peristiwa pengiriman email Amazon SES dari aliran pengiriman Kinesis Data Firehose Anda, dan juga cara mengueri SQL sederhana pada data untuk mengembalikan peristiwa ketik "Kirim".

catatan

Peristiwa pengiriman email dari berbagai tipe peristiwa (pengiriman, pentalan, aduan, dan penyampaian) memiliki skema JSON yang berbeda. Dalam lingkungan produksi, Anda mungkin memeriksa beberapa bidang skema ini, tetapi dalam tutorial ini, kami membatasi pemeriksaan kami pada set bidang kecil yang ada untuk semua tipe peristiwa.

Membuat aplikasi Amazon Kinesis Data Analytics

1. Mulai mengirim aliran email yang dikonfigurasi untuk penerbitan peristiwa melalui Amazon SES, dan lanjutkan pengiriman email melalui prosedur ini. Hal ini diperlukan agar Amazon Kinesis Data Analytics dapat secara otomatis mendeteksi skema catatan peristiwa. Mengirim satu email setiap sepuluh detik selama lima menit sudah cukup untuk tutorial ini. Untuk informasi lebih lanjut, lihat Langkah 3: Mengirim email.

   Setelah program email Anda mengirim beberapa email, lanjutkan ke langkah berikutnya.

2. Masuk ke AWS Management Console dan buka konsol Kinesis Data Analytics di https://console.aws.amazon.com/kinesisanalytics.

3. Pilih Buat aplikasi baru.

4. Masukkan nama dan deskripsi aplikasi, lalu pilih Simpan dan lanjutkan.

5. Pilih Hubungkan ke sumber.

6. Pilih aliran Kinesis Data Firehose yang telah Anda buat di Langkah 2: Siapkan Set Konfigurasi.

   Amazon Kinesis Data Analytics mencoba menemukan skema email yang catatan peristiwa pengiriman email berdasarkan catatan yang masuk. Jika Amazon Kinesis Data Analytics menampilkan Kesalahan saat menemukan skema input, artinya Amazon Kinesis Data Analytics belum menerima catatan pengiriman email apa pun. Pilih Temukan kembali skema. Anda mungkin perlu memilih tombol ini beberapa kali. Jika penemuan skema tidak berhasil setelah beberapa kali mencoba, pastikan aplikasi pengiriman email Anda terus mengirim email, dan email tersebut menentukan set konfigurasi.

   Saat Amazon Kinesis Data Analytics mendeteksi skema, Amazon Kinesis Data Analytics akan menampilkan pesan sukses dan mencantumkan catatan yang terdeteksi.

   penting

   Jangan pilih Simpan dan lanjutkan. Prosedur tersebut akan menyebabkan kesalahan karena skema yang ditemukan tidak mematuhi batasan penamaan SQL. Anda harus mengedit skema seperti yang dijelaskan di langkah selanjutnya.

7. Pilih Edit skema.

   

8. Untuk tutorial ini, kami menghapus sebagian besar baris. Pilih X di samping semua baris kecuali baris dengan nama kolom berikut:

   • eventType

   • timestamp

   • messageId

   • kepada

   • ses:configuration-set

   penting

   Jangan pilih Simpan skema dan perbarui sampel aliran. Prosedur tersebut akan menyebabkan kesalahan karena skema yang ditemukan tidak mematuhi batasan penamaan SQL. Anda harus mengedit skema seperti yang dijelaskan di langkah selanjutnya.

   

9. Periksa entri yang tersisa di bawah Nama kolom dan membandingkannya dengan persyaratan penamaan SQL sebagai berikut:

   • Format – Seperti yang dijelaskan di Pengidentifikasi dalam Referensi SQL Amazon Kinesis Data Analytics, pengidentifikasi yang tidak memiliki tanda kutip harus dimulai dengan huruf atau garis bawah, dan diikuti dengan huruf, angka, atau garis bawah. Nama tanda otomatis Amazon SES tidak sesuai dengan persyaratan ini karena mengandung titik dua dan tanda hubung. Anda akan mengedit nama tersebut di langkah selanjutnya.

   • Kata-kata Cadangan – Nama kolom tidak boleh bertentangan dengan kata-kata cadangan SQL yang tercantum dalam Kata Cadangan dan Kata Kunci dalam Referensi SQL Amazon Kinesis Data Analytics. Contoh kata kunci cadangan yang bertentangan dengan catatan peristiwa Amazon SES adalah timestamp, value, date, from, dan to.

10. Edit nama kolom yang tersisa agar sesuai dengan persyaratan SQL sebagai berikut:

    • Ganti nama ses:configuration-set ke ses_configuration_set.

    • Ganti nama timestamp ke ses_timestamp.

    • Ganti nama to ke ses_to.

    
    

11. Pilih Simpan skema dan perbarui sampel aliran. Jika Anda mengalami kesalahan validasi, pastikan bahwa Anda melakukan langkah 10 dengan benar. Jika Anda menemukan kesalahan Tidak ada baris dalam aliran sumber, maka pastikan Anda masih mengirimkan aliran email yang Anda mulai di awal prosedur ini, lalu pilih Ambil baris. Anda mungkin harus memilih Ambil baris beberapa kali sebelum Amazon Kinesis Data Analytics menangkap catatan.

12. Setelah pengambilan baris berhasil, pilih Keluar (selesai).

    

Langkah Selanjutnya

Langkah 5: Jalankan Kueri SQL