アプリケーションの作成と実行 (コンソール）

1. https://console.aws.amazon.com/flink で Managed Service for Apache Flink コンソールを開きます。

2. Managed Service for Apache Flinkのダッシュボードで、「分析アプリケーションの作成」 を選択します。

3. 「Managed Service for Apache Flink-アプリケーションの作成」ページで、次のようにアプリケーションの詳細を入力します。

   • [アプリケーション名] には MyApplication と入力します。

   • [Description (説明)] に My scala test app と入力します。

   • [ランタイム] には、[Apache Flink] を選択します。

   • バージョンは Apache Flink バージョン 1.19.1 のままにします。

4. アクセス許可 で、IAMロールの作成/更新 kinesis-analytics-MyApplication-us-west-2を選択します。

5. [Create application] を選択します。

アプリケーションを構成するには

1. MyApplication ページで、 の設定 を選択します。

2. [Configure application] ページで、[Code location] を次のように指定します。

   • [Amazon S3 バケット] で、ka-app-code-<username>と入力します。

   • [Amazon S3 オブジェクトへのパス] で、getting-started-scala-1.0.jar.と入力します。

3. 「アプリケーションリソースへのアクセス」の「アクセス許可」で、IAM「ロールの作成/更新kinesis-analytics-MyApplication-us-west-2」を選択します。

4. [プロパティ] で [グループの追加]を選択します。

5. 次のように入力します。

   グループ ID	キー	値
   ConsumerConfigProperties	input.stream.name	ExampleInputStream
   ConsumerConfigProperties	aws.region	us-west-2
   ConsumerConfigProperties	flink.stream.initpos	LATEST

   [Save] を選択します。

6. プロパティ で、グループの追加をもう一度選択します。

7. 次のように入力します。

   グループ ID	キー	値
   ProducerConfigProperties	output.stream.name	ExampleOutputStream
   ProducerConfigProperties	aws.region	us-west-2

8. [Monitoring] の [Monitoring metrics level] が [Application] に設定されていることを確認します。

9. CloudWatch ログ記録 で、有効化チェックボックスを選択します。

10. [Update] (更新) を選択します。

IAM ポリシーを編集して S3 バケットのアクセス許可を追加するには

1. でIAMコンソールを開きますhttps://console.aws.amazon.com/iam/。

2. [Policies] (ポリシー) を選択します。前のセクションでコンソールによって作成された kinesis-analytics-service-MyApplication-us-west-2 ポリシーを選択します。

3. [概要] ページで、[ポリシーの編集] を選択します。JSON タブを選択します。

4. 次のポリシー例で強調表示されているセクションをポリシーに追加します。サンプルアカウント IDs (012345678901) を アカウント ID で指定します。

   {
       "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"
           }
       ]
   }