Buat dan jalankan aplikasi (konsol)

1. Buka Layanan Terkelola untuk konsol Apache Flink di /flink https://console.aws.amazon.com

2. Pada dashboard Managed Service for Apache Flink, pilih Create Analytics Application.

3. Pada Layanan Terkelola untuk Apache Flink - Buat halaman aplikasi, berikan detail aplikasi sebagai berikut:

   • Untuk Application name (Nama aplikasi), masukkan MyApplication.

   • Untuk Description (Deskripsi), masukkan My scala test app.

   • Untuk Runtime, pilih Apache Flink.

   • Simpan versi sebagai Apache Flink versi 1.19.1.

4. Untuk izin Akses, pilih Buat/perbarui IAM peran kinesis-analytics-MyApplication-us-west-2.

5. Pilih Create application (Buat aplikasi).

Untuk mengonfigurasi aplikasi

1. Pada MyApplicationhalaman, pilih Konfigurasi.

2. Di halaman Konfigurasikan aplikasi, berikan Code location (Lokasi kode):

   • Untuk Bucket Amazon S3, masukkan ka-app-code-<username>.

   • Untuk Jalur ke objek Amazon S3, masukkan getting-started-scala-1.0.jar..

3. Di bawah Akses ke sumber daya aplikasi, untuk izin Akses, pilih Buat/perbarui IAM peran kinesis-analytics-MyApplication-us-west-2.

4. Di bawah Properties (Properti), pilih Add group (Tambahkan grup).

5. Masukkan yang berikut ini:

   ID Grup	Kunci	Nilai
   ConsumerConfigProperties	input.stream.name	ExampleInputStream
   ConsumerConfigProperties	aws.region	us-west-2
   ConsumerConfigProperties	flink.stream.initpos	LATEST

   Pilih Simpan.

6. Di bawah Properties (Properti), pilih Add group (Tambahkan grup) lagi.

7. Masukkan yang berikut ini:

   ID Grup	Kunci	Nilai
   ProducerConfigProperties	output.stream.name	ExampleOutputStream
   ProducerConfigProperties	aws.region	us-west-2

8. Di bawah Pemantauan, pastikan Memantau tingkat metrik diatur ke Aplikasi.

9. Untuk CloudWatch logging, pilih kotak centang Aktifkan.

10. Pilih Perbarui.

Untuk mengedit IAM kebijakan untuk menambahkan izin bucket S3

1. Buka IAM konsol di https://console.aws.amazon.com/iam/.

2. Pilih Policies (Kebijakan). Pilih kebijakan kinesis-analytics-service-MyApplication-us-west-2 yang dibuat konsol untuk Anda di bagian sebelumnya.

3. Di halaman Ringkasan, pilih Edit policy (Edit kebijakan). Pilih JSONtab.

4. Tambahkan bagian yang disorot dari contoh kebijakan berikut ke kebijakan. Ganti akun sampel IDs (012345678901) dengan ID akun Anda.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/getting-started-scala-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }