Layanan Terkelola Amazon untuk Apache Flink - Amazon Timestream
Aplikasi sampelVideo tutorial

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Layanan Terkelola Amazon untuk Apache Flink

Anda dapat menggunakan Apache Flink untuk mentransfer data deret waktu Anda dari Amazon Managed Service untuk Apache Flink, MSK Amazon, Apache Kafka, dan teknologi streaming lainnya langsung ke Amazon Timestream untuk. LiveAnalytics Kami telah membuat konektor data sampel Apache Flink untuk Timestream. Kami juga telah membuat contoh aplikasi untuk mengirim data ke Amazon Kinesis sehingga data dapat mengalir dari Kinesis ke Managed Service untuk Apache Flink, dan akhirnya ke Amazon Timestream. Semua artefak ini tersedia untuk Anda. GitHub Tutorial video ini menjelaskan pengaturan.

catatan

Java 11 adalah versi yang direkomendasikan untuk menggunakan Managed Service untuk Apache Flink Application. Jika Anda memiliki beberapa versi Java, pastikan Anda mengekspor Java 11 ke variabel HOME lingkungan JAVA _ Anda.

Aplikasi sampel

Untuk memulai, ikuti prosedur di bawah ini:

  1. Buat database di Timestream dengan nama kdaflink mengikuti petunjuk yang dijelaskan di Buat database

  2. Buat tabel di Timestream dengan nama kinesisdata1 mengikuti petunjuk yang dijelaskan dalam Membuat tabel

  3. Membuat Amazon Kinesis Data Stream dengan nama TimestreamTestStream mengikuti petunjuk yang dijelaskan dalam Membuat Stream

  4. Kloning GitHub repositori untuk konektor data Apache Flink untuk Timestream mengikuti instruksi dari GitHub

  5. Untuk mengkompilasi, menjalankan dan menggunakan aplikasi sampel, ikuti instruksi di konektor data sampel Apache Flink README

  6. Kompilasi Layanan Terkelola untuk aplikasi Apache Flink mengikuti instruksi untuk Mengompilasi Kode Aplikasi

  7. Unggah Layanan Terkelola untuk aplikasi Apache Flink biner mengikuti petunjuk untuk Mengunggah Kode Streaming Apache Flink

    1. Setelah mengklik Buat Aplikasi, klik tautan IAM Peran untuk aplikasi

    2. Lampirkan IAM kebijakan untuk AmazonKinesisReadOnlyAccessdan AmazonTimestreamFullAccess.

      catatan

      IAMKebijakan di atas tidak terbatas pada sumber daya tertentu dan tidak cocok untuk penggunaan produksi. Untuk sistem produksi, pertimbangkan untuk menggunakan kebijakan yang membatasi akses ke sumber daya tertentu.

  8. Kloning GitHub repositori untuk data penulisan aplikasi sampel ke Kinesis mengikuti instruksi dari GitHub

  9. Ikuti petunjuk dalam READMEuntuk menjalankan aplikasi sampel untuk menulis data ke Kinesis

  10. Jalankan satu atau beberapa kueri di Timestream untuk memastikan bahwa data sedang dikirim dari Kinesis ke Layanan Terkelola untuk Apache Flink ke Timestream mengikuti petunjuk Membuat tabel

Video tutorial

Video ini menjelaskan cara menggunakan Timestream dengan Managed Service untuk Apache Flink.