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

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

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

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

重要

在创建流后,将象征性地向您的账户收取 Kinesis Data Streams 使用费,因为 Kinesis Data Streams 没有获得 Amazon Free Tier 的资格。在消费端应用程序启动后,也会象征性收取 Amazon DynamoDB 使用费用。消费端应用程序使用 DynamoDB 跟踪处理状态。在使用完此应用程序后,请删除 Amazon 资源以停止产生费用。有关更多信息,请参阅 清理资源

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

您可以在台式计算机或笔记本电脑上演练本教程中的步骤,然后在同一台计算机或支持已定义要求的任何平台上同时运行创建器和消费端代码。

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