Amazon Kinesis Data Streams
开发人员指南
AWS 服务或AWS文档中描述的功能,可能因地区/位置而异。请点击 Amazon AWS 入门,可查看中国地区的具体差异

第一部分:流、创建器和使用者

本文档是说明如何在 Java 中针对 Amazon Kinesis Data Streams 进行开发的多部分系列教程的第一部分。如果您不确定哪一款流服务适合于您,请在什么是流数据?中查看比较信息。

本模块的场景是将股票交易注入流中并编写用来对流执行计算的简单应用程序。在第一部分中,您将了解如何将记录流发送到 Kinesis Data Streams 并实施几乎能实时使用和处理记录的应用程序。在本系列的后续部分中,场景将扩展以包含有关适用于大多数 Kinesis Data Streams 业务应用程序的股票交易分析模型的更多中级和高级设计和编程注意事项。

重要

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

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

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

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