对于新项目,建议您使用新的适用于 Apache Flink Studio 的托管服务,而不是使用适用于 SQL 应用程序的 Kinesis Data Analytics。Managed Service for Apache Flink Studio 不仅操作简单,还具有高级分析功能,使您能够在几分钟内构建复杂的流处理应用程序。
本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
步骤 2:创建 Kinesis Data Analytics 应用程序
在该热点示例的此部分中,您创建一个 Kinesis Data Analytics 应用程序,如下所示:
-
配置应用程序输入以将您在步骤 1 中创建的 Kinesis 数据流用作流式传输源。
-
在 Amazon Web Services Management Console中使用提供的应用程序代码。
创建应用程序
-
按照入门练习中的步骤 1、2 和 3(请参阅 步骤 3.1:创建应用程序)创建 Kinesis Data Analytics 应用程序。
在源配置中,执行以下操作:
-
指定您在步骤 1:创建输入和输出流中创建的流式传输源。
-
在控制台推断架构后编辑架构。确保
x
和y
DOUBLE
列类型设置为 ,并确保IS_HOT
列类型设置为VARCHAR
。
-
-
使用以下应用程序代码 (您可以将此代码粘贴到 SQL 编辑器中):
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( "x" DOUBLE, "y" DOUBLE, "is_hot" VARCHAR(4), HOTSPOTS_RESULT VARCHAR(10000) ); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" FROM TABLE ( HOTSPOTS( CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 1000, 0.2, 17) );
-
运行 SQL 代码并审查结果。