Contoh: Membuat Peringatan Sederhana - Panduan Pengembang Amazon Kinesis Data Analytics SQL untuk Aplikasi

Setelah mempertimbangkan dengan cermat, kami memutuskan untuk menghentikan Amazon Kinesis Data Analytics SQL untuk aplikasi dalam dua langkah:

1. Mulai 15 Oktober 2025, Anda tidak akan dapat membuat Kinesis Data Analytics SQL baru untuk aplikasi.

2. Kami akan menghapus aplikasi Anda mulai 27 Januari 2026. Anda tidak akan dapat memulai atau mengoperasikan Amazon Kinesis Data Analytics Anda SQL untuk aplikasi. Support tidak akan lagi tersedia untuk Amazon Kinesis Data Analytics SQL sejak saat itu. Untuk informasi selengkapnya, lihat Amazon Kinesis Data Analytics SQL untuk penghentian Aplikasi.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Contoh: Membuat Peringatan Sederhana

Dalam aplikasi Kinesis Data Analytics ini, kueri berjalan terus menerus pada aliran dalam aplikasi yang dibuat melalui aliran demo. Untuk informasi selengkapnya, lihat Kueri Berkelanjutan.

Jika setiap baris menunjukkan perubahan harga saham yang lebih besar dari 1 persen, baris tersebut dimasukkan ke aliran dalam aplikasi lain. Dalam latihan, Anda dapat mengonfigurasi output aplikasi untuk menyimpan hasil ke tujuan eksternal. Anda selanjutnya dapat menyelidiki hasilnya lebih lanjut. Misalnya, Anda dapat menggunakan fungsi AWS Lambda untuk memproses catatan dan mengirimkan peringatan.

Untuk membuat aplikasi peringatan sederhana

  1. Buat aplikasi analitik seperti yang dijelaskan dalam latihan Memulai Kinesis Data Analytics.

  2. Di editor SQL dalam Kinesis Data Analytics, ganti kode aplikasi dengan berikut ini: 

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
           (ticker_symbol VARCHAR(4), 
            sector        VARCHAR(12), 
            change        DOUBLE, 
            price         DOUBLE);

CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
   INSERT INTO "DESTINATION_SQL_STREAM"
      SELECT STREAM ticker_symbol, sector, change, price 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS(Change / (Price - Change)) * 100) > 1;

    Pernyataan SELECT dalam kode aplikasi memfilter baris dalam SOURCE_SQL_STREAM_001 untuk perubahan harga saham yang lebih besar dari 1 persen. Ini selanjutnya memasukkan baris ke aliran lain dalam aplikasi DESTINATION_SQL_STREAM menggunakan pompa. Untuk informasi selengkapnya tentang pola pengkodean yang menjelaskan penggunaan pompa untuk memasukkan baris ke aliran dalam aplikasi, lihat Kode Aplikasi.

  3. Pilih Save and run SQL (Simpan dan jalankan SQL).

  4. Tambahkan tujuan. Untuk melakukan ini, pilih tab Destination (Tujuan) di editor SQL atau pilih Add a destination (Tambahkan tujuan) pada halaman detail aplikasi.

    1. Di editor SQL, pilih tab Destination (Tujuan), lalu pilih Connect to a destination (Sambungkan ke tujuan).

      Di halaman Sambungkan ke tujuan, pilih Create New (Buat Baru).

    2. Pilih Go to Kinesis Streams (Buka Aliran Kinesis).

    3. Pada konsol Amazon Kinesis Data Streams, buat aliran Kinesis baru (misalnya, gs-destination) dengan satu serpihan. Tunggu hingga status aliran ACTIVE (AKTIF).

    4. Kembali ke konsol Kinesis Data Analytics. Di halaman Sambungkan ke tujuan, pilih aliran yang Anda buat.

      Jika aliran tidak muncul, refresh halaman.

    5. Jangan pilih Save and continue (Simpan dan lanjutkan).

    Sekarang Anda memiliki tujuan eksternal, Kinesis Data Stream, tempat Kinesis Data Analytics menyimpan output aplikasi Anda di aliran dalam aplikasi DESTINATION_SQL_STREAM.

  5. Konfigurasi AWS Lambda untuk memantau aliran Kinesis yang Anda buat dan memanggil fungsi Lambda.

    Untuk petunjuk, lihat Memproses Data Terlebih Dulu Menggunakan Fungsi Lambda.