開始使用 Amazon Managed Service for Apache Flink
為什麼選擇 Amazon Managed Service for Apache Flink?
有了 Amazon Managed Service for Apache Flink,您就可以使用 Apache Flink 即時轉換和分析串流資料。Amazon Managed Service for Apache Flink 可簡化 Apache Flink 工作負載的建置及管理,且可讓您整合應用程式和其他 AWS 服務。
使用 Apache Flink 和 Apache Beam 建置串流應用程式
步驟 1:將開放原始碼程式庫下載至您喜愛的 IDE
您可以從下載包括 AWS SDK、Apache Flink 和 AWS 服務適用容器的開放原始碼程式庫開始。
步驟 2:使用 Apache Flink 或 Apache Beam 建置範例應用程式
您可以使用資料串流和串流運算子撰寫 Apache Flink 應用程式的程式碼。應用程式資料串流是您使用應用程式的程式碼執行處理所依據的資料結構。由來源傳出的資料會持續流入應用程式資料串流。一或多個串流運算子會用來定義您的應用程式資料串流處理。
步驟 3:將您的程式碼上傳至 Amazon Managed Service for Apache Flink
一旦建置完成,將您的程式碼上傳到 Amazon Managed Service for Apache Flink。這項服務會處理持續執行您的即時應用程式所需的一切事項,包含自動擴展以符合傳入資料的數量及輸送量。
以直覺的方式使用 Amazon Managed Service for Apache Flink Studio
第 1 步:建立 Amazon Managed Service for Apache Flink Studio 應用程式
從 Amazon Managed Service for Apache Flink、Amazon MSK 或 Amazon Kinesis Data Streams 主控台開始。使用自訂連接器,連接至任何其他資料來源。
步驟 2:在無伺服器筆記本中撰寫 SQL、Python 和 Scala 程式碼,並開發 Apache Flink 應用程式
在筆記本中執行個別段落、檢視有脈絡的結果,並使用 Apache Zeppelin 的內建視覺化加速開發。您也可以在程式碼中採用使用者定義函數。
步驟 3:建置並部署為 Amazon Managed Service for Apache Flink 串流應用程式
只要幾個步驟,就可以將您的程式碼部署為連續執行的串流處理應用程式。部署完成的應用程式會是處於耐用狀態且可自動調整規模的 Amazon Managed Service for Apache Flink 應用程式。將程式碼放進正式環境之前,您也會有機會變更來源、目的地、日誌記錄和監控層級。