建立 Managed Service for Apache Flink 應用程式 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

建立 Managed Service for Apache Flink 應用程式

本主題包含建立 Managed Service for Apache Flink 應用程式的相關資訊。

建置 Managed Service for Apache Flink 應用程式程式碼

本節說明您用來建置 Managed Service for Apache Flink 應用程式的應用程式程式碼的元件。

建議將 Apache Flink 應用程式的最新支援版本用於您的應用程式程式碼。如需升級 Managed Service for Apache Flink 應用程式的相關資訊,請參閱針對 Apache Flink 使用就地版本升級

您可以使用 Apache Maven 建置應用程式的程式碼。Apache Maven 專案使用 pom.xml 檔案來指定它使用的元件的版本。

注意

Managed Service for Apache Flink 支援大小高達 512 MB JAR的檔案。如果您使用大於此值JAR的檔案,您的應用程式將無法啟動。

應用程式現在可以API從任何 Scala 版本使用 Java。您必須將您選擇的 Scala 標準程式庫綁定到 Scala 應用程式。

如需建立使用 Apache Beam 之 Managed Service for Apache Flink 應用程式的相關資訊,請參閱為 Apache Flink 應用程式使用具有託管服務的 Apache 光束

使用 Managed Service for Apache Flink 執行期 1.1.0 版及更新版本時,您可以指定您編譯應用程式時應用程式使用的 Apache Flink 版本。您可以使用 -Dflink.version 參數提供 Apache Flink 的版本。例如,如果您使用的是 Apache Flink 1.19.1,請提供下列項目:

mvn package -Dflink.version=1.19.1

如需使用舊版 Apache Flink 建置應用程式,請參閱 較早版本

建立 Managed Service for Apache Flink 應用程式

建置應用程式程式碼之後,請執行下列動作來建立 Managed Service for Apache Flink 應用程式:

  • 上傳應用程式的程式碼:將應用程式的程式碼上傳至 Amazon S3 儲存貯體。建立應用程式時,請指定應用程式程式碼的 S3 儲存貯體名稱和物件名稱。如需示範如何上傳應用程式程式碼的教學課程,請參閱教學課程:開始使用 Managed Service for Apache Flink 中的 DataStream API 教學課程。

  • 建立 Managed Service for Apache Flink:使用下列其中一種方法建立 Managed Service for Apache Flink 應用程式:

    • 使用 AWS 主控台建立 Managed Service for Apache Flink 應用程式:您可以使用 AWS 主控台建立和設定應用程式。

      當您使用主控台建立應用程式時,會為您建立應用程式的相依資源 (例如 CloudWatch Logs 串流、IAM角色和IAM政策)。

      使用主控台建立應用程式時,您可以從 Managed Service for Apache Flink - 建立應用程式頁面的下拉式清單中選取版本,來指定應用程式使用的 Apache Flink 版本。

      如需如何使用主控台建立應用程式的教學課程,請參閱教學課程:開始使用 Managed Service for Apache Flink 中的 DataStream API 教學課程。

    • 使用 建立 Managed Service for Apache Flink 應用程式 AWS CLI:您可以使用 建立和設定應用程式 AWS CLI。

      使用 建立應用程式時CLI,您還必須手動建立應用程式的相依資源 (例如 CloudWatch Logs 串流、IAM角色和IAM政策)。

      使用 建立應用程式時CLI,您可以使用 CreateApplication動作的 RuntimeEnvironment 參數指定應用程式使用的 Apache Flink 版本。

    注意

    您可以變更RuntimeEnvironment現有應用程式的 。如要瞭解如何作業,請參閱針對 Apache Flink 使用就地版本升級

啟動 Managed Service for Apache Flink 應用程式

建置應用程式的程式碼、將程式碼上傳至 S3,並建立 Managed Service for Apache Flink 應用程式之後,即可啟動應用程式。啟動 Managed Service Apache Flink 應用程式通常需要幾分鐘時間。

使用下列其中一種方法來啟動應用程式:

  • 使用 AWS 主控台啟動 Managed Service for Apache Flink 應用程式:您可以在 AWS 主控台的應用程式頁面上選擇執行,以執行應用程式。

  • 使用 啟動 Managed Service for Apache Flink 應用程式 AWS API:您可以使用 StartApplication動作執行應用程式。

驗證 Managed Service for Apache Flink 應用程式

您可以驗證應用程式是否正常運作,方式如下:

  • 使用 CloudWatch Logs:您可以使用 CloudWatch Logs 和 CloudWatch Logs Insights 來驗證應用程式是否正常運作。如需將 CloudWatch Logs 與 Managed Service for Apache Flink 應用程式搭配使用的相關資訊,請參閱 在 Amazon 管理服務中為 Apache Flink 進行日誌記錄和監控

  • 使用 CloudWatch 指標:您可以使用 CloudWatch 指標來監控應用程式的活動,或應用程式用於輸入或輸出的資源中的活動 (例如 Kinesis 串流、Firehose 串流或 Amazon S3 儲存貯體)。如需 CloudWatch 指標的詳細資訊,請參閱 Amazon CloudWatch 使用者指南中的使用指標

  • 監控輸出位置:如果應用程式將輸出寫入某個位置 (例如 Amazon S3 儲存貯體或資料庫),您可以為寫入的資料監控該位置。