要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击[此处](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html)了解更多信息。
本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
# 适用于 Apache Flink 的亚马逊托管服务
您可以使用 Apache Flink 将时间序列数据从适用于 Apache Flink 的亚马逊托管服务、Amazon MSK、Apache Kafka 及其他流技术直接传输至适用于 LiveAnalytics 的 Amazon Timestream。我们已为 Timestream 创建 Apache Flink 示例数据连接器。我们还已创建示例应用程序，用于将数据发送到 Amazon Kinesis，以便数据可以从 Kinesis 流到适用于 Apache Flink 的托管服务，最后流到 Amazon Timestream。所有这些构件均可在 GitHub 中获取。本[视频教程](https://youtu.be/64DSlBvN5lg)介绍设置。
**注意**
Java 11 是使用适用于 Apache Flink 的托管服务应用程序的推荐版本。如果有多个 Java 版本，请确保将 Java 11 导出至 JAVA\$1HOME 环境变量。
**Topics**
+ [示例应用程序](#ApacheFlink.sample-app)
+ [教程视频](#ApacheFlink.video-tutorial)
## 示例应用程序
要开始使用，请按照以下步骤进行：
1. 按照 [创建数据库](console_timestream.md#console_timestream.db.using-console) 中所述说明，在 Timestream 中使用名称 `kdaflink` 创建数据库。
1. 按照 [创建表](console_timestream.md#console_timestream.table.using-console) 中所述说明，在 Timestream 中使用名称 `kinesisdata1` 创建表。
1. 按照[创建流](https://docs.aws.amazon.com/streams/latest/dev/amazon-kinesis-streams.html#how-do-i-create-a-stream)中所述说明，使用名称 `TimestreamTestStream` 创建 Amazon Kinesis Data Streams。
1. 按照 [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository) 的说明，克隆[适用于 Timestream 的 Apache Flink 数据连接器](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector)的 GitHub 存储库。
1. 要编译、运行和使用示例应用程序，请按照 [Apache Flink 示例数据连接器自述文件](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector/README.md)中的说明操作。
1. 按照[编译应用程序代码](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-5.5)的说明，编译适用于 Apache Flink 的托管服务应用程序。
1. 按照[上传 Apache Flink 流代码](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-6)的说明，上传适用于 Apache Flink 的托管服务应用程序二进制文件。
1. 点击“创建应用程序”后，点击该应用程序的 IAM 角色链接。
1. 随附 **AmazonKinesisReadOnlyAccess** 和 **AmazonTimestreamFullAccess** 的 IAM 策略。
**注意**
上述 IAM 策略不局限于特定资源，且不适用于生产环境。对于生产系统，建议使用限制特定资源访问权限的策略。
1. 按照 [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository) 的说明，克隆用于[将数据写入 Kinesis 的示例应用程序](https://github.com/awslabs/amazon-timestream-tools/tree/mainline/tools/python/kinesis_ingestor)的 GitHub 存储库。
1. 按照[自述文件](https://github.com/awslabs/amazon-timestream-tools/blob/mainline/tools/python/kinesis_ingestor/README.md)中的说明，运行用于将数据写入 Kinesis 的示例应用程序。
1. 按照 [创建表](console_timestream.md#console_timestream.table.using-console) 的说明，在 Timestream 中运行一个或多个查询，确保数据从 Kinesis 发送到适用于 Apache Flink 的托管服务，再发送到 Timestream。
## 教程视频
本[视频](https://youtu.be/64DSlBvN5lg)介绍如何将 Timestream 与适用于 Apache Flink 的托管服务结合使用。