本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。
# 教學課程：在 Managed Service for Apache Flink 中建立 Studio 筆記本
下列教學課程示範如何建立 Studio 筆記本，從 Kinesis 資料串流或 Amazon MSK 叢集讀取資料。
**Topics**
+ [完成先決條件](#example-notebook-setup)
+ [建立 AWS Glue 資料庫](#example-notebook-glue)
+ [後續步驟：使用 Kinesis Data Streams 或 Amazon MSK 建立 Studio 筆記本](#examples-notebook-nextsteps)
+ [使用 Kinesis Data Streams 建立 Studio 筆記本](example-notebook-streams.md)
+ [使用 Amazon MSK 建立 Studio 筆記本](example-notebook-msk.md)
+ [清除您的應用程式和相依資源](example-notebook-cleanup.md)
## 完成先決條件
請確定您的 AWS CLI 是第 2 版或更新版本。若要安裝最新的 AWS CLI，請參閱[安裝、更新和解除安裝第 2 AWS CLI 版](https://docs.aws.amazon.com/cli/latest/userguide/install-cliv2.html)。
## 建立 AWS Glue 資料庫
您的 Studio 筆記本使用 [AWS Glue](https://docs.aws.amazon.com/glue/latest/dg/what-is-glue.html) 資料庫取得有關 Amazon MSK 資料來源的中繼資料。
**建立 AWS Glue 資料庫**
1. 在 https：//[https://console.aws.amazon.com/glue/](https://console.aws.amazon.com/glue/) 開啟 AWS Glue 主控台。
1. 選擇**新增資料庫**。在**新增資料庫**視窗中，為**資料庫名稱**輸入 **default**。選擇**建立**。
## 後續步驟：使用 Kinesis Data Streams 或 Amazon MSK 建立 Studio 筆記本
借助本教學課程，您可以建立使用 Kinesis Data Streams 或 Amazon MSK 的 Studio 筆記本：
+ [使用 Kinesis Data Streams 建立 Studio 筆記本](example-notebook-streams.md)：使用 Kinesis Data Streams，您可以快速建立使用 Kinesis 資料串流作為來源的應用程式。您只需要將 Kinesis 資料串流建立為相依資源。
+ [使用 Amazon MSK 建立 Studio 筆記本](example-notebook-msk.md)：使用 Amazon MSK，您可以建立使用 Amazon MSK 叢集做為來源的應用程式。您需要建立一個 Amazon VPC、一個 Amazon EC2 用戶端執行個體和一個 Amazon MSK 叢集作為相依資源。
# 使用 Kinesis Data Streams 建立 Studio 筆記本
本教學課程說明如何建立使用 Kinesis 資料串流作為來源的 Studio 筆記本。
**Topics**
+ [完成先決條件](#example-notebook-streams-setup)
+ [建立 AWS Glue 資料表](#example-notebook-streams-glue)
+ [使用 Kinesis Data Streams 建立 Studio 筆記本](#example-notebook-streams-create)
+ [將資料傳送至 Kinesis 資料串流](#example-notebook-streams-send)
+ [測試 Studio 筆記本](#example-notebook-streams-test)
## 完成先決條件
建立 Studio 筆記本之前，請先建立 Kinesis 資料串流 (`ExampleInputStream`)。您的應用程式使用此串流作為應用程式來源。
您可以使用 Amazon Kinesis 主控台或以下 AWS CLI 命令來建立該串流。如需主控台指示，請參閱《Amazon Kinesis Data Streams 開發人員指南》中的[建立和更新資料串流](https://docs.aws.amazon.com/kinesis/latest/dev/amazon-kinesis-streams.html)**。將該串流命名為 **ExampleInputStream**，並將**開啟的碎片數量**設定為 **1**。
若要使用 建立串流 (`ExampleInputStream`) AWS CLI，請使用下列 Amazon Kinesis `create-stream` AWS CLI 命令。
```
$ aws kinesis create-stream \
--stream-name ExampleInputStream \
--shard-count 1 \
--region us-east-1 \
--profile adminuser
```
## 建立 AWS Glue 資料表
您的 Studio 筆記本使用 [AWS Glue](https://docs.aws.amazon.com/glue/latest/dg/what-is-glue.html) 資料庫取得有關 Kinesis Data Streams 資料來源的中繼資料。
**注意**
您可以先手動建立資料庫，也可以讓 Managed Service for Apache Flink 在您建立筆記本時為您建立資料庫。同樣，您可以依照本節所述手動建立資料表，也可以在 Apache Zeppelin 的筆記本中，使用針對 Managed Service for Apache Flink 的建立資料表連接器程式碼，透過 DDL 陳述式建立資料表。然後，您可以簽入 AWS Glue ，以確保正確建立資料表。
**建立資料表**
1. 登入 AWS 管理主控台 ，並在 https：//[https://console.aws.amazon.com/glue/](https://console.aws.amazon.com/glue/) 開啟 AWS Glue 主控台。
1. 如果您還沒有 AWS Glue 資料庫，請從左側導覽列中選擇**資料庫**。選擇**新增資料庫**。在**新增資料庫**視窗中，為**資料庫名稱**輸入 **default**。選擇 **Create** (建立)。
1. 在左側導覽列中，選擇**資料表**。在**資料表**頁面，選擇**新增資料表** > **手動新增資料表**。
1. 在**設定資料表**頁面，為**資料表名稱**輸入 **stock**。請務必選取先前建立的資料庫。選擇 **Next (下一步)**。
1. 在**新增資料存放區**頁面，選擇 **Kinesis**。對於**串流名稱**，輸入 **ExampleInputStream**。針對 **Kinesis 來源 URL**，請選擇輸入 **https://kinesis.us-east-1.amazonaws.com**。如果您複製並貼上 **Kinesis 來源 URL**，請務必刪除任何前置或尾端空格。選擇 **Next (下一步)**。
1. 在**分類**頁面，選擇 **JSON**。選擇 **Next (下一步)**。
1. 在**定義結構描述**頁面，選擇「新增資料欄」以新增資料欄。新增具有下列屬性的欄：
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_tw/managed-flink/latest/java/example-notebook-streams.html)
選擇 **Next (下一步)**。
1. 在下一頁上，確認您的設定，然後選擇**完成**。
1. 從資料表清單中選取您新建立的資料表。
1. 選擇**編輯資料表**，然後新增索引鍵為 `managed-flink.proctime` 值為 `proctime` 的屬性。
1. 選擇**套用**。
## 使用 Kinesis Data Streams 建立 Studio 筆記本
現在，您已建立應用程式使用的資源，接下來可以建立您的 Studio 筆記本。
**Topics**
+ [使用 建立 Studio 筆記本 AWS 管理主控台](#example-notebook-create-streams-console)
+ [使用 建立 Studio 筆記本 AWS CLI](#example-notebook-msk-create-api)
### 使用 建立 Studio 筆記本 AWS 管理主控台
1. 前往 [https://console.aws.amazon.com/managed-flink/home?region=us-east-1\$1/applications/dashboard](https://console.aws.amazon.com/managed-flink/home?region=us-east-1#/applications/dashboard) 開啟 Managed Service in the Apache Flink 主控台。
1. 在 **Managed Service for Apache Flink 應用程式**頁面，選擇 **Studio** 標籤。選擇**建立 Studio 筆記本**。
**注意**
您也可以藉由選取輸入 Amazon MSK 叢集或 Kinesis 資料串流，然後選擇**即時處理資料**，從 Amazon MSK 或 Kinesis Data Streams 主控台建立 Studio 筆記本。
1. 在**建立 Studio 筆記本**頁面，提供下列資訊：
+ 為筆記本名稱輸入 **MyNotebook**。
+ 為 **AWS Glue 資料庫**選擇**預設值**。
選擇**建立 Studio 筆記本**。
1. 在 **MyNotebook** 頁面，選擇**執行**。等待**狀態**顯示為**執行中**。筆記本執行時需支付費用。
### 使用 建立 Studio 筆記本 AWS CLI
若要使用 建立 Studio 筆記本 AWS CLI，請執行下列動作：
1. 驗證您的帳戶 ID。您需要此值來建立應用程式。
1. 建立角色 `arn:aws:iam::AccountID:role/ZeppelinRole`，並將下列許可新增至主控台自動建立的角色。
`"kinesis:GetShardIterator",`
`"kinesis:GetRecords",`
`"kinesis:ListShards"`
1. 建立稱為 `create.json` 的檔案，其中具有以下內容。使用您的資訊取代預留位置的值。
```
{
"ApplicationName": "MyNotebook",
"RuntimeEnvironment": "ZEPPELIN-FLINK-3_0",
"ApplicationMode": "INTERACTIVE",
"ServiceExecutionRole": "arn:aws:iam::AccountID:role/ZeppelinRole",
"ApplicationConfiguration": {
"ApplicationSnapshotConfiguration": {
"SnapshotsEnabled": false
},
"ZeppelinApplicationConfiguration": {
"CatalogConfiguration": {
"GlueDataCatalogConfiguration": {
"DatabaseARN": "arn:aws:glue:us-east-1:AccountID:database/default"
}
}
}
}
}
```
1. 若要建立應用程式，請執行下列命令：
```
aws kinesisanalyticsv2 create-application --cli-input-json file://create.json
```
1. 命令完成後，您應該會看到類似如下的輸出，其中顯示新 Studio 筆記本的詳細資料：以下為輸出範例。
```
{
"ApplicationDetail": {
"ApplicationARN": "arn:aws:kinesisanalyticsus-east-1:012345678901:application/MyNotebook",
"ApplicationName": "MyNotebook",
"RuntimeEnvironment": "ZEPPELIN-FLINK-3_0",
"ApplicationMode": "INTERACTIVE",
"ServiceExecutionRole": "arn:aws:iam::012345678901:role/ZeppelinRole",
...
```
1. 若要執行應用程式，請執行下列命令：使用您的帳戶 ID 取代範例值。
```
aws kinesisanalyticsv2 start-application --application-arn arn:aws:kinesisanalyticsus-east-1:012345678901:application/MyNotebook\
```
## 將資料傳送至 Kinesis 資料串流
若要將測試資料傳送至 Kinesis 資料串流，請執行下列動作：
1. 開啟 [Kinesis 資料產生器](https://awslabs.github.io/amazon-kinesis-data-generator/web/help.html)。
1. 選擇使用 **CloudFormation 建立 Cognito 使用者**。
1. CloudFormation 主控台會開啟 Kinesis Data Generator 範本。選擇 **Next (下一步)**。
1. 在**指定堆疊詳細資訊**頁面，輸入 Cognito 使用者的使用者名稱和密碼。選擇 **Next (下一步)**。
1. 在**設定堆疊選項**頁面，選擇**下一步**。
1. 在**檢閱 Kinesis-Data-Generator-Cognito-User** 頁面中，選擇**我確認 AWS CloudFormation 可能會建立 IAM 資源。**核取方塊。選擇 **Create Stack** (建立堆疊)。
1. 等待 CloudFormation 堆疊完成建立。堆疊完成後，在 CloudFormation 主控台中開啟 **Kinesis-Data-Generator-Cognito-User** 堆疊，然後選擇**輸出**索引標籤。開啟針對 **KinesisDataGeneratorUrl** 輸出值所列出的 URL。
1. 在 **Amazon Kinesis 資料產生器**頁面，使用您在步驟 4 中建立的憑證登入。
1. 在下一頁面，提供下列值：
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_tw/managed-flink/latest/java/example-notebook-streams.html)
為**記錄範本**貼上下列程式碼：
```
{
"ticker": "{{random.arrayElement(
["AMZN","MSFT","GOOG"]
)}}",
"price": {{random.number(
{
"min":10,
"max":150
}
)}}
}
```
1. 選擇**傳送資料**。
1. 產生器會將資料傳送至 Kinesis 資料串流。
完成下一節時，讓產生器保持執行狀態。
## 測試 Studio 筆記本
在本節中，您可以使用 Studio 筆記本查詢 Kinesis 資料串流中的資料。
1. 前往 [https://console.aws.amazon.com/managed-flink/home?region=us-east-1\$1/applications/dashboard](https://console.aws.amazon.com/managed-flink/home?region=us-east-1#/applications/dashboard) 開啟 Managed Service in the Apache Flink 主控台。
1. 在 **Managed Service for Apache Flink 應用程式**頁面，選擇 **Studio 筆記本**標籤。選擇 **MyNotebook**。
1. 在 **MyNotebook** 頁面，選擇**在 Apache Zeppelin 中開啟**。
Apache Zeppelin 介面會在新標籤中開啟。
1. 在**歡迎來到 Zeppelin\$1** 頁面，選擇 **Zeppelin 筆記**。
1. 在 **Zeppelin 筆記**頁面，在新筆記中輸入以下查詢：
```
%flink.ssql(type=update)
select * from stock
```
選擇執行圖示。
一小段時間後，筆記會顯示 Kinesis 資料串流中的資料。
若要為應用程式開啟 Apache Flink 儀表板以檢視操作層面，請選擇 **FLINK 作業**。如需 Flink 儀表板的詳細資訊，請參閱 [Managed Service for Apache Flink 開發人員指南](https://docs.aws.amazon.com/)中的 [Apache Flink 儀表板](https://docs.aws.amazon.com/managed-flink/latest/java/how-dashboard.html)。
如需 Flink 串流 SQL 查詢的更多範例，請參閱 [Apache Flink 文件](https://nightlies.apache.org/flink/flink-docs-release-1.15/)中的[查詢](https://nightlies.apache.org/flink/flink-docs-release-1.15/dev/table/sql/queries.html)。
# 使用 Amazon MSK 建立 Studio 筆記本
本教學課程說明如何建立使用 Amazon MSK 叢集作為來源的 Studio 筆記本。
**Topics**
+ [設定 Amazon MSK 叢集](#example-notebook-msk-setup)
+ [將 NAT 閘道新增至 VPC](#example-notebook-msk-nat)
+ [建立 AWS Glue 連線和資料表](#example-notebook-msk-glue)
+ [使用 Amazon MSK 建立 Studio 筆記本](#example-notebook-msk-create)
+ [將資料傳送至 Amazon MSK 叢集](#example-notebook-msk-send)
+ [測試 Studio 筆記本](#example-notebook-msk-test)
## 設定 Amazon MSK 叢集
在本教學課程中，您需要一個允許純文字存取的 Amazon MSK 叢集。如果尚未設定 Amazon MSK 叢集，請依照 [Amazon MSK 使用入門](https://docs.aws.amazon.com/msk/latest/developerguide/getting-started.html)教學課程來建立 Amazon VPC、Amazon MSK 叢集、主題和 Amazon EC2 用戶端執行個體。
跟隨教學課程學習時，請執行下列動作：
+ 在[步驟 3：建立 Amazon MSK 叢集](https://docs.aws.amazon.com/msk/latest/developerguide/create-cluster.html)的步驟 4 中，將 `ClientBroker` 值從 `TLS` 變更為 **PLAINTEXT**。
## 將 NAT 閘道新增至 VPC
如果依照 [Amazon MSK 使用入門](https://docs.aws.amazon.com/msk/latest/developerguide/getting-started.html)教學課程建立 Amazon MSK 叢集，或者您現有的 Amazon VPC 還沒有適用於其私有子網路的 NAT 閘道，則必須將 NAT 閘道新增到 Amazon VPC。下圖顯示一般架構。
![\[AWS VPC architecture with public and private subnets, NAT gateway, and Glue Data Catalog integration.\]](http://docs.aws.amazon.com/zh_tw/managed-flink/latest/java/images/vpc_05.png)
若要為您的 Amazon VPC 建立 NAT 閘道，請執行下列動作：
1. 前往 [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/) 開啟 Amazon VPC 主控台。
1. 從左側導覽列選擇 **NAT 閘道**。
1. 在 **NAT 閘道**頁面，選擇**建立 NAT 閘道**。
1. 在**建立 NAT 閘道**頁面，提供下列值：
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_tw/managed-flink/latest/java/example-notebook-msk.html)
選擇**建立 NAT 閘道**。
1. 在導覽列中，選擇**路由表**。
1. 選擇**建立路由表**。
1. 在**建立路由表**頁面，提供以下資訊：
+ **名稱標籤**：**ZeppelinRouteTable**
+ **VPC****：選擇 VPC (例如AWS KafkaTutorialVPC)**。
選擇**建立**。
1. 在路由表清單中，選擇 **ZeppelinRouteTable**。選擇**路由**標籤，然後選擇**編輯路由**。
1. 在**編輯路由**標籤中，選擇**新增路由**。
1. 在 **** 中，為**目標**輸入 **0.0.0.0/0**。為**目標**選擇 **NAT 閘道**、**ZeppelinGateway**。選擇**儲存路由**。選擇**關閉**。
1. 在「路由表」頁面，已選取 **ZeppelinRouteTable** 時，選擇**子網路關聯**標籤。選擇**編輯子網路關聯**。
1. 在**編輯子網路關聯**頁面，選擇 **AWS KafkaTutorialSubnet2** 和 **AWS KafkaTutorialSubnet3**。選擇 **Save** (儲存)。
## 建立 AWS Glue 連線和資料表
您的 Studio 筆記本使用 [AWS Glue](https://docs.aws.amazon.com/glue/latest/dg/what-is-glue.html) 資料庫取得有關 Amazon MSK 資料來源的中繼資料。在本節中，您會建立 AWS Glue 連線，說明如何存取 Amazon MSK 叢集，以及說明如何將資料來源中的資料呈現給 Studio 筆記本等用戶端的 AWS Glue 資料表。
**建立連線**
1. 登入 AWS 管理主控台 ，並在 https：//[https://console.aws.amazon.com/glue/](https://console.aws.amazon.com/glue/) 開啟 AWS Glue 主控台。
1. 如果您還沒有 AWS Glue 資料庫，請從左側導覽列中選擇**資料庫**。選擇**新增資料庫**。在**新增資料庫**視窗中，為**資料庫名稱**輸入 **default**。選擇 **Create** (建立)。
1. 從左側導覽列選擇**連線**。選擇**新增連線**。
1. 在**新增連線**視窗中，提供下列值：
+ 對於**連線名稱**，請輸入 **ZeppelinConnection**。
+ 對於**連線類型**，請選擇 **Kafka**。
+ 對於 **Kafka 啟動伺服器 URL**，請為叢集提供啟動代理程式字串。您可以從 MSK 主控台或輸入下列 CLI 命令來取得啟動代理程式：
```
aws kafka get-bootstrap-brokers --region us-east-1 --cluster-arn ClusterArn
```
+ 取消核取**需要 SSL 連線**核取方塊。
選擇**下一步**。
1. 在 **VPC** 頁面，提供下列值：
+ 針對 **VPC**，選擇 VPC 的名稱 （例如 ** AWS KafkaTutorialVPC**)。
+ 對於**子網路**，請選擇 **AWS KafkaTutorialSubnet2**。
+ 對於**安全群組**，請選擇所有可用的群組。
選擇 **Next (下一步)**。
1. 在**連線屬性** / **連線存取權**頁面，選擇**完成**。
**建立資料表**
**注意**
您可以依照下列步驟所述手動建立資料表，也可以在 Apache Zeppelin 的筆記本中，使用針對 Managed Service for Apache Flink 的建立資料表連接器程式碼，透過 DDL 陳述式建立資料表。然後，您可以簽入 AWS Glue ，以確保正確建立資料表。
1. 在左側導覽列中，選擇**資料表**。在**資料表**頁面，選擇**新增資料表** > **手動新增資料表**。
1. 在**設定資料表**頁面，為**資料表名稱**輸入 **stock**。請務必選取先前建立的資料庫。選擇 **Next (下一步)**。
1. 在**新增資料存放區**頁面，選擇 **Kafka**。對於**主題名稱**，請輸入您的主題名稱 (例如 **AWS KafkaTutorialTopic**)。針對**連線**，選擇 **ZeppelinConnection**。
1. 在**分類**頁面，選擇 **JSON**。選擇 **Next (下一步)**。
1. 在**定義結構描述**頁面，選擇「新增資料欄」以新增資料欄。新增具有下列屬性的欄：
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_tw/managed-flink/latest/java/example-notebook-msk.html)
選擇 **Next (下一步)**。
1. 在下一頁上，確認您的設定，然後選擇**完成**。
1. 從資料表清單中選取您新建立的資料表。
1. 選擇**編輯資料表**並新增下列屬性：
+ 金鑰：`managed-flink.proctime`，值： `proctime`
+ 金鑰：`flink.properties.group.id`，值： `test-consumer-group`
+ 金鑰：`flink.properties.auto.offset.reset`，值： `latest`
+ 金鑰：`classification`，值： `json`
如果沒有這些鍵/值對，Flink 筆記本會執行為錯誤。
1. 選擇**套用**。
## 使用 Amazon MSK 建立 Studio 筆記本
現在，您已建立應用程式使用的資源，接下來可以建立您的 Studio 筆記本。
**Topics**
+ [使用 建立 Studio 筆記本 AWS 管理主控台](#example-notebook-create-msk-console)
+ [使用 建立 Studio 筆記本 AWS CLI](#example-notebook-msk-create-api)
**注意**
您也可以選擇現有叢集，然後選擇**即時處理資料**，從 Amazon MSK 主控台建立 Studio 筆記本。
### 使用 建立 Studio 筆記本 AWS 管理主控台
1. 前往 [https://console.aws.amazon.com/managed-flink/home?region=us-east-1\$1/applications/dashboard](https://console.aws.amazon.com/managed-flink/home?region=us-east-1#/applications/dashboard) 開啟 Managed Service in the Apache Flink 主控台。
1. 在 **Managed Service for Apache Flink 應用程式**頁面，選擇 **Studio** 標籤。選擇**建立 Studio 筆記本**。
**注意**
若要從 Amazon MSK 或 Kinesis Data Streams 主控台建立 Studio 筆記本，請選取您的輸入 Amazon MSK 叢集或 Kinesis 資料串流，然後選擇**即時處理資料**。
1. 在**建立 Studio 筆記本**頁面，提供下列資訊：
+ 為 **Studio 筆記本名稱**輸入 **MyNotebook**。
+ 為 **AWS Glue 資料庫**選擇**預設值**。
選擇**建立 Studio 筆記本**。
1. 在 **MyNotebook** 頁面，選擇**組態**標籤。在**網路模式**區段中，選擇**編輯**。
1. 在**編輯 MyNotebook 聯網**頁面，選擇**以 Amazon MSK 叢集為基礎的 VPC 組態**。為 **Amazon MSK 叢集**選擇 Amazon MSK 叢集。選擇**儲存變更**。
1. 在 **MyNotebook** 頁面，選擇**執行**。等待**狀態**顯示為**執行中**。
### 使用 建立 Studio 筆記本 AWS CLI
若要使用 建立 Studio 筆記本 AWS CLI，請執行下列動作：
1. 請務必備妥下列資訊：您需要這些值來建立應用程式。
+ 帳戶 ID。
+ 子網路 ID 以及包含 Amazon MSK 叢集的 Amazon VPC 的安全群組 ID。
1. 建立稱為 `create.json` 的檔案，其中具有以下內容。使用您的資訊取代預留位置的值。
```
{
"ApplicationName": "MyNotebook",
"RuntimeEnvironment": "ZEPPELIN-FLINK-3_0",
"ApplicationMode": "INTERACTIVE",
"ServiceExecutionRole": "arn:aws:iam::AccountID:role/ZeppelinRole",
"ApplicationConfiguration": {
"ApplicationSnapshotConfiguration": {
"SnapshotsEnabled": false
},
"VpcConfigurations": [
{
"SubnetIds": [
"SubnetID 1",
"SubnetID 2",
"SubnetID 3"
],
"SecurityGroupIds": [
"VPC Security Group ID"
]
}
],
"ZeppelinApplicationConfiguration": {
"CatalogConfiguration": {
"GlueDataCatalogConfiguration": {
"DatabaseARN": "arn:aws:glue:us-east-1:AccountID:database/default"
}
}
}
}
}
```
1. 若要建立應用程式，請執行下列命令：
```
aws kinesisanalyticsv2 create-application --cli-input-json file://create.json
```
1. 命令完成後，您應該會看到類似如下的輸出，其中顯示新 Studio 筆記本的詳細資料：
```
{
"ApplicationDetail": {
"ApplicationARN": "arn:aws:kinesisanalyticsus-east-1:012345678901:application/MyNotebook",
"ApplicationName": "MyNotebook",
"RuntimeEnvironment": "ZEPPELIN-FLINK-3_0",
"ApplicationMode": "INTERACTIVE",
"ServiceExecutionRole": "arn:aws:iam::012345678901:role/ZeppelinRole",
...
```
1. 若要執行應用程式，請執行下列命令：使用您的帳戶 ID 取代範例值。
```
aws kinesisanalyticsv2 start-application --application-arn arn:aws:kinesisanalyticsus-east-1:012345678901:application/MyNotebook\
```
## 將資料傳送至 Amazon MSK 叢集
在本節中，您會在 Amazon EC2 用戶端中執行 Python 指令碼，以將資料傳送到您的 Amazon MSK 資料來源。
1. 連線到 Amazon EC2 用戶端。
1. 執行以下命令來安裝 Python 版本 3、Pip 和 Kafka for Python 套件，並確認操作：
```
sudo yum install python37
curl -O https://bootstrap.pypa.io/get-pip.py
python3 get-pip.py --user
pip install kafka-python
```
1. 輸入下列命令，在用戶端機器 AWS CLI 上設定 ：
```
aws configure
```
提供帳戶憑證，並為 `region` 提供 **us-east-1**。
1. 建立稱為 `stock.py` 的檔案，其中具有以下內容。使用 Amazon MSK 叢集的啟動代理程式字串取代範例值，如果您的主題不是 **AWS KafkaTutorialTopic**，請更新主題名稱：
```
from kafka import KafkaProducer
import json
import random
from datetime import datetime
BROKERS = "<>"
producer = KafkaProducer(
bootstrap_servers=BROKERS,
value_serializer=lambda v: json.dumps(v).encode('utf-8'),
retry_backoff_ms=500,
request_timeout_ms=20000,
security_protocol='PLAINTEXT')
def getStock():
data = {}
now = datetime.now()
str_now = now.strftime("%Y-%m-%d %H:%M:%S")
data['event_time'] = str_now
data['ticker'] = random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV'])
price = random.random() * 100
data['price'] = round(price, 2)
return data
while True:
data =getStock()
# print(data)
try:
future = producer.send("AWSKafkaTutorialTopic", value=data)
producer.flush()
record_metadata = future.get(timeout=10)
print("sent event to Kafka! topic {} partition {} offset {}".format(record_metadata.topic, record_metadata.partition, record_metadata.offset))
except Exception as e:
print(e.with_traceback())
```
1. 使用下列命令執行指令碼：
```
$ python3 stock.py
```
1. 完成下一節時，讓指令碼保持執行狀態。
## 測試 Studio 筆記本
在本節中，您可以使用 Studio 筆記本查詢 Amazon MSK 叢集中的資料。
1. 前往 [https://console.aws.amazon.com/managed-flink/home?region=us-east-1\$1/applications/dashboard](https://console.aws.amazon.com/managed-flink/home?region=us-east-1#/applications/dashboard) 開啟 Managed Service in the Apache Flink 主控台。
1. 在 **Managed Service for Apache Flink 應用程式**頁面，選擇 **Studio 筆記本**標籤。選擇 **MyNotebook**。
1. 在 **MyNotebook** 頁面，選擇**在 Apache Zeppelin 中開啟**。
Apache Zeppelin 介面會在新標籤中開啟。
1. 在**歡迎來到 Zeppelin\$1** 頁面，選擇 **Zeppelin 新筆記**。
1. 在 **Zeppelin 筆記**頁面，在新筆記中輸入以下查詢：
```
%flink.ssql(type=update)
select * from stock
```
選擇執行圖示。
應用程式會顯示 Amazon MSK 叢集中的資料。
若要為應用程式開啟 Apache Flink 儀表板以檢視操作層面，請選擇 **FLINK 作業**。如需 Flink 儀表板的詳細資訊，請參閱 [Managed Service for Apache Flink 開發人員指南](https://docs.aws.amazon.com/)中的 [Apache Flink 儀表板](https://docs.aws.amazon.com/managed-flink/latest/java/how-dashboard.html)。
如需 Flink 串流 SQL 查詢的更多範例，請參閱 [Apache Flink 文件](https://nightlies.apache.org/flink/flink-docs-release-1.15/)中的[查詢](https://nightlies.apache.org/flink/flink-docs-release-1.15/dev/table/sql/queries.html)。
# 清除您的應用程式和相依資源
## 刪除 Studio 筆記本
1. 開啟 Managed Service for Apache Flink 主控台。
1. 選擇 **MyNotebook**。
1. 依序選擇**動作**和**刪除**。
## 刪除您的 AWS Glue 資料庫和連線
1. 在 https：//[https://console.aws.amazon.com/glue/](https://console.aws.amazon.com/glue/) 開啟 AWS Glue 主控台。
1. 從左側導覽列選擇**資料庫**。核取**預設**旁邊的核取方塊以選取它。依序選擇**動作**和**刪除資料庫**。確認您的選擇。
1. 從左側導覽列選擇**連線**。選中 **ZeppelinConnection** 旁邊的核取方塊以選取它。依序選擇**動作**和**刪除連線**。確認您的選擇。
## 刪除 IAM 角色和政策
1. 前往 [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/) 開啟 IAM 主控台。
1. 從左側導覽選單選擇**角色**。
1. 使用搜尋列搜尋 **ZeppelinRole** 角色。
1. 選擇 **ZeppelinRole** 角色。選擇**刪除角色**。確認刪除。
## 刪除 CloudWatch 日誌群組
使用主控台建立應用程式時，主控台會為您建立 CloudWatch 日誌群組和日誌串流。如果您已使用 AWS CLI建立應用程式，則沒有日誌群組和串流。
1. 透過 [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/) 開啟 CloudWatch 主控台。
1. 從左側導覽列選擇**日誌群組**。
1. 選擇 **/AWS/KinesisAnalytics/MyNotebook** 日誌群組。
1. 選擇**動作**、**刪除日誌群組**。確認刪除。
## 清除 Kinesis Data Streams 資源
若要刪除 Kinesis 串流，請開啟 Kinesis Data Streams 主控台，選取您的 Kinesis 串流，然後選擇**動作** > **刪除**。
## 清除 MSK 資源
如果您已在本教學課程中建立 Amazon MSK 叢集，請按照本節中的步驟進行操作。本節說明如何清理 Amazon EC2 用戶端執行個體、Amazon VPC 和 Amazon MSK 叢集。
### 刪除您的 Amazon MSK 叢集
如果您已在本教學課程中建立 Amazon MSK 叢集，請按照以下步驟進行操作。
1. 開啟 Amazon MSK 主控台，網址為 [https://console.aws.amazon.com/msk/home?region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)。
1. 選擇 **AWS KafkaTutorialCluster**。選擇 **刪除**。在出現的視窗中輸入 **delete**，然後確認選擇。
### 終止您的用戶端執行個體
如果您已在本教學課程中建立 Amazon EC2 用戶端執行個體，請按照以下步驟進行操作。
1. 前往 [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) 開啟 Amazon EC2 主控台。
1. 從左側導覽列中選擇**執行個體**。
1. 選擇 **ZeppelinClient** 旁邊的核取方塊以選取它。
1. 依序選擇**執行個體狀態**和**終止執行個體**。
### 刪除 Amazon VPC
如果您已在本教學課程中建立 Amazon VPC，請按照以下步驟進行操作。
1. 前往 [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) 開啟 Amazon EC2 主控台。
1. 從左側導覽列選擇**網路介面**。
1. 在搜尋列中輸入 VPC ID，然後按 Enter 鍵。
1. 選取資料表標題中的核取方塊，以選取所有顯示的網路介面。
1. 選擇 **Actions** (動作)、**Detach** (分離)。在出現的視窗中，選擇**強制分離**下方的**啟用**。選擇**分離**，然後等待所有網路介面都到達**可用**狀態。
1. 選取資料表標題中的核取方塊，以再次選取所有顯示的網路介面。
1. 選擇 **動作**、**刪除**。確認動作。
1. 在 [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/) 開啟 Amazon VPC 主控台。
1. 選取 **AWS KafkaTutorialVPC**。依序選擇**動作**和**刪除 VPC**。輸入 **delete** 並確認刪除。