Amazon Kinesis Data Streams
开发人员指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

教程:使用 Kinesis Data Analytics for Java Applications 分析实时股票数据

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

重要

在创建两个数据流和一个应用程序后,将象征性地向您的账户收取 Kinesis Data Streams 使用费,因为 Kinesis Data Analytics 没有获得 AWS 免费套餐的资格。在使用完此应用程序后,请删除 AWS 资源以停止产生费用。

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

显示的示例使用的是美国西部(俄勒冈)区域,但它对任何支持 Kinesis Data Analytics 的 AWS 区域都有效。

完成练习的先决条件

要完成本指南中的步骤,您必须满足以下条件:

  • Java 开发工具包 (JDK) 版本 8。设置 JAVA_HOME 环境变量,使其指向您的 JDK 安装位置。

  • 我们建议您使用开发环境(如 Eclipse Java NeonIntelliJ Idea)来开发和编译您的应用程序。

  • Git 客户端。 如果尚未安装 Git 客户端,请安装它。

  • Apache Maven 编译器插件。Maven 必须位于您的有效路径中。要测试您的 Apache Maven 安装,请输入以下内容:

    $ mvn -version

    注意

    Kinesis Data Analytics for Java Applications 仅支持使用 Apache Maven 构建的 Java 应用程序。

要开始,请转到步骤 1:设置 AWS 账户并创建管理员用户

本页内容: