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 dalam Layanan Terkelola untuk Apache Flink dengan DataStream API
Di Amazon Managed Service untuk 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 ke Layanan Terkelola untuk Apache Flink: Berikan data ke aplikasi Anda dari Kinesis data stream, file, atau sumber data lainnya.
Menulis data menggunakan sink di Managed Service untuk Apache Flink: Kirim data dari aplikasi Anda ke aliran data Kinesis, aliran Firehose, atau tujuan data lainnya.
Gunakan Asynchronous I/O di Managed Service untuk Apache Flink: 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 (UAE), Asia Pasifik (Hyderabad), Israel (Tel Aviv), Eropa (Zurich), Timur Tengah (), Asia Pasifik (MelbourneUAE) atau Asia Pasifik (Jakarta), Anda mungkin perlu 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
Berikut ini adalah pedoman yang direkomendasikan:
Peningkatan konektor | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Versi Flink | Konektor yang digunakan | Resolusi | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | EFO |
Saat memutakhirkan ke Amazon Managed Service untuk Apache Flink versi 1.15, pastikan Anda menggunakan konektor terbaru. EFO Itu harus versi 1.15.3 atau yang lebih baru. Untuk informasi selengkapnya, lihat: |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | Wastafel Firehose Data Amazon |
Saat memutakhirkan ke Amazon Managed Service untuk Apache Flink versi 1.15, pastikan Anda menggunakan Amazon Data Firehose Sink terbaru. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | Konektor Kafka |
Saat memutakhirkan ke Amazon Managed Service untuk Apache Flink versi 1.15, pastikan Anda menggunakan konektor Kafka terbaru. APIs Apache Flink telah usang FlinkKafkaConsumer |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1,6 - 1,13 | Firehose |
Aplikasi Anda bergantung pada konektor Firehose versi usang yang tidak mengetahui Wilayah yang lebih baru. AWS Bangun kembali arsip aplikasi Anda dengan konektor Firehose versi 2.1.0. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.8 | Kinesis |
Aplikasi Anda bergantung pada versi konektor Kinesis Flink yang sudah ketinggalan zaman yang tidak mengetahui Wilayah yang lebih baru. AWS Bangun kembali arsip aplikasi Anda dengan konektor Flink Kinesis versi 1.6.1. https://github.com/awslabs/amazon-kinesis-connector-flink/pohon/1.6.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.11 | Kinesis |
Aplikasi Anda bergantung pada versi konektor Kinesis Flink yang sudah ketinggalan zaman yang tidak mengetahui Wilayah yang lebih baru. AWS Membangun kembali arsip aplikasi Anda dengan konektor Flink Kinesis versi 2.4.1. https://github.com/awslabs/amazon-kinesis-connector-flink/pohon/2.4.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.6 dan 1.13 | Kinesis |
Aplikasi Anda bergantung pada versi konektor Kinesis Flink yang sudah ketinggalan zaman yang tidak mengetahui Wilayah yang lebih baru. AWS Sayangnya, Flink tidak lagi merilis patch atau perbaikan bug untuk konektor 1.6/1.13. Kami menyarankan memperbarui ke Flink 1.15 dengan membangun kembali arsip aplikasi Anda dengan Flink 1.15. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
