有了 Amazon Managed Service for Apache Flink,您就可以使用 Apache Flink 即時轉換和分析串流資料。Amazon Managed Service for Apache Flink 可簡化 Apache Flink 工作負載的建置及管理,且可讓您整合應用程式和其他 AWS 服務。

步驟 1:將開放原始碼程式庫下載至您喜愛的 IDE

建立 Java 應用程式

您可以從下載包括 AWS SDK、Apache Flink 和 AWS 服務適用容器的開放原始碼程式庫開始。 

Java 範本程式碼

您可以使用資料串流和串流運算子撰寫 Apache Flink 應用程式的程式碼。應用程式資料串流是您使用應用程式的程式碼執行處理所依據的資料結構。由來源傳出的資料會持續流入應用程式資料串流。一或多個串流運算子會用來定義您的應用程式資料串流處理。

設定 Java 應用程式

一旦建置完成,將您的程式碼上傳到 Amazon Managed Service for Apache Flink。這項服務會處理持續執行您的即時應用程式所需的一切事項,包含自動擴展以符合傳入資料的數量及輸送量。 

建立 Java 應用程式

從 Amazon Managed Service for Apache Flink、Amazon MSK 或 Amazon Kinesis Data Streams 主控台開始。使用自訂連接器,連接至任何其他資料來源。

Java 範本程式碼

在筆記本中執行個別段落、檢視有脈絡的結果,並使用 Apache Zeppelin 的內建視覺化加速開發。您也可以在程式碼中採用使用者定義函數。 

設定 Java 應用程式

只要幾個步驟,就可以將您的程式碼部署為連續執行的串流處理應用程式。部署完成的應用程式會是處於耐用狀態且可自動調整規模的 Amazon Managed Service for Apache Flink 應用程式。將程式碼放進正式環境之前,您也會有機會變更來源、目的地、日誌記錄和監控層級。 

線上學習

教學研討會

在此研討會中,您將建置一個端對端串流架構,近乎即時地擷取、分析和視覺化串流資料。您可以運用近乎即時的速度來分析計程車隊的遙測資料,開始為紐約市計程車公司的車隊營運最佳化。

進一步了解 »
預先建置的解決方案

使用預先建置的解決方案快速入門。運用 Amazon Managed Service for Apache Flink 專屬 AWS 串流資料解決方案,您就可以處理即時串流使用案例,例如擷取大量應用程式日誌、分析點選流資料、持續交付至資料湖,以及更多功能。 

探索 »
教學研討會

在此研討會中,您將建立串流應用程式,以辨識進入您賭場並正在投注大筆金額的客戶。當投注大筆金額的消費者坐在賭桌前時,該應用程式將向您傳送電子郵件。您還將辨識需要補充籌碼的賭桌,並透過他們的投注及獲勝模式辨識賭場潛在的騙子。 

進一步了解 »

Amazon Kinesis Data Analytics 入門

註冊 AWS 帳戶
註冊 AWS 帳戶

立即存取 AWS 免費方案

Read the documentation
查看入門指南

透過 SQLApache Flink 的逐步指南了解如何使用 Amazon Kinesis Data Analytics。

開始在主控台進行建置
開始建立串流應用程式

從 Amazon Kinesis Data Analytics 主控台建置您的第一個串流應用程式。