Mengonfigurasi Output Aplikasi - Panduan Developer Amazon Kinesis Data Analytics untuk Aplikasi SQL

Untuk proyek baru, kami menyarankan Anda menggunakan Managed Service baru untuk Apache Flink Studio melalui Kinesis Data Analytics untuk Aplikasi 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.

Mengonfigurasi Output Aplikasi

Dalam kode aplikasi Anda, Anda menulis output pernyataan SQL untuk satu atau lebih aliran dalam aplikasi. Anda dapat menambahkan konfigurasi output ke aplikasi Anda. untuk menyimpan semua yang ditulis ke aliran dalam aplikasi ke tujuan eksternal seperti aliran data Amazon Kinesis, aliran pengiriman Firehose, atau fungsi. AWS Lambda

Ada batas pada jumlah tujuan eksternal yang dapat Anda gunakan untuk menyimpan output aplikasi. Untuk informasi selengkapnya, lihat Batas.

catatan

Sebaiknya gunakan satu tujuan eksternal untuk menyimpan data aliran kesalahan dalam aplikasi agar Anda dapat menyelidiki kesalahan.

Dalam setiap konfigurasi output ini, Anda memberikan hal berikut:

  • Nama aliran dalam aplikasi – Aliran yang ingin Anda simpan ke tujuan eksternal.

    Kinesis Data Analytics mencari aliran dalam aplikasi yang Anda tentukan dalam konfigurasi output. (Nama aliran adalah peka huruf besar/kecil dan harus sama persis.) Pastikan kode aplikasi Anda membuat aliran dalam aplikasi ini.

  • Tujuan eksternal — Anda dapat menyimpan data ke aliran data Kinesis, aliran pengiriman Firehose, atau fungsi Lambda. Anda menyediakan Amazon Resource Name (ARN) aliran atau fungsi. Anda juga menyediakan IAM role yang dapat diambil Kinesis Data Analytics untuk menulis ke aliran atau fungsi atas nama Anda. Anda menjelaskan format catatan (JSON, CSV) ke Kinesis Data Analytics yang digunakan saat menulis ke tujuan eksternal.

Jika Kinesis Data Analytics tidak dapat menulis ke tujuan streaming atau Lambda, layanan terus mencoba tanpa batas. Ini membuat tekanan balik, yang menyebabkan aplikasi Anda tertinggal. Jika masalah ini tidak teratasi, aplikasi Anda akhirnya berhenti memproses data baru. Anda dapat memantau Metrik Kinesis Data Analytics dan mengatur alarm untuk kegagalan. Untuk informasi selengkapnya tentang metrik dan alarm, lihat Menggunakan CloudWatchMetrik Amazon dan Membuat Alarm Amazon. CloudWatch

Anda dapat mengonfigurasi output aplikasi menggunakan AWS Management Console. Konsol membuat panggilan API untuk menyimpan konfigurasi.

Membuat Output Menggunakan AWS CLI

Bagian ini menjelaskan cara membuat bagian Outputs dari isi permintaan untuk operasi CreateApplication atau AddApplicationOutput.

Membuat Output Aliran Kinesis

Fragmen JSON berikut menunjukkan bagian Outputs di isi permintaan CreateApplication untuk membuat tujuan Amazon Kinesis data stream.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Membuat Output Aliran Pengiriman Firehose

Fragmen JSON berikut menunjukkan Outputs bagian di badan CreateApplication permintaan untuk membuat tujuan aliran pengiriman Amazon Data Firehose.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Membuat Output Fungsi Lambda

Fragmen JSON berikut menunjukkan Outputs bagian dalam badan CreateApplication permintaan untuk membuat tujuan AWS Lambda fungsi.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "LambdaOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]