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.
Penanganan Kesalahan
Amazon Kinesis Data Analytics mengembalikan kesalahan API atau SQL langsung kepada Anda. Untuk informasi selengkapnya tentang operasi API, lihatTindakan. Untuk informasi selengkapnya tentang menangani kesalahan SQL, lihat Referensi SQL Amazon Kinesis Data Analytics.
Amazon Kinesis Data Analytics melaporkan kesalahan runtime menggunakan aliran kesalahan dalam aplikasi yang disebut error_stream.
Melaporkan Kesalahan Menggunakan Aliran Kesalahan dalam Aplikasi
Amazon Kinesis Data Analytics melaporkan kesalahan runtime ke aliran kesalahan dalam aplikasi yang disebut error_stream. Berikut adalah contoh kesalahan yang mungkin terjadi:
-
Catatan yang dibaca dari sumber streaming tidak sesuai dengan skema input.
-
Kode aplikasi Anda menentukan pembagian dengan nol.
-
Baris rusak (misalnya, catatan muncul di aliran dengan nilai
ROWTIMEyang diubah pengguna yang menyebabkan catatan keluar dari urutan). Data dalam aliran sumber tidak dapat dikonversi ke tipe data yang ditentukan dalam skema (Kesalahan paksaan). Untuk informasi tentang tipe data yang dapat dikonversi, lihat Memetakan Tipe Data JSON ke Tipe Data SQL.
Sebaiknya tangani kesalahan ini secara terprogram dalam kode SQL Anda atau simpan data pada aliran kesalahan ke tujuan eksternal. Anda diharuskan menambahkan konfigurasi output (lihat Mengonfigurasi Output Aplikasi) ke aplikasi Anda. Untuk contoh cara kerja aliran kesalahan dalam aplikasi, lihat Contoh: Menjelajahi Aliran Kesalahan dalam Aplikasi.
catatan
Aplikasi Kinesis Data Analytics Anda tidak dapat mengakses atau memodifikasi aliran kesalahan secara terprogram karena aliran kesalahan dibuat menggunakan akun sistem. Anda harus menggunakan output kesalahan untuk menentukan jenis kesalahan yang mungkin dihadapi aplikasi Anda. Anda selanjutnya menulis kode SQL aplikasi Anda untuk menangani kondisi kesalahan yang diantisipasi.
Skema
Aliran kesalahan ini memiliki skema berikut:
Bidang | Tipe Data | Catatan |
ERROR_TIME | TIMESTAMP | Waktu terjadinya kesalahan |
ERROR_LEVEL | VARCHAR(10) | |
ERROR_NAME | VARCHAR(32) | |
MESSAGE | VARCHAR(4096) | |
DATA_ROWTIME | TIMESTAMP | Waktu baris catatan yang masuk |
DATA_ROW | VARCHAR(49152) | Data yang dikodekan hex di baris asli. Anda dapat menggunakan pustaka standar untuk melakukan dekode hex nilai ini, atau menggunakan sumber daya web seperti Konverter Hex untuk String |
PUMP_NAME | VARCHAR(128) | Pompa asal, seperti yang ditentukan dengan |
