

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# アプリケーションを作成して実行する (コンソール)
<a name="gs-scala-7"></a>

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

## アプリケーションの作成
<a name="gs-scala-7-console-create"></a>

1. にサインインし AWS マネジメントコンソール、https://console.aws.amazon.com/flink で Amazon MSF コンソールを開きます。

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

1. 「**Managed Service for Apache Flink-アプリケーションの作成**」ページで、次のようにアプリケーションの詳細を入力します。
   + [**アプリケーション名**] には **MyApplication** と入力します。
   + [**Description (説明)**] に **My scala test app** と入力します。
   + [**ランタイム**] には、[**Apache Flink**] を選択します。
   + バージョンは **[Apache Flink バージョン 1.19.1]** のままにしておきます。

1. [**アクセス許可**] には、[**IAM ロールの作成 / 更新`kinesis-analytics-MyApplication-us-west-2`**] を選択します。

1. [**アプリケーションを作成**] を選択します。

**注記**  
コンソールを使用して Apache Flink アプリケーション用 Managed Service を作成する場合は、IAM ロールとポリシーをアプリケーションが自動的に作成するオプションを選択できます。アプリケーションではこのロールとポリシーを使用して、依存リソースにアクセスします。これらの IAM リソースは、次のようにアプリケーション名とリージョンを使用して命名されます。  
ポリシー: `kinesis-analytics-service-MyApplication-us-west-2`
ロール: `kinesisanalytics-MyApplication-us-west-2`

## アプリケーションを設定する
<a name="gs-scala-7-console-configure"></a>

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

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

1. [**MyApplication**] ページで、[**Congirue**] を選択します。

1. [**Configure application**] ページで、[**Code location**] を次のように指定します。
   + [**Amazon S3 バケット**] で、**ka-app-code-*<username>***と入力します。
   + [**Amazon S3 オブジェクトへのパス**] で、**getting-started-scala-1.0.jar.**と入力します。

1. [**Access to application resources**] の [**Access permissions**] では、[**Create / update IAM role`kinesis-analytics-MyApplication-us-west-2`**] を選択します。

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

1. 次のように入力します。    
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ja_jp/managed-flink/latest/java/gs-scala-7.html)

   **[保存]** を選択します。

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

1. 次のように入力します。    
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ja_jp/managed-flink/latest/java/gs-scala-7.html)

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

1. [**CloudWatch logging**] では、[**有効化**] チェックボックスをオンにします。

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

**注記**  
Amazon CloudWatch ログ記録を有効にすることを選択すると、ロググループとログストリームが Kinesis Data Analytics によって作成されます。これらのリソースの名前は次のとおりです。  
ロググループ: `/aws/kinesis-analytics/MyApplication`
ログストリーム: `kinesis-analytics-log-stream`

## IAM ポリシーを編集する
<a name="gs-scala-7-console-iam"></a>

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

**IAM ポリシーを編集して S3 バケット権限を追加するには**

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

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

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

1. 次のポリシー例で強調表示されているセクションをポリシーに追加します。サンプルのアカウント ID (*012345678901*) を自分のアカウント ID に置き換えます。

------
#### [ JSON ]

****  

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

------

## アプリケーションを実行する
<a name="gs-scala-7-console-run"></a>

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

## アプリケーションを停止する
<a name="gs-scala-7-console-stop"></a>

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