本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
教學課程:使用 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 Elastic Compute Cloud (Amazon EC2) 上同時執行生產者和取用者程式碼。
以下所示範例使用美國西部 (奧勒岡) 區域,但在任何支援 Kinesis Data Streams 的AWS 區域內均能運作。