Buat Layanan Terkelola untuk aplikasi Apache Flink - Layanan Terkelola untuk Apache Flink
Bangun Layanan Terkelola Anda untuk kode aplikasi Apache FlinkBuat Layanan Terkelola Anda untuk aplikasi Apache FlinkMulai Layanan Terkelola Anda untuk aplikasi Apache FlinkVerifikasi Layanan Terkelola Anda untuk aplikasi Apache Flink

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.

Buat Layanan Terkelola untuk aplikasi Apache Flink

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 Maven. Proyek Apache Maven menggunakan file pom.xml untuk menentukan versi komponen yang digunakan.

catatan

Layanan Terkelola untuk Apache Flink mendukung JAR file berukuran hingga 512 MB. Jika Anda menggunakan JAR file yang lebih besar dari ini, aplikasi Anda akan gagal untuk memulai.

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

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 Layanan Terkelola DataStream API di 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, IAM peran, dan IAM kebijakan) 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 Layanan Terkelola DataStream API di Apache Flink tutorialnya.

    • Buat Layanan Terkelola Anda untuk aplikasi Apache Flink menggunakan AWS CLI: Anda dapat membuat dan mengonfigurasi aplikasi Anda menggunakan aplikasi. AWS CLI

      Ketika Anda membuat aplikasi menggunakanCLI, Anda juga harus membuat sumber daya dependen aplikasi Anda (seperti aliran CloudWatch Log, IAM peran, dan IAM kebijakan) secara manual.

      Saat Anda membuat aplikasi menggunakanCLI, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda dengan menggunakan RuntimeEnvironment parameter tindakan. CreateApplication

    catatan

    Anda dapat mengubah RuntimeEnvironment aplikasi 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 Anda 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.