在仔細考慮之後,我們決定在兩個步驟中停止 Amazon Kinesis Data Analytics for SQL 應用程式:
1. 從 2025 年 10 月 15 日起,您將無法為SQL應用程式建立新的 Kinesis Data Analytics。
2. 我們將從 2026 年 1 月 27 日起刪除您的應用程式。您將無法啟動或操作SQL應用程式的 Amazon Kinesis Data Analytics。從那時SQL起,Amazon Kinesis Data Analytics 將不再提供 的支援。如需詳細資訊,請參閱Amazon Kinesis Data Analytics for SQL 應用程式終止。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
步驟 3.4:(選用) 更新應用程式碼
在此步驟中,探索如何更新應用程式碼。
如要更新應用程式碼
-
建立另一個應用程式內串流,如下所示:
-
建立另一個名為
DESTINATION_SQL_STREAM_2
的應用程式內串流。 -
建立幫浦,然後透過從
DESTINATION_SQL_STREAM
中選取列,用幫浦在新建立的串流中插入列。
在SQL編輯器中,將下列程式碼附加至現有的應用程式程式碼:
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS INSERT INTO "DESTINATION_SQL_STREAM_2" SELECT STREAM ticker_symbol, change, price FROM "DESTINATION_SQL_STREAM";
儲存並執行程式碼。其他應用程式內串流會顯示在即時分析標籤上。
-
-
建立兩個應用程式內串流。根據股票代號篩選
SOURCE_SQL_STREAM_001
中的列,然後將它們插入到這些單獨的串流中。將下列SQL陳述式附加至您的應用程式程式碼:
CREATE OR REPLACE STREAM "AMZN_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "AMZN_PUMP" AS INSERT INTO "AMZN_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%AMZN%'; CREATE OR REPLACE STREAM "TGT_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "TGT_PUMP" AS INSERT INTO "TGT_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%TGT%';
儲存並執行程式碼。請注意即時分析標籤上的其他應用程式內串流。
現在您即獲得第一個可運作的 Amazon Kinesis Data Analytics 應用程式。在本練習中,您進行了以下動作:
-
建立了您的第一個 Kinesis Data Analytics 應用程式。
-
設定分應用程式輸入,將示範串流識別為串流來源,並將其映射至建立的應用程式內串流 (
SOURCE_SQL_STREAM_001
)。Kinesis Data Analytics 會持續讀取示範串流,並將記錄插入應用程式內串流。 -
您的應用程式碼查詢了
SOURCE_SQL_STREAM_001
,並將輸出寫入另一個名為DESTINATION_SQL_STREAM
的應用程式內串流。
現在,您可以選擇性地設定應用程式輸出,以將其寫入外部目的地。換句話說,您可以設定應用程式輸出,將 DESTINATION_SQL_STREAM
的紀錄寫入外部目的地。針對本練習,此為選用步驟。若要瞭解如何設定目的地,請至下一個步驟。
後續步驟
步驟 4 (選擇性) 使用主控台編輯結構描述和SQL程式碼.