教學：使用適用於 Apache Flink 的 Amazon 託管服務分析即時庫存資料

本教學課程的情境涉及將股票交易擷取至資料串流和撰寫簡單的 Amazon Managed Service for Apache Flink 應用程式對該串流執行計算。您將學習如何將記錄串流傳送到 Kinesis Data Streams，以及實作幾乎即時消耗和處理記錄的應用程式。

透過 Amazon 的 Apache Flink 受管服務，您可以使用 Java 或斯卡拉來處理和分析串流資料。此服務可讓您針對串流來源撰寫和執行 Java 或 Scala 程式碼，以執行時間序列分析、提供即時儀表板，以及建立即時指標。

您可以使用基於 Apache Flink 的開放原始碼程式庫，在 Apache Flink 的受管服務中建置 Flink 應用程式。Apache Flink 是處理資料串流的熱門框架及引擎。

重要

建立兩個資料串流和一個應用程式之後，您的帳戶會產生 Kinesis Data Streams 和 Apache Flink 使用受管服務的象徵性費用，因為這些資料不符合 AWS 免費方案。完成此應用程序後，請刪除您的 AWS 停止產生費用的資源。

程式碼不會存取實際股票市場資料，而是模擬股票交易串流。它會使用隨機股票交易產生器來執行此作業。若您能夠存取即時股票交易串流，可能會希望從該串流衍生出實用且及時的統計資料。例如，您可能想要執行滑動時段分析，以得知前 5 分鐘內購買的最熱門股票。或者，您可能希望在銷售訂單過大 (即股份過多) 時接獲通知。您可透過擴展此系列程式碼以提供這類功能。

顯示的範例使用美國西部 (奧勒岡) 區域，但它們適用於任何一個 AWS 支援阿帕奇 Flink 管理服務的區域。

任務

• 完成練習的先決條件
• 設置一個 AWS 帳戶並創建管理員用戶
• 設定 AWS Command Line Interface (AWS CLI)
• 為 Apache Flink 應用程式建立並執行受管理的服務

完成練習的先決條件

若要完成本指南中的步驟，您必須執行下列各項：

• Java 開發工具包（JDK）版本 8. 將JAVA_HOME環境變數設定為指向您的JDK安裝位置。

• 我們建議您使用開發環境 (如 Eclipse Java Neon 或 IntelliJ Idea) 來開發和編譯您的應用程式。

• Git 用戶端。如果您尚未安裝 Git 用戶端，請先安裝。

• Apache Maven 編譯器外掛程式。Maven 必須在您的工作路徑中。若要測試您的 Apache Maven 安裝，輸入以下資訊：

  $ mvn -version

開始執行，請移至 設置一個 AWS 帳戶並創建管理員用戶。