創建並運行應用程序（控制台）

1. 在 https://console.aws.amazon.com /flink 開啟適用於阿帕奇 Flink 的受管理服務

2. 在 Managed Service for Apache Flink 儀表板上，選擇建立分析應用程式。

3. 在 Managed Service for Apache Flink - 建立應用程式頁面，提供應用程式詳細資訊，如下所示：

   • 在應用程式名稱中，輸入 MyApplication。

   • 對於 Description (說明)，輸入 My scala test app。

   • 對於​執行期，選擇 ​Apache Flink。

   • 保持阿帕奇 FLINK 版本 1.19.1 版本的版本。

4. 對於 [存取權限]，選擇 [建立/更新IAM角色] kinesis-analytics-MyApplication-us-west-2。

5. 選擇建立應用程式。

設定應用程式

1. 在MyApplication頁面上，選擇設定。

2. 在設定應用程式頁面，提供程式碼位置：

   • 對於 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. 在監控下，確保監控指標層級設為應用程式。

9. 對於CloudWatch 記錄，請選擇啟用核取方塊。

10. 選擇更新。

編輯IAM政策以新增 S3 儲存貯體許可

1. 在開啟IAM主控台https://console.aws.amazon.com/iam/。

2. 選擇政策。選擇主控台為您在上一節所建立的 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"
           }
       ]
   }