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

以下の手順を実行し、コンソールを使用してアプリケーションを作成、設定、更新、および実行します。

アプリケーションの作成

1. https://console.aws.amazon.com/flink で Apache Flink 用 Managed Serviceコンソールを開く

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] を選択します。

注記

コンソールを使用して Managed Service for Apache Flink アプリケーションを作成する場合、アプリケーション用に IAMロールとポリシーを作成するオプションがあります。アプリケーションではこのロールとポリシーを使用して、依存リソースにアクセスします。これらのIAMリソースの名前は、次のようにアプリケーション名とリージョンを使用して付けられます。

• ポリシー: kinesis-analytics-service-MyApplication-us-west-2

• ロール: kinesisanalytics-MyApplication-us-west-2

アプリケーションを設定する

アプリケーションを設定するには、次の手順に従います。

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

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

   [保存] を選択します。

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

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

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

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

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

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

注記

Amazon CloudWatch ログ記録を有効にすると、Managed Service for Apache Flink によってロググループとログストリームが作成されます。これらのリソースの名前は次のとおりです。

• ロググループ: /aws/kinesis-analytics/MyApplication

• ログストリーム: kinesis-analytics-log-stream

IAM ポリシーを編集する

IAM ポリシーを編集して、Amazon S3 バケットにアクセスするためのアクセス許可を追加します。

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

1. https://console.aws.amazon.com/iam/ で 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"
           }
       ]
   }

アプリケーションを実行する

Flink ジョブグラフは、アプリケーションを実行し、Apache Flink ダッシュボードを開き、目的の Flink ジョブを選択すると表示できます。

アプリケーションの停止

アプリケーションを停止するには、MyApplicationページで停止 を選択します。アクションを確認します。