Langkah 3: Buat Aplikasi Amazon Kinesis Data Analytics Starter Anda - 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.

Langkah 3: Buat Aplikasi Amazon Kinesis Data Analytics Starter Anda

Dengan mengikuti langkah-langkah di bagian ini, Anda dapat membuat aplikasi Kinesis Data Analytics pertama menggunakan konsol.

catatan

Sebaiknya tinjau Amazon Kinesis Data Analytics untuk Aplikasi SQL: Cara Kerjanya sebelum mencoba latihan Memulai.

Untuk latihan Memulai ini, Anda dapat menggunakan konsol untuk bekerja dengan aliran demo atau templat dengan kode aplikasi.

  • Jika Anda memilih untuk menggunakan aliran demo, konsol membuat Kinesis data stream di akun Anda yang disebut kinesis-analytics-demo-stream.

    Aplikasi Kinesis Data Analytics membutuhkan sumber streaming. Untuk sumber ini, beberapa SQL contoh dalam panduan ini menggunakan aliran demokinesis-analytics-demo-stream. Konsol juga menjalankan skrip yang terus menambahkan data sampel (simulasi catatan perdagangan saham) ke aliran ini, seperti yang ditunjukkan berikut ini.

    Tabel sampel aliran diformat yang menunjukkan simbol , sektor, dan harga saham.

    Anda dapat menggunakan kinesis-analytics-demo-stream sebagai sumber streaming untuk aplikasi Anda dalam latihan ini.

    catatan

    Aliran demo tetap ada di akun Anda. Anda dapat menggunakannya untuk menguji contoh lain dalam panduan ini. Namun, ketika Anda meninggalkan konsol, skrip yang digunakan konsol berhenti mengisi data. Jika diperlukan, konsol menyediakan opsi untuk mulai mengisi kembali aliran.

  • Jika Anda memilih untuk menggunakan templat dengan contoh kode aplikasi, Anda menggunakan kode templat yang disediakan konsol untuk melakukan analitik sederhana pada aliran demo.

Anda menggunakan fitur ini untuk menyiapkan aplikasi pertama Anda dengan cepat sebagai berikut:

  1. Create an application (Buat aplikasi) – Anda hanya perlu memberikan nama. Konsol membuat aplikasi dan layanan yang menetapkan status aplikasi ke READY.

     

  2. Configure input (Konfigurasikan Input) – Pertama-tama, Anda menambahkan sumber streaming, aliran demo. Anda harus membuat aliran demo di konsol sebelum Anda dapat menggunakannya. Kemudian, konsol mengambil sampel acak catatan pada aliran demo dan menyimpulkan skema untuk aliran input dalam aplikasi yang dibuat. Konsol menamai aliran dalam aplikasi ini SOURCE_SQL_STREAM_001.

    Konsol menggunakan penemuan API untuk menyimpulkan skema. Jika perlu, Anda dapat mengedit skema yang disimpulkan. Untuk informasi selengkapnya, lihat DiscoverInputSchema. Kinesis Data Analytics menggunakan skema ini untuk membuat aliran dalam aplikasi.

     

    Saat Anda memulai aplikasi, Kinesis Data Analytics terus membaca aliran demo atas nama Anda dan memasukkan baris di aliran input dalam aplikasi SOURCE_SQL_STREAM_001.

     

  3. Specify application code (Tentukan kode aplikasi) – Anda menggunakan templat (disebut Filter berkelanjutan) yang menyediakan kode berikut:

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
  (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
 
-- Create pump to insert into output. 
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 sector SIMILAR TO '%TECH%';

    Kode aplikasi dapat mengkueri aliran dalam aplikasi SOURCE_SQL_STREAM_001. Kode kemudian memasukkan baris yang dihasilkan di aliran dalam aplikasi lainnya DESTINATION_SQL_STREAM, menggunakan pompa. Untuk informasi selengkapnya tentang pola pengkodean ini, lihat Kode Aplikasi.

    Untuk informasi tentang elemen SQL bahasa yang didukung oleh Kinesis Data Analytics, lihat Referensi Amazon Kinesis Data Analytics. SQL

     

  4. Mengonfigurasi output— Dalam latihan ini, Anda tidak mengonfigurasi output apa pun. Artinya, Anda tidak menyimpan data di aliran dalam aplikasi yang aplikasi Anda buat untuk tujuan eksternal apa pun. Sebaliknya, Anda memverifikasi hasil kueri di konsol. Contoh tambahan dalam panduan ini menunjukkan cara mengonfigurasi output. Sebagai contoh, lihat Contoh: Membuat Peringatan Sederhana.

penting

Latihan ini menggunakan Wilayah US East (N. Virginia) (us-east-1) untuk menyiapkan aplikasi. Anda dapat menggunakan salah satu yang didukung Wilayah AWS.

Langkah Selanjutnya

Langkah 3.1: Buat Aplikasi