Langkah 3.3: Tambahkan Analitik Waktu Nyata (Tambahkan Kode Aplikasi)

Anda dapat menulis SQL kueri Anda sendiri terhadap aliran dalam aplikasi, tetapi untuk langkah berikut Anda menggunakan salah satu template yang menyediakan kode sampel.

1. Pada halaman hub aplikasi, pilih Pergi ke SQL editor.

   

2. Dalam Apakah Anda ingin mulai menjalankan "ExampleApp“? kotak dialog, pilih Ya, mulai aplikasi.

   Konsol mengirimkan permintaan untuk memulai aplikasi (lihatStartApplication), dan kemudian halaman SQL editor muncul.

3. Konsol membuka halaman SQL editor. Tinjau halaman, termasuk tombol (Tambahkan SQL dari templat, Simpan dan jalankan SQL) dan berbagai tab.

4. Di SQL editor, pilih Tambahkan SQL dari templat.

5. Dari daftar templat yang tersedia, pilih Continuous filter (Filter berkelanjutan). Kode sampel membaca data dari satu aliran dalam aplikasi (klausa WHERE memfilter baris) dan memasukkannya di aliran dalam aplikasi lainnya sebagai berikut:

   • Ini membuat aliran dalam aplikasi DESTINATION_SQL_STREAM.

   • Ini membuat pompa STREAM_PUMP, dan menggunakannya untuk memilih baris dari SOURCE_SQL_STREAM_001 dan memasukkannya dalam DESTINATION_SQL_STREAM.

6. Pilih Tambahkan ini SQL ke editor.

7. Uji kode aplikasi sebagai berikut:

   Ingat, Anda sudah memulai aplikasi (statusnyaRUNNING). Oleh karena itu, Amazon Kinesis Data Analytics terus membaca data dari sumber streaming dan menambahkan baris ke aliran dalam aplikasi SOURCE_SQL_STREAM_001.

   1. Di SQL Editor, pilih Simpan dan jalankan SQL. Konsol pertama-tama mengirimkan permintaan pembaruan untuk menyimpan kode aplikasi. Kemudian, kode terus berjalan.

   2. Anda dapat melihat hasilnya di tab Real-time analytics (Analitik waktu nyata).

      

      SQLEditor memiliki tab berikut:

      • Tab Source data (Data sumber) menampilkan aliran input dalam aplikasi yang dipetakan ke sumber streaming. Pilih aliran dalam aplikasi, dan Anda dapat melihat data yang masuk. Perhatikan kolom tambahan di aliran input dalam aplikasi yang tidak ditentukan dalam konfigurasi input. Ini termasuk kolom stempel waktu berikut:

         

        • ROWTIME— Setiap baris dalam aliran dalam aplikasi memiliki kolom khusus yang disebutROWTIME. Kolom ini adalah stempel waktu ketika Amazon Kinesis Data Analytics memasukkan baris di aliran dalam aplikasi pertama (aliran input dalam aplikasi yang dipetakan ke sumber streaming).

           

        • Approximate_Arrival_Time – Setiap catatan Kinesis Data Analytics menyertakan nilai yang disebut Approximate_Arrival_Time. Nilai ini adalah perkiraan kedatangan stempel waktu yang ditetapkan ketika sumber streaming berhasil menerima dan menyimpan catatan. Ketika Kinesis Data Analytics membaca catatan dari sumber streaming, kolom ini akan dimasukkan ke aliran input dalam aplikasi.

        Nilai stempel waktu ini berguna dalam kueri jendela yang berbasis waktu. Untuk informasi selengkapnya, lihat Kueri Jendela.

         

      • Tab Real-time analytics (Analitik waktu nyata) menunjukkan semua aliran dalam aplikasi lainnya yang dibuat dengan kode aplikasi Anda. Tab ini juga mencakup aliran kesalahan. Kinesis Data Analytics mengirimkan baris apa pun yang tidak dapat diproses ke aliran kesalahan. Untuk informasi selengkapnya, lihat Penanganan Kesalahan.

         

        Pilih DESTINATION_SQL_STREAM untuk melihat baris yang dimasukkan kode aplikasi Anda. Perhatikan kolom tambahan yang tidak dibuat oleh kode aplikasi Anda. Kolom ini termasuk kolom stempel waktu ROWTIME. Kinesis Data Analytics hanya menyalin nilai ini dari sumbernya (SOURCE_SQL_STREAM_001).

         

      • Tab Destination (Tujuan) menunjukkan tujuan eksternal tempat Kinesis Data Analytics menulis hasil kueri. Anda belum mengonfigurasi tujuan eksternal apa pun untuk output aplikasi Anda.

Langkah Selanjutnya

Langkah 3.4: (Opsional) Perbarui Kode Aplikasi