发布于: Oct 5, 2017

现在,可对您的 Amazon Kinesis Analytics 应用程序进行配置,以在 SQL 代码处理数据之前转换数据。这一新功能允许您使用 AWS Lambda 转换格式、丰富数据、筛选数据等。在函数对数据进行转换后,Kinesis Analytics 会将数据发送给您的应用程序的 SQL 代码,以进行实时分析。

要开始使用,只需从 AWS 管理控制台的 Kinesis Analytics 应用程序源代码页中选择 AWS Lambda 函数即可。您的 Kinesis Analytics 应用程序会自动使用该 Lambda 函数来处理您的原始数据记录,并将转换后的数据发送至您的 SQL 代码,以做进一步处理。

Kinesis Analytics 会提供用于常见用例的 Lambda 蓝图,例如将 GZIP 和 Kinesis 创建器库格式转换为 JSON。您可以不做任何更改地使用这些蓝图,也可以编写自己的自定义函数。有关此功能的示例,请参阅博客文章用 AWS Lambda 对 Kinesis Analytics 中的数据进行预处理。要了解有关此功能的更多信息,请参阅《Kinesis Analytics 开发人员指南》中的使用 Lambda 预处理功能

Kinesis Analytics 是处理实时流数据的一种最简单的方法,采用的是标准 SQL 且无需了解新的编程语言或处理框架。通过 Kinesis Analytics,您能够使用 SQL 查询流数据或构建整个流式处理应用程序,以便您获取可执行的见解并及时响应您的业务和客户需求。Kinesis Analytics 目前在美国东部 (弗吉尼亚北部)、美国西部 (俄勒冈) 和欧洲 (爱尔兰) 区域可用。