Langkah 2: Buat Aplikasi Kinesis Data Analytics - Panduan Pengembang Amazon Kinesis Data Analytics SQL untuk Aplikasi

Untuk proyek baru, kami menyarankan Anda menggunakan Managed Service baru untuk Apache Flink Studio melalui Kinesis Data Analytics for Applications. SQL Layanan Terkelola untuk Apache Flink Studio menggabungkan kemudahan penggunaan dengan kemampuan analitis tingkat lanjut, memungkinkan Anda membangun aplikasi pemrosesan aliran yang canggih dalam hitungan menit.

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

Langkah 2: Buat Aplikasi Kinesis Data Analytics

Di bagian contoh Hotspot ini, Anda membuat aplikasi Kinesis Data Analytics sebagai berikut:

  • Konfigurasikan input aplikasi untuk menggunakan Kinesis data stream yang Anda buat sebagai sumber streaming di Langkah 1.

  • Gunakan kode aplikasi yang disediakan di AWS Management Console.

Untuk membuat aplikasi

  1. Buat aplikasi Kinesis Data Analytics dengan mengikuti langkah 1, 2, dan 3 dalam latihan Memulai (Langkah 3.1: Buat Aplikasilihat).

    Dalam konfigurasi sumber, lakukan hal berikut:

    • Tentukan sumber streaming yang Anda buat di Langkah 1 Buat Aliran Input dan Output.

    • Setelah konsol menyimpulkan skema, edit skema. Pastikan tipe kolom x dan y ditetapkan ke DOUBLE dan tipe kolom IS_HOT ditetapkan ke VARCHAR.

  2. Gunakan kode aplikasi berikut (Anda dapat menempelkan kode ini ke editor SQL):

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
    "x" DOUBLE, 
    "y" DOUBLE, 
    "is_hot" VARCHAR(4),
    HOTSPOTS_RESULT VARCHAR(10000)
); 
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
    INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" 
    FROM TABLE (
        HOTSPOTS(   
            CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 
            1000, 
            0.2, 
            17)
    );

  3. Jalankan kode SQL dan tinjau hasilnya.

    Hasil kode SQL menunjukkan rowtime, hotspot, dan hotspot_heat.

Langkah Selanjutnya

Langkah 3: Konfigurasikan Output Aplikasi