Kode Aplikasi

Kode aplikasi adalah serangkaian pernyataan SQL yang memproses input dan menghasilkan output. Pernyataan SQL ini beroperasi pada aliran dalam aplikasi dan tabel referensi. Untuk informasi selengkapnya, lihat Amazon Kinesis Data Analytics untuk Aplikasi SQL: Cara Kerjanya.

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

Dalam basis data relasional, Anda bekerja dengan tabel, menggunakan pernyataan INSERT untuk menambahkan catatan dan pernyataan SELECT untuk mengkueri data. Di Amazon Kinesis Data Analytics, Anda bekerja dengan aliran. Anda dapat menulis pernyataan SQL untuk mengkueri aliran ini. Hasil mengkueri satu aliran dalam aplikasi selalu dikirim ke aliran dalam aplikasi lainnya. Saat melakukan analitik yang kompleks, Anda dapat membuat beberapa aliran dalam aplikasi untuk menyimpan hasil analitik perantara. Akhirnya, Anda mengonfigurasi output aplikasi untuk meneruskan hasil analisis akhir (dari satu atau beberapa aliran dalam aplikasi) ke tujuan eksternal. Singkatnya, berikut adalah pola khas untuk menulis kode aplikasi:

• Pernyataan SELECT selalu digunakan dalam konteks pernyataan INSERT. Artinya, ketika Anda memilih baris, Anda menyisipkan hasil ke aliran dalam aplikasi lainnya.

• Pernyataan INSERT selalu digunakan dalam konteks pompa. Artinya, Anda menggunakan pompa untuk menulis ke aliran dalam aplikasi.

Kode aplikasi contoh berikut membaca catatan dari satu aliran (SOURCE_SQL_STREAM_001) dalam aplikasi dan menulis ke aliran dalam aplikasi lain (DESTINATION_SQL_STREAM). Anda dapat menyisipkan catatan ke aliran dalam aplikasi menggunakan pompa, seperti yang ditunjukkan di bawah ini:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   change DOUBLE, 
                                                   price DOUBLE);
-- Create a pump and insert into output stream.
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 

  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM ticker_symbol, change,price
    FROM   "SOURCE_SQL_STREAM_001";

catatan

Pengidentifikasi yang Anda tentukan untuk nama aliran dan nama kolom mengikuti konvensi SQL standar. Misalnya, jika Anda menempatkan tanda kutip di sekitar pengindentifikasi, hal itu menjadikan pengidentifikasi peka huruf besar/kecil. Jika tidak, pengindentifikasi default ke huruf besar. Untuk informasi selengkapnya tentang pengidentifikasi, lihat Pengidentifikasi di Amazon Managed Service for Apache Flink SQL Reference.

Kode aplikasi Anda dapat terdiri dari banyak pernyataan SQL. Misalnya:

• Anda dapat menulis kueri SQL secara berurutan dengan hasil dari satu pernyataan SQL mengumpan ke pernyataan SQL berikutnya.

• Anda juga dapat menulis kueri SQL yang berjalan independen satu sama lain. Misalnya, Anda dapat menulis dua pernyataan SQL yang mengkueri aliran dalam aplikasi yang sama, tetapi mengirim output ke aliran dalam aplikasi yang berbeda. Anda selanjutnya dapat mengkueri aliran dalam aplikasi yang baru dibuat secara independen.

Anda dapat membuat aliran dalam aplikasi untuk menyimpan hasil perantara. Anda memasukkan data di aliran dalam aplikasi menggunakan pompa. Untuk informasi selengkapnya, lihat Aliran dan Pompa dalam Aplikasi.

Jika Anda menambahkan tabel referensi dalam aplikasi, Anda dapat menulis SQL untuk menggabungkan data di aliran dalam aplikasi dan tabel referensi. Untuk informasi selengkapnya, lihat Contoh: Menambahkan Data Referensi ke Aplikasi Kinesis Data Analytics.

Berdasarkan konfigurasi output aplikasi, Amazon Kinesis Data Analytics menulis data dari aliran dalam aplikasi tertentu ke tujuan eksternal sesuai dengan konfigurasi output aplikasi. Pastikan kode aplikasi Anda menulis ke aliran dalam aplikasi yang ditentukan dalam konfigurasi output.

Untuk informasi lain, lihat topik berikut:

• Konsep SQL Streaming

• Referensi SQL Amazon Kinesis Data Analytics