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.
Topik ini berisi informasi tentang membuat Layanan Terkelola untuk aplikasi Apache Flink.
Topik ini berisi bagian-bagian berikut:
Bangun Layanan Terkelola Anda untuk kode aplikasi Apache Flink
Bagian ini menjelaskan komponen yang Anda gunakan untuk membangun kode aplikasi untuk Layanan Terkelola untuk aplikasi Apache Flink Anda.
Sebaiknya gunakan versi terbaru Apache Flink yang didukung untuk kode aplikasi Anda. Untuk informasi tentang memutakhirkan Layanan Terkelola untuk aplikasi Apache Flink, lihat. Gunakan upgrade versi di tempat untuk Apache Flink
Anda membangun kode aplikasi Anda menggunakan Apache Mavenpom.xml untuk menentukan versi komponen yang digunakan.
catatan
Layanan Terkelola untuk Apache Flink mendukung file JAR hingga ukuran 512 MB. Jika Anda menggunakan file JAR lebih besar dari ini, aplikasi Anda akan gagal dimulai.
Aplikasi sekarang dapat menggunakan Java API dari versi Scala apa pun. Anda harus menggabungkan pustaka standar Scala pilihan Anda ke dalam aplikasi Scala Anda.
Untuk informasi tentang membuat Layanan Terkelola untuk aplikasi Apache Flink yang menggunakan Apache Beam, lihat. Gunakan Apache Beam dengan Managed Service untuk aplikasi Apache Flink
Tentukan versi Apache Flink aplikasi Anda
Saat menggunakan Managed Service for Apache Flink Runtime versi 1.1.0 dan yang lebih baru, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda saat Anda mengkompilasi aplikasi Anda. Anda memberikan versi Apache Flink dengan parameter. -Dflink.version Misalnya, jika Anda menggunakan Apache Flink 1.19.1, berikan yang berikut ini:
mvn package -Dflink.version=1.19.1
Untuk membangun aplikasi dengan versi Apache Flink sebelumnya, lihat. Versi sebelumnya
Buat Layanan Terkelola Anda untuk aplikasi Apache Flink
Setelah Anda membangun kode aplikasi Anda, Anda melakukan hal berikut untuk membuat Layanan Terkelola untuk aplikasi Apache Flink Anda:
Unggah kode Aplikasi Anda: Unggah kode aplikasi Anda ke bucket Amazon S3. Anda menentukan nama bucket S3 dan nama objek kode aplikasi Anda ketika membuat aplikasi Anda. Untuk tutorial yang menunjukkan cara mengunggah kode aplikasi Anda, lihat Tutorial: Mulai menggunakan DataStream API di Managed Service untuk Apache Flink tutorialnya.
Buat Layanan Terkelola untuk aplikasi Apache Flink Anda: Gunakan salah satu metode berikut untuk membuat Layanan Terkelola untuk aplikasi Apache Flink Anda:
Buat Layanan Terkelola untuk aplikasi Apache Flink menggunakan AWS konsol: Anda dapat membuat dan mengonfigurasi aplikasi menggunakan konsol. AWS
Saat Anda membuat aplikasi menggunakan konsol, sumber daya dependen aplikasi Anda (seperti aliran CloudWatch Log, peran IAM, dan kebijakan IAM) akan dibuat untuk Anda.
Saat Anda membuat aplikasi menggunakan konsol, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda dengan memilihnya dari pull-down pada halaman Managed Service for Apache Flink - Create application.
Untuk tutorial tentang cara menggunakan konsol untuk membuat aplikasi, lihat Tutorial: Mulai menggunakan DataStream API di Managed Service untuk Apache Flink tutorialnya.
Buat Layanan Terkelola Anda untuk aplikasi Apache Flink menggunakan AWS CLI: Anda dapat membuat dan mengkonfigurasi aplikasi Anda menggunakan CLI. AWS
Saat Anda membuat aplikasi menggunakan CLI, Anda juga harus membuat sumber daya dependen aplikasi Anda (seperti aliran CloudWatch Log, peran IAM, dan kebijakan IAM) secara manual.
Ketika Anda membuat aplikasi Anda menggunakan CLI, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda menggunakan parameter
RuntimeEnvironmentdari tindakanCreateApplication.
catatan
Anda dapat mengubah
RuntimeEnvironmentaplikasi yang ada. Untuk mempelajari caranya, lihat Gunakan upgrade versi di tempat untuk Apache Flink.
Mulai Layanan Terkelola Anda untuk aplikasi Apache Flink
Setelah Anda membangun kode aplikasi Anda, mengunggahnya ke S3, dan membuat Layanan Terkelola untuk aplikasi Apache Flink, Anda kemudian memulai aplikasi Anda. Memulai Layanan Terkelola untuk aplikasi Apache Flink biasanya memakan waktu beberapa menit.
Gunakan salah satu metode berikut untuk memulai aplikasi Anda:
Mulai Layanan Terkelola untuk aplikasi Apache Flink menggunakan AWS konsol: Anda dapat menjalankan aplikasi Anda dengan memilih Jalankan pada halaman aplikasi Anda di AWS konsol.
Mulai Layanan Terkelola untuk aplikasi Apache Flink menggunakan AWS API: Anda dapat menjalankan aplikasi Anda menggunakan tindakan. StartApplication
Verifikasi Layanan Terkelola Anda untuk aplikasi Apache Flink
Anda dapat memverifikasi bahwa aplikasi Anda bekerja dengan cara berikut:
Menggunakan CloudWatch Log: Anda dapat menggunakan Wawasan CloudWatch CloudWatch Log dan Log untuk memverifikasi bahwa aplikasi Anda berjalan dengan benar. Untuk informasi tentang menggunakan CloudWatch Log dengan Layanan Terkelola untuk aplikasi Apache Flink, lihat. Pencatatan dan pemantauan di Amazon Managed Service untuk Apache Flink
Menggunakan CloudWatch Metrik: Anda dapat menggunakan CloudWatch Metrik untuk memantau aktivitas aplikasi, atau aktivitas dalam sumber daya yang digunakan aplikasi untuk input atau output (seperti aliran Kinesis, aliran Firehose, atau bucket Amazon S3.) Untuk informasi selengkapnya tentang CloudWatch metrik, lihat Bekerja dengan Metrik di CloudWatch Panduan Pengguna Amazon.
Pemantauan Lokasi Output: Jika aplikasi Anda menulis output ke lokasi (seperti bucket atau basis data Amazon S3), Anda dapat memantau lokasi tersebut untuk data tertulis.
