AddApplicationInputProcessingConfiguration - Amazon Managed Service untuk Apache Flink (sebelumnya Amazon Kinesis Data Analytics untuk Apache Flink)

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

AddApplicationInputProcessingConfiguration

Menambahkan InputProcessingConfiguration ke aplikasi Kinesis Data Analytics berbasis SQL. Prosesor input pra-proses catatan pada aliran input sebelum kode SQL aplikasi dijalankan. Saat ini, satu-satunya prosesor input yang tersedia adalah Amazon Lambda.

Sintaksis Permintaan

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "InputId": "string", "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } } }

Parameter Permintaan

Permintaan menerima data berikut dalam format JSON.

ApplicationName

Nama aplikasi yang ingin Anda tambahkan konfigurasi pemrosesan input.

Jenis: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 128.

Pola: [a-zA-Z0-9_.-]+

Wajib: Ya

CurrentApplicationVersionId

Versi aplikasi yang ingin Anda tambahkan konfigurasi pemrosesan input. Anda dapat menggunakan DescribeApplication operasi untuk mendapatkan versi aplikasi saat ini. Jika versi yang ditentukan bukan versi saat ini, ConcurrentModificationException dikembalikan.

Tipe: Long

Rentang yang Valid: Nilai minimum 1. Nilai maksimum 999999999.

Wajib: Ya

InputId

ID konfigurasi input untuk menambahkan konfigurasi pemrosesan input. Anda bisa mendapatkan daftar ID input untuk aplikasi menggunakan DescribeApplication operasi.

Jenis: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 50.

Pola: [a-zA-Z0-9_.-]+

Wajib: Ya

InputProcessingConfiguration

InputProcessingConfigurationUntuk ditambahkan ke aplikasi.

Tipe: Objek InputProcessingConfiguration

Wajib: Ya

Sintaksis Respons

{ "ApplicationARN": "string", "ApplicationVersionId": number, "InputId": "string", "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "ResourceARN": "string", "RoleARN": "string" } } }

Elemen Respons

Jika tindakan berhasil, layanan mengirimkan kembali respons HTTP 200.

Layanan mengembalikan data berikut dalam format JSON.

ApplicationARN

Amazon Resource Name (ARN) dari aplikasi.

Tipe: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 2048.

Pola: arn:.*

ApplicationVersionId

Menyediakan versi aplikasi saat ini.

Tipe: Long

Rentang yang Valid: Nilai minimum 1. Nilai maksimum 999999999.

InputId

ID input yang terkait dengan input aplikasi. Ini adalah ID yang diberikan Kinesis Data Analytics ke setiap konfigurasi input yang Anda tambahkan ke aplikasi Anda.

Jenis: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 50.

Pola: [a-zA-Z0-9_.-]+

InputProcessingConfigurationDescription

Deskripsi prapemrosesan yang menjalankan catatan dalam input ini sebelum kode aplikasi dijalankan.

Tipe: Objek InputProcessingConfigurationDescription

Kesalahan

ConcurrentModificationException

Pengecualian dilemparkan sebagai hasil dari modifikasi bersamaan ke aplikasi. Kesalahan ini dapat disebabkan oleh upaya memodifikasi aplikasi tanpa menggunakan ID aplikasi saat ini.

Kode Status HTTP: 400

InvalidArgumentException

Nilai parameter input yang ditentukan tidak valid.

Kode Status HTTP: 400

InvalidRequestException

Permintaan JSON tidak valid untuk operasi.

Kode Status HTTP: 400

ResourceInUseException

Aplikasi ini tidak tersedia untuk operasi ini.

Kode Status HTTP: 400

ResourceNotFoundException

Aplikasi yang ditentukan tidak dapat ditemukan.

Kode Status HTTP: 400

Lihat Juga

Untuk informasi selengkapnya tentang penggunaan API ini di salah satu AWS SDK khusus bahasa, lihat berikut ini: