教程:使用KPL和 KCL 1.x 處理實時庫存數據 - Amazon Kinesis Data Streams

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

教程:使用KPL和 KCL 1.x 處理實時庫存數據

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

重要

建立串流後,您的帳戶會產生 Kinesis Data Streams 使用的象徵性費用,因為 Kinesis Data Streams 不符合免費方案的 AWS 資格。取用者應用程式啟動之後,也會象徵性地收取 Amazon DynamoDB 使用費。取用者應用程式使用 DynamoDB 追蹤處理狀態。當您使用此應用程式完畢後,請刪除您的 AWS 資源以避免其產生費用。如需詳細資訊,請參閱清除資源

程式碼不會存取實際股票市場資料,而是模擬股票交易串流。其做法是使用隨機股票交易產生器,以截至 2015 年 2 月為止市值排名前 25 位的股票實際市場資料做為起始點。若您能夠存取即時股票交易串流,可能會希望從該串流衍生出實用且及時的統計資料。例如,您可能想要執行滑動時段分析,以得知前 5 分鐘內購買的最熱門股票。或者,您可能希望在銷售訂單過大 (即股份過多) 時接獲通知。您可透過擴展此系列程式碼以提供這類功能。

您可以在桌上型電腦或筆記型電腦上完成本教學中的步驟,並在相同的機器或任何支援已定義需求的平台 (例如 Amazon 彈性運算雲端 (AmazonEC2) 上執行生產者和消費者程式碼。

以下所示範例使用美國西部 (奧勒岡) 區域,但在任何支援 Kinesis Data Streams 的AWS 區域內均能運作。