建立工作室筆記本 - Managed Service for Apache Flink

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

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

建立工作室筆記本

Studio 筆記本包含用 Python 或 Scala 編寫的SQL查詢或程序，這些查詢或程序在流數據上運行並返回分析結果。您可以使用主控台或建立應用程式CLI，並提供查詢以分析資料來源中的資料。

應用程式具有下列元件：

  • 資料來源，例如亞馬遜MSK叢集、Kinesis 資料串流或 Amazon S3 儲存貯體。

  • 一個 AWS Glue 數據庫。此資料庫包含儲存資料來源、目標結構描述和端點的資料表。如需詳細資訊，請參閱 使用 AWS Glue。

  • 應用程式的程式碼。您的程式碼會實作您的分析查詢或程式。

  • 您的應用程式設定和執行期屬性。如需應用程式設定和執行期屬性的相關資訊，請參閱 Apache Flink 應用程式開發人員指南中的下列主題：

    • 應用程式平行處理和擴展：您可以使用應用程式的平行處理設定來控制應用程式可同時執行的查詢數目。如果查詢具有多個執行路徑，則還可以利用增加的平行處理，如下列情況所示：

      • 處理 Kinesis 資料串流的多個碎片時

      • 使用 KeyBy 運算子分割資料時。

      • 使用多個視窗運算子時

      如需應用程式擴展的詳細資訊，請參閱 Managed Service for Apache Flink 中的應用程式擴展。

    • 記錄和監控：如需應用程式記錄和監控的相關資訊，請參閱 Amazon Managed Service for Apache Flink 中的記錄和監控。

    • 應用程式使用檢查點和儲存點進行容錯。依預設，Studio 筆記本不啟用檢查點和儲存點。

您可以使用 AWS Management Console 或建立您的 Studio 筆記本 AWS CLI。

從主控台建立應用程式時，您可以使用下列選項：

  • 在 Amazon 主MSK控台中選擇您的叢集，然後選擇「即時處理資料」。

  • 在 Kinesis Data Streams 主控台中，選擇您的資料串流，然後在應用程式標籤上選擇即時處理資料。

  • 在 Managed Service for Apache Flink 主控台中，選擇 Studio 標籤，然後選擇建立 Studio 筆記本。

如需教學課程，請參閱使用 Managed Service for Apache Flink 進行事件偵測。

如需更進階 Studio 筆記本解決方案的範例，請參閱 Apache Flink 用於 Amazon Managed Service for Apache Flink Studio。