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

• Buat Layanan Terkelola Anda untuk aplikasi Apache Flink

• Gunakan kunci yang dikelola pelanggan

• Mulai Layanan Terkelola Anda untuk aplikasi Apache Flink

• Verifikasi Layanan Terkelola Anda untuk aplikasi Apache Flink

• Aktifkan rollback sistem untuk Layanan Terkelola Anda untuk aplikasi Apache Flink

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 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 membuat kode aplikasi, lakukan hal berikut untuk membuat aplikasi Managed Service for Apache Flink (Amazon MSF):

• 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 aplikasi MSF Amazon Anda:

  catatan

  Amazon MSF mengenkripsi aplikasi Anda secara default menggunakan. Kunci milik AWS Anda juga dapat membuat aplikasi baru menggunakan kunci yang dikelola AWS KMS pelanggan (CMKs) untuk membuat, memiliki, dan mengelola kunci Anda sendiri. Untuk informasi tentang CMKs, lihatManajemen kunci di Amazon Managed Service untuk Apache Flink.

  • Buat aplikasi Amazon MSF Anda menggunakan AWS konsol: Anda dapat membuat dan mengonfigurasi aplikasi Anda menggunakan AWS konsol.

    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 aplikasi Amazon MSF Anda 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 RuntimeEnvironment dari tindakan CreateApplication.

  catatan

  Anda dapat mengubah RuntimeEnvironment aplikasi yang ada. Untuk mempelajari caranya, lihat Gunakan upgrade versi di tempat untuk Apache Flink.

Gunakan kunci yang dikelola pelanggan

Di Amazon MSF, kunci yang dikelola pelanggan (CMKs) adalah fitur yang dapat digunakan untuk mengenkripsi data aplikasi Anda dengan kunci yang Anda buat, miliki, dan kelola pada AWS Key Management Service ()AWS KMS. Untuk aplikasi Amazon MSF, ini berarti semua data yang tunduk pada pos pemeriksaan Flink atau snapshot dienkripsi dengan CMK yang Anda tentukan untuk aplikasi itu.

Untuk menggunakan CMK dengan aplikasi Anda, Anda harus terlebih dahulu membuat aplikasi baru Anda, dan kemudian menerapkan CMK. Untuk informasi selengkapnya tentang penggunaan CMKs, lihatManajemen kunci di Amazon Managed Service 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.