步驟 3:建立 Amazon Kinesis Data Analytics 入門應用程式。 - 亞馬遜 Kinesis SQL 應用程式資料分析開發人員指南

對於新專案,我們建議您使用適用於 Apache Flink Studio 的全新受管理服務,取代適用於應用程式的 Kinesis Data Analytics。SQLManaged Service for Apache Flink Studio 易於使用且具備進階分析功能,讓您在幾分鐘內建置複雜的串流處理應用程式。

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

步驟 3:建立 Amazon Kinesis Data Analytics 入門應用程式。

按照本節中的步驟操作,您可以使用主控台建立第一個 Kinesis Data Analytics 應用程式。

注意

我們建議您在嘗試入門練習之前先檢閱 Amazon Kinesis Data Analytics for SQL 應用程式:運作方式

在這個入門練習中,您可以使用主控台來處理示範串流或包含應用程式碼的範本。

  • 如果您選擇使用示範串流,主控台會在您的帳戶中建立名為 kinesis-analytics-demo-stream 的 Kinesis 資料串流。

    Kinesis Data Analytics 應用程式需要串流來源。針對此來源,本指南中的數個 SQL 範例會使用示範串流 kinesis-analytics-demo-stream。主控台還運行一個指令碼,將樣本資料(模擬股票交易記錄)持續添加到此串流中,如下所示。

    顯示股票代號,產業和價格的格式化串流範例表。

    在本練習中,您可以把 kinesis-analytics-demo-stream 當作應用程式的串流來源。

    注意

    示範串流會保留在您的帳戶中。您可以用其測試本指南中的其他範例。不過,當您離開主控台時,主控台使用的指令碼會停止填入資料。當需要時,主控台提供了開始再次填充串流的選項。

  • 如果您選擇將範本與應用程式碼範例搭配使用,可使用主控台提供的範本程式碼,在示範串流上執行簡單的分析。

您可以使用這些功能來快速設定第一個應用程式,如下所示:

  1. 建立應用程式:您只需要提供名稱即可。主控台會建立應用程式,且服務會將應用程式狀態設定為 READY

     

  2. 設定輸入:首先添加一個串流來源,即示範串流。您必須先在主控台中建立示範串流,才能使用它。然後,主控台會在示範串流上擷取隨機記錄樣本,並針對所建立的應用程式內輸入串流推斷結構描述。主控台會將應用程式內串流命名為 SOURCE_SQL_STREAM_001

    主控台會使用探索 API 來推斷結構描述。如有必要,您可以編輯推斷的結構描述。如需詳細資訊,請參閱 DiscoverInputSchema。Kinesis Data Analytics 會使用此結構描述來建立應用程式內串流。

     

    當應用程式啟動時,Kinesis Data Analytics 會代表您持續讀取示範串流,並將資料列插入 SOURCE_SQL_STREAM_001 應用程式內串流。

     

  3. 指定應用程式碼:使用提供下列程式碼的範本 (稱為持續篩選條件):

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE); -- Create pump to insert into output. CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, sector, CHANGE, price FROM "SOURCE_SQL_STREAM_001" WHERE sector SIMILAR TO '%TECH%';

    應用程式碼會查詢應用程式內串流 SOURCE_SQL_STREAM_001。然後,程式碼會使用幫浦將產生的資料列插入另一個應用程式內串流 DESTINATION_SQL_STREAM 中。如需此編碼模式的更多資訊,請參閱 應用程式碼

    如需 Kinesis Data Analytics 支援之 SQL 語言元素的相關資訊,請參閱 Amazon Kinesis Data Analytics SQL 參考資料

     

  4. 設定輸出:在本練習中,不會設定任何輸出。也就是說,您不會將應用程式建立的內部串流資料保存到任何外部目的地。而是在主控台中驗證查詢結果。本指南中的其他範例說明如何設定輸出。如需範例,請參閱 範例:建立簡單提醒

重要

此練習使用美國東部 (維吉尼亞北部) 區域 (us-east-1) 來設定應用程式。您可以使用任何支持的 AWS 區域。

後續步驟

步驟 3.1:建立應用程式