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.
AddApplicationReferenceDataSource
catatan
Dokumentasi ini ditujukan untuk API Amazon Kinesis Data Analytics versi 1, yang hanya mendukung aplikasi SQL. API versi 2 mendukung aplikasi SQL dan Java. Untuk informasi selengkapnya tentang versi 2, lihat Dokumentasi V2 API Amazon Kinesis Data Analytics.
Menambahkan sumber data referensi ke aplikasi yang ada.
Amazon Kinesis Analytics membaca data referensi (yaitu, objek Amazon S3) dan membuat tabel dalam aplikasi di dalam aplikasi Anda. Dalam permintaan, Anda menyediakan sumber (nama bucket S3 dan nama kunci objek), nama tabel dalam aplikasi yang dibuat, dan informasi pemetaan yang diperlukan yang menjelaskan cara memetakan data di objek Amazon S3 ke kolom di tabel dalam aplikasi yang dihasilkan.
Untuk informasi konseptual, lihat Mengonfigurasi Input Aplikasi. Untuk batas sumber data yang dapat ditambahkan ke aplikasi, lihat Batas.
Operasi ini memerlukan izin untuk menjalankan tindakan kinesisanalytics:AddApplicationOutput.
Sintaksis Permintaan
{
"ApplicationName": "string",
"CurrentApplicationVersionId": number,
"ReferenceDataSource": {
"ReferenceSchema": {
"RecordColumns": [
{
"Mapping": "string",
"Name": "string",
"SqlType": "string"
}
],
"RecordEncoding": "string",
"RecordFormat": {
"MappingParameters": {
"CSVMappingParameters": {
"RecordColumnDelimiter": "string",
"RecordRowDelimiter": "string"
},
"JSONMappingParameters": {
"RecordRowPath": "string"
}
},
"RecordFormatType": "string"
}
},
"S3ReferenceDataSource": {
"BucketARN": "string",
"FileKey": "string",
"ReferenceRoleARN": "string"
},
"TableName": "string"
}
}Parameter Permintaan
Permintaan menerima data berikut dalam format JSON.
- ApplicationName
-
Nama aplikasi yang ada.
Jenis: String
Batasan Panjang: Panjang minimum 1. Panjang maksimum 128.
Pola:
[a-zA-Z0-9_.-]+Wajib: Ya
- CurrentApplicationVersionId
-
Versi aplikasi tempat Anda menambahkan sumber data referensi. Anda dapat menggunakan DescribeApplicationoperasi untuk mendapatkan versi aplikasi saat ini. Jika versi yang ditentukan bukan versi saat ini,
ConcurrentModificationExceptiondikembalikan.Tipe: Long
Rentang yang Valid: Nilai minimum 1. Nilai maksimum 999999999.
Wajib: Ya
- ReferenceDataSource
-
Sumber data referensi dapat berupa objek dalam bucket Amazon S3 Anda. Amazon Kinesis Analytics membaca objek dan menyalin data ke tabel dalam aplikasi yang dibuat. Anda menyediakan bucket S3, objek kunci nama, dan tabel dalam aplikasi yang dihasilkan yang dibuat. Anda juga harus menyediakan IAM role dengan izin yang diperlukan yang dapat diambil Amazon Kinesis Analytics untuk membaca objek dari bucket S3 atas nama Anda.
Tipe: Objek ReferenceDataSource
Wajib: Ya
Elemen Respons
Jika tindakan berhasil, layanan mengirimkan kembali respons HTTP 200 dengan isi HTTP kosong.
Kesalahan
- ConcurrentModificationException
-
Pengecualian yang dibuat sebagai hasil modifikasi konkuren ke aplikasi. Sebagai contoh, dua individu yang mencoba untuk mengedit aplikasi yang sama pada waktu yang sama.
Kode Status HTTP: 400
- InvalidArgumentException
-
Nilai parameter input yang ditentukan tidak valid.
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
- UnsupportedOperationException
-
Permintaan ditolak karena parameter tertentu tidak didukung atau sumber daya tertentu tidak valid untuk operasi ini.
Kode Status HTTP: 400
Lihat Juga
Untuk informasi selengkapnya tentang penggunaan API ini di salah satu AWS SDK khusus bahasa, lihat berikut ini:
