對於新專案,我們建議您使用適用於 Apache Flink Studio 的全新受管理服務,取代適用於應用程式的 Kinesis Data Analytics。SQLManaged Service for Apache Flink Studio 易於使用且具備進階分析功能,讓您在幾分鐘內建置複雜的串流處理應用程式。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
步驟 2:建立 Amazon Kinesis Data Analytics 應用程式
在熱點範例的本節中,建立 Amazon Kinesis Data Analytics 應用程式,如下所示:
-
設定應用程式輸入,以使用您在步驟 1 中建立的 Kinesis 資料串流作為串流來源。
-
使用 AWS Management Console 中提供的應用程式碼。
建立應用程式
-
按照入門練習中的步驟 1、2 和 3 建立 Kinesis Data Analytics 應用程式 (請參閱 步驟 3.1:建立應用程式)。
在來源設定中,執行下列動作:
-
指定您在 步驟 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 程式碼並檢閱結果。