開始使用 Amazon Managed Service for Apache Flink (資料表 API) - Managed Service for Apache Flink

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

開始使用 Amazon Managed Service for Apache Flink (資料表 API)

本節介紹 Managed Service for Apache Flink 的基本概念,以及使用資料表 API 和 SQL 在 Java 中實作應用程式。它示範如何在相同應用程式中切換不同的 APIs,並說明建立和測試應用程式的可用選項。此外,它還提供了相關指示,以協助您安裝完成本指南教學課程以及建立您的第一個應用程式所需要的工具。

檢閱 Managed Service for Apache Flink 應用程式的元件

注意

Managed Service for Apache Flink 支援所有 Apache Flink APIs並可能支援所有 JVM 語言。根據您選擇的 API,應用程式和實作的結構略有不同。本教學課程涵蓋使用資料表 API 和 SQL 的應用程式實作,以及與在 Java 中實作之 DataStream API 的整合。

為了處理資料,您的 Managed Service for Apache Flink 應用程式使用 Java 應用程式來處理輸入,並使用 Apache Flink 執行時間產生輸出。

典型的 Apache Flink 應用程式具有下列元件:

  • 執行期屬性:您可以使用執行期屬性將組態參數傳遞至應用程式,而無需修改和重新發佈程式碼。

  • 來源:應用程式會耗用來自一或多個來源的資料。來源使用連接器從 和外部系統讀取資料,例如 Kinesis 資料串流或 Amazon MSK 主題。對於開發或測試,您也可以讓來源隨機 【產生測試資料。如需詳細資訊,請參閱將串流資料來源新增至 Managed Service for Apache Flink。使用 SQL 或資料表 API,來源會定義為來源資料表

  • 轉換:應用程式會透過一個或多個可篩選、豐富或彙總資料的轉換來處理資料。使用 SQL 或資料表 API 時,轉換會定義為透過資料表或檢視的查詢

  • 接收器:應用程式會透過接收器將資料傳送至外部系統。接收器使用連接器將資料傳送至外部系統,例如 Kinesis 資料串流、Amazon MSK 主題、Amazon S3 儲存貯體或關聯式資料庫。您也可以使用特殊連接器來列印輸出,僅用於開發目的。使用 SQL 或資料表 API 時,目的地會定義為您要插入結果的目的地資料表。如需詳細資訊,請參閱在 Managed Service for Apache Flink 中使用接收器寫入資料

您的應用程式需要一些外部相依性,例如應用程式使用的 Flink 連接器,或可能的 Java 程式庫。若要在 Amazon Managed Service for Apache Flink 中執行,您必須將應用程式與相依性封裝在 fat-JAR 中,並將其上傳至 Amazon S3 儲存貯體。然後建立 Managed Service for Apache Flink 應用程式。您可以傳遞程式碼套件位置,以及其他執行時間組態參數。本教學課程示範如何使用 Apache Maven 封裝應用程式,以及如何在您選擇的 IDE 中於本機執行應用程式。

完成必要的先決條件

開始本教學課程之前,請先完成 開始使用 Amazon Managed Service for Apache Flink (DataStream API) 中的前兩個步驟:

若要開始使用,請參閱 建立應用程式

下一步驟

清除 AWS 資源