教程:使用 KPL 和 KCL 1.x 处理实时股票数据 - Amazon Kinesis Data Streams
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

教程:使用 KPL 和 KCL 1.x 处理实时股票数据

本教程的场景涉及将股票交易引入数据流中并编写对流执行计算的简单 Amazon Kinesis Data Streams 应用程序。您将了解如何将记录流发送到 Kinesis Data Streams 并实施几乎能实时使用和处理记录的应用程序。

重要

在创建流后,将象征性地向您的账户收取 Kinesis Data Streams 使用费,因为 Kinesis 数据流没有获得Amazon免费套餐。在使用者应用程序启动后,也会象征性收取 Amazon DynamoDB 使用费用。使用者应用程序使用 DynamoDB 跟踪处理状态。完成使用此应用程序后,请删除您的Amazon资源停止产生费用。有关更多信息,请参阅 步骤 7:完成操作

代码不访问实际股票市场数据,而是模拟股票交易流。它通过使用随机股票交易生成器(将截至 2015 年 2 月市值排名前 25 位的股票的实际市场数据作为起始点)来执行此操作。如果您有权访问实时的股票交易流,则可能有兴趣从该流派生有用且及时的统计数据。例如,您可能希望执行滑动窗口分析,从而确定前 5 分钟内购买的最热门股票。或者,您可能希望在销售订单过大(即具有过多股份)时收到通知。可以扩展此系列代码以提供此类功能。

您可以在台式计算机或笔记本电脑上演练本教程中的步骤,然后在同一台计算机或支持已定义要求的任何平台(如 Amazon Elastic Create Create Cloud (Amazon EC2))上同时运行创建者和使用者代码。

显示的示例使用的是美国西部(俄勒冈)区域,但它们可使用任何Amazon支持 Kinesis Data Streams 的区域