Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai 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.
Gunakan konektor untuk memindahkan data di Managed Service untuk Apache Flink dengan API DataStream
Di Amazon Managed Service for Apache Flink DataStream API, konektor adalah komponen perangkat lunak yang memindahkan data masuk dan keluar dari Layanan Terkelola untuk aplikasi Apache Flink. Konektor adalah integrasi fleksibel yang memungkinkan Anda membaca dari file dan direktori. Konektor terdiri dari modul lengkap untuk berinteraksi dengan layanan Amazon dan sistem pihak ketiga.
Tipe konektor termasuk berikut ini:
Tambahkan sumber data streaming: Berikan data ke aplikasi Anda dari Kinesis data stream, file, atau sumber data lainnya.
Tulis data menggunakan sink: Kirim data dari aplikasi Anda ke aliran data Kinesis, aliran Firehose, atau tujuan data lainnya.
Gunakan Asynchronous I/O: Menyediakan akses asinkron ke sumber data (seperti basis data) untuk memperkaya peristiwa aliran.
Konektor yang tersedia
Kerangka kerja Apache Flink berisi konektor untuk mengakses data dari berbagai sumber. Untuk informasi tentang konektor yang tersedia di kerangka kerja Apache Flink, lihat Konektor
Awas
Jika Anda memiliki aplikasi yang berjalan di Flink 1.6, 1.8, 1.11 atau 1.13 dan ingin berjalan di Timur Tengah (UEA), Asia Pasifik (Hyderabad), Israel (Tel Aviv), Eropa (Zurich), Timur Tengah (UEA), Asia Pasifik (Melbourne) atau Asia Pasifik (Jakarta), Anda mungkin harus membangun kembali arsip aplikasi Anda dengan konektor yang diperbarui atau meningkatkan ke Flink 1.18.
Konektor Apache Flink disimpan di repositori open source mereka sendiri. Jika Anda memutakhirkan ke versi 1.18 atau yang lebih baru, Anda harus memperbarui dependensi Anda. Untuk mengakses repositori konektor Apache Flink AWS , lihat. flink-connector-aws
Sumber Kinesis sebelumnya org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer dihentikan dan mungkin dihapus dengan rilis Flink di masa depan. Gunakan Sumber Kinesis
Tidak ada kompatibilitas status antara FlinkKinesisConsumer danKinesisStreamsSource. Untuk detailnya, lihat Memigrasi pekerjaan yang ada ke Sumber Aliran Kinesis baru
Berikut ini adalah pedoman yang direkomendasikan:
| Versi Flink | Konektor digunakan | Resolusi |
|---|---|---|
| 1.19, 1.20 | Sumber Kinesis |
Saat memutakhirkan ke Managed Service untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan konektor sumber Kinesis Data Streams terbaru. Itu harus versi 5.0.0 atau yang lebih baru. Untuk informasi selengkapnya, lihat Konektor Amazon Kinesis Data Streams |
| 1.19, 1.20 | Wastafel Kinesis |
Saat memutakhirkan ke Layanan Terkelola untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan konektor sink Kinesis Data Streams terbaru. Itu harus versi 5.0.0 atau yang lebih baru. Untuk informasi lebih lanjut, lihat Kinesis Streams |
| 1.19, 1.20 | Sumber Streams DynamoDB |
Saat memutakhirkan ke Managed Service untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan konektor sumber DynamoDB Streams terbaru. Itu harus versi 5.0.0 atau yang lebih baru. Untuk informasi selengkapnya, lihat Konektor Amazon DynamoDB |
| 1.19, 1.20 | DynamoDB Wastafel | Saat memutakhirkan ke Managed Service untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan konektor wastafel DynamoDB terbaru. Itu harus versi 5.0.0 atau yang lebih baru. Untuk informasi selengkapnya, lihat Konektor Amazon DynamoDB |
| 1.19, 1.20 | Wastafel Amazon SQS |
Saat memutakhirkan ke Managed Service untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan konektor wastafel Amazon SQS terbaru. Itu harus versi 5.0.0 atau yang lebih baru. Untuk informasi selengkapnya, lihat Amazon SQS Sink. |
| 1.19, 1.20 | Layanan Dikelola Amazon untuk Prometheus Sink |
Saat memutakhirkan ke Layanan Terkelola untuk Apache Flink versi 1.19 dan 1.20, pastikan Anda menggunakan Layanan Terkelola Amazon terbaru untuk konektor wastafel Prometheus. Itu harus versi 1.0.0 atau yang lebih baru. Untuk informasi lebih lanjut, lihat Prometheus |
