适用于 Apache Flink 的亚马逊托管服务 - Amazon Timestream
示例应用程序教程视频
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击此处了解更多信息。

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

适用于 Apache Flink 的亚马逊托管服务

您可以使用 Apache Flink 将时间序列数据从适用于 Apache Flink 的亚马逊托管服务、Amazon MSK、Apache Kafka 及其他流技术直接传输至适用于 LiveAnalytics 的 Amazon Timestream。我们已为 Timestream 创建 Apache Flink 示例数据连接器。我们还已创建示例应用程序，用于将数据发送到 Amazon Kinesis，以便数据可以从 Kinesis 流到适用于 Apache Flink 的托管服务，最后流到 Amazon Timestream。所有这些构件均可在 GitHub 中获取。本视频教程介绍设置。

注意

Java 11 是使用适用于 Apache Flink 的托管服务应用程序的推荐版本。如果有多个 Java 版本，请确保将 Java 11 导出至 JAVA_HOME 环境变量。

示例应用程序

要开始使用，请按照以下步骤进行：

  1. 按照 创建数据库 中所述说明，在 Timestream 中使用名称 kdaflink 创建数据库。

  2. 按照 创建表 中所述说明，在 Timestream 中使用名称 kinesisdata1 创建表。

  3. 按照创建流中所述说明，使用名称 TimestreamTestStream 创建 Amazon Kinesis Data Streams。

  4. 按照 GitHub 的说明，克隆适用于 Timestream 的 Apache Flink 数据连接器的 GitHub 存储库。

  5. 要编译、运行和使用示例应用程序，请按照 Apache Flink 示例数据连接器自述文件中的说明操作。

  6. 按照编译应用程序代码的说明，编译适用于 Apache Flink 的托管服务应用程序。

  7. 按照上传 Apache Flink 流代码的说明，上传适用于 Apache Flink 的托管服务应用程序二进制文件。

    1. 点击“创建应用程序”后，点击该应用程序的 IAM 角色链接。

    2. 随附 AmazonKinesisReadOnlyAccess 和 AmazonTimestreamFullAccess 的 IAM 策略。

      注意

      上述 IAM 策略不局限于特定资源，且不适用于生产环境。对于生产系统，建议使用限制特定资源访问权限的策略。

  8. 按照 GitHub 的说明，克隆用于将数据写入 Kinesis 的示例应用程序的 GitHub 存储库。

  9. 按照自述文件中的说明，运行用于将数据写入 Kinesis 的示例应用程序。

  10. 按照 创建表 的说明，在 Timestream 中运行一个或多个查询，确保数据从 Kinesis 发送到适用于 Apache Flink 的托管服务，再发送到 Timestream。

教程视频

本视频介绍如何将 Timestream 与适用于 Apache Flink 的托管服务结合使用。