发布于: 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 Producer Library 格式转换为 JSON。您可以不做任何更改地使用这些蓝图，也可以编写自己的自定义函数。有关这一功能的示例，请参阅博客文章用 AWS Lambda 对 Kinesis Analytics 中的数据进行预处理。要了解有关这一功能的更多信息，请参阅《Kinesis Analytics 开发人员指南》中的使用 Lambda 预处理功能。
Kinesis Analytics 是处理实时流数据的一种最简单的方法，它使用标准 SQL，并且无需了解新的编程语言或处理框架。通过 Kinesis Analytics，您能够使用 SQL 查询流数据或构建整个流式传输应用程序，从而获得能够作为行动依据的见解并及时响应业务需求和客户需求。Kinesis Analytics 目前在美国东部（弗吉尼亚北部）、美国西部（俄勒冈）和欧洲（爱尔兰）区域可用。