本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
本教學課程的情境涉及將股票交易擷取至資料串流和撰寫簡單的 Amazon Managed Service for Apache Flink 應用程式對該串流執行計算。您將學習如何將記錄串流傳送到 Kinesis Data Streams,以及實作幾乎即時消耗和處理記錄的應用程式。
透過 Amazon 的 Apache Flink 受管服務,您可以使用 Java 或斯卡拉來處理和分析串流資料。此服務可讓您針對串流來源撰寫和執行 Java 或 Scala 程式碼,以執行時間序列分析、提供即時儀表板,以及建立即時指標。
您可以使用基於 Apache Flink
重要
建立兩個資料串流和一個應用程式之後,您的帳戶會產生 Kinesis Data Streams 和 Apache Flink 使用受管服務的象徵性費用,因為這些資料不符合 AWS 免費方案。完成此應用程序後,請刪除您的 AWS 停止產生費用的資源。
程式碼不會存取實際股票市場資料,而是模擬股票交易串流。它會使用隨機股票交易產生器來執行此作業。若您能夠存取即時股票交易串流,可能會希望從該串流衍生出實用且及時的統計資料。例如,您可能想要執行滑動時段分析,以得知前 5 分鐘內購買的最熱門股票。或者,您可能希望在銷售訂單過大 (即股份過多) 時接獲通知。您可透過擴展此系列程式碼以提供這類功能。
顯示的範例使用美國西部 (奧勒岡) 區域,但它們適用於任何一個 AWS 支援阿帕奇 Flink 管理服務的區域。
任務
完成練習的先決條件
若要完成本指南中的步驟,您必須執行下列各項:
-
Java 開發工具包
(JDK)版本 8. 將 JAVA_HOME
環境變數設定為指向您的JDK安裝位置。 -
我們建議您使用開發環境 (如 Eclipse Java Neon
或 IntelliJ Idea ) 來開發和編譯您的應用程式。 -
Git 用戶端。
如果您尚未安裝 Git 用戶端,請先安裝。 -
Apache Maven 編譯器外掛程式
。Maven 必須在您的工作路徑中。若要測試您的 Apache Maven 安裝,輸入以下資訊: $ mvn -version
開始執行,請移至 設置一個 AWS 帳戶並創建管理員用戶。