Memulai Layanan Terkelola HAQM untuk Apache Flink
Mengapa harus Layanan Terkelola untuk Apache Flink?
Dengan Layanan Terkelola HAQM untuk Apache Flink, Anda dapat mengubah dan menganalisis data streaming secara waktu nyata menggunakan Apache Flink. Layanan Terkelola HAQM untuk Apache Flink menyederhanakan pembangunan dan pengelolaan beban kerja Apache Flink dan memungkinkan Anda dengan mudah mengintegrasikan aplikasi dengan layanan AWS lainnya.
Bangun aplikasi streaming dengan Apache Flink dan Apache Beam
1
Langkah 1: Unduh pustaka sumber terbuka ke IDE favorit Anda
Anda dapat memulai dengan mengunduh pustaka sumber terbuka termasuk AWS SDK, Apache Flink, dan konektor untuk layanan AWS.
2
Langkah 2: Bangun aplikasi sampel menggunakan Apache Flink atau Apache Beam
Anda menulis kode aplikasi Apache Flink menggunakan aliran data dan operator streaming. Aliran data aplikasi adalah struktur data yang Anda proses terhadap penggunaan kode aplikasi Anda. Data terus mengalir dari sumber ke aliran data aplikasi. Satu atau beberapa operator streaming digunakan untuk menentukan pemrosesan Anda pada aliran data aplikasi.
3
Langkah 3: Unggah kode Anda ke Layanan Terkelola HAQM untuk Apache Flink
Setelah dibuat, unggah kode Anda ke Layanan Terkelola HAQM untuk Apache Flink. Layanan ini menangani semua yang diperlukan untuk terus menjalankan aplikasi waktu nyata Anda, termasuk penskalaan secara otomatis agar sesuai dengan volume dan throughput data masuk Anda.
Gunakan Layanan Terkelola HAQM untuk Apache Flink Studio secara intuitif
1
Langkah 1: Buat aplikasi Layanan Terkelola HAQM untuk Apache Flink Studio
Mulai dari Layanan Terkelola HAQM untuk Apache Flink, HAQM MSK, atau konsol HAQM Kinesis Data Streams. Anda juga dapat menggunakan konektor khusus untuk terhubung ke sumber data lainnya.
2
Langkah 2: Tulis kode di notebook nirserver dalam SQL, Python, dan Scala lalu kembangkan aplikasi Apache Flink dengan cepat
Jalankan paragraf individual dalam notebook, lihat hasilnya dalam konteks, dan gunakan visualisasi bawaan Apache Zeppelin untuk mempercepat pengembangan. Anda juga dapat menggunakan fungsi yang ditentukan pengguna dalam kode Anda.
3
Langkah 3: Bangun dan lakukan deployment sebagai aplikasi streaming Layanan Terkelola HAQM untuk Apache Flink
Deploy kode Anda sebagai aplikasi pemrosesan aliran yang terus berjalan hanya dengan beberapa klik. Aplikasi yang Anda lakukan deployment akan menjadi aplikasi Layanan Terkelola HAQM untuk Apache Flink dengan status tahan lama dan penskalaan otomatis. Anda juga akan mendapatkan kesempatan untuk mengubah sumber, tujuan, pencatatan, dan tingkat pemantauan sebelum Anda memproduksi kode.