創建使用阿帕奇梁的應用程序

使用下列內容建立名為 ping.py 的檔案：

import json
import boto3
import random

kinesis = boto3.client('kinesis')

while True:
        data = random.choice(['ping', 'telnet', 'ftp', 'tracert', 'netstat'])
        print(data)
        kinesis.put_record(
                StreamName="ExampleInputStream",
                Data=data,
                PartitionKey="partitionkey")

執行 ping.py 指令碼：

$ python ping.py

在完成教學課程的其餘部分時，讓指令碼保持執行狀態。

如果您尚未安裝 Git 用戶端，請先安裝。如需詳細資訊，請參閱安裝 Git。

使用以下指令複製遠端儲存庫：

git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

導覽至 amazon-kinesis-data-analytics-java-examples/Beam 目錄。

如果尚未安裝 Java 和 Maven，請先安裝。如需詳細資訊，請參閱教學課程：開始使用 Managed Service for Apache Flink 中的 DataStream API 教學課程中的完成必要的先決條件。

使用下列命令編譯應用程式：

mvn package -Dflink.version=1.15.2 -Dflink.version.minor=1.8

在 Amazon S3 控制台中，選擇 ka-app-code-<username>桶，然後選擇上傳。

在選取檔案步驟中，選擇 新增檔案。導覽至您在上一步驟中建立的 basic-beam-app-1.0.jar 檔案。

您不需要變更物件的任何設定，因此請選擇上傳。

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

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

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

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

選擇建立應用程式。

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

選擇政策。選擇主控台為您在上一節所建立的 kinesis-analytics-service-MyApplication-us-west-2 政策。

在摘要頁面，選擇編輯政策。選擇索JSON引標籤。

將下列政策範例的反白部分新增至政策。取代範例帳戶 IDs (012345678901) 使用您的帳戶 ID。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "ReadCode",
            "Effect": "Allow",
            "Action": [
                "s3:GetObject",
                "logs:DescribeLogGroups",
                "s3:GetObjectVersion"
            ],
            "Resource": [
                "arn:aws:logs:us-west-2:012345678901:log-group:*",
                "arn:aws:s3:::ka-app-code-<username>/basic-beam-app-1.0.jar"
            ]
        },
        {
            "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": "ListCloudwatchLogGroups",
            "Effect": "Allow",
            "Action": [
                "logs:DescribeLogGroups"
            ],
            "Resource": [
                "arn:aws:logs:us-west-2:012345678901:log-group:*"
            ]
        },
        {
            "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"
        }
    ]
}

在MyApplication頁面上，選擇設定。

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

在 [存取應用程式資源] 下，針對 [存取權限] 選擇 [建立/更新IAM角色] kinesis-analytics-MyApplication-us-west-2。

輸入下列資料：

在監控下，確保監控指標層級設為應用程式。

若要CloudWatch 記錄，請選取 [啟用] 核取方塊。

選擇更新。

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

在適用於 Apache Flink 的受管理服務面板中，選擇MyApplication。

在應用程式的頁面，選擇刪除，然後確認刪除。

在 https://console.aws.amazon.com/Kinesis 處開啟室壁運動主控台。

在「Kinesis Data Streams」面板中，選擇ExampleInputStream。

在ExampleInputStream頁面中，選擇「刪除 Kinesis 串流」，然後確認刪除。

在 Kinesis 串流頁面中，選擇，選擇「ExampleOutputStream動作」，選擇「刪除」，然後確認刪除。

在開啟 Amazon S3 主控台https://console.aws.amazon.com/s3/。

選擇 ka-app-code-<username> 桶。

選擇刪除，然後輸入儲存貯體名稱以確認刪除。

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

在導覽列中，選擇政策。

在篩選器控制項中，輸入 kinesis。

選擇 kinesis-analytics-service--MyApplication us-we st-2 原則。

選擇政策動作，然後選擇刪除。

在導覽列中，選擇角色。

選擇運動分析-MyApplication us-west-2 角色。

選擇刪除角色，然後確認刪除。

在開啟 CloudWatch 主控台https://console.aws.amazon.com/cloudwatch/。

在導覽列中，選擇日誌。

選擇 /aws/運動分析/日誌群MyApplication組。

選擇刪除日誌群組，然後確認刪除。