在仔細考慮之後,我們決定在兩個步驟中停止 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.3:新增實時分析 (新應用程式碼)
您可以針對應用程式內串流撰寫自己的SQL查詢,但在接下來的步驟中,您可以使用其中一個提供範例程式碼的範本。
在 [應用程式中樞] 頁面上,選擇 [移至SQL編輯器]。
-
在 [您要開始執行 "ExampleApp「嗎? 」對話方塊中,選擇是,啟動應用程式。
控制台發送啟動應用程序的請求(請參閱StartApplication),然後出現SQL編輯器頁面。
-
控制台打開編SQL輯器頁面。複查頁面,包括按鈕(SQL從模板添加,保存並運行 SQL)和各種標簽。
-
在SQL編輯器中,選擇「SQL從範本新增」。
從可用範本清單中,選擇連續篩選。範例程式碼會從一個應用程式內串流讀取資料 (
WHERE
子句會篩選資料列),並將其插入另一個應用程式內串流,如下所示:-
此舉會建立應用程式內串流
DESTINATION_SQL_STREAM
。 -
此舉會建立幫浦
STREAM_PUMP
,並用它從SOURCE_SQL_STREAM_001
中選取列並插入DESTINATION_SQL_STREAM
。
-
選擇 [新增此SQL至編輯器]。
依照下列方式來測試應用程式碼:
請記住,您已經啟動應用程序(狀態為RUNNING)。儲存組態時,Amazon Kinesis Data Analytics 已持續從串流來源讀取資料,並將資料列加入應用程式內串流
SOURCE_SQL_STREAM_001
。-
在「SQL編輯器」中,選擇「儲存並執行」SQL。主控台首先發送更新請求,以保存應用程式碼。然後,程式碼會持續執行。
-
您可以在即時分析標籤中查看結果。
編SQL輯器具有下列索引標籤:
-
來源資料標籤會顯示映射至串流來源的應用程式內輸入串流。選擇應用程式內串流,您就可以看到傳入的資料。請注意應用程式內輸入串流中的其他資料欄,輸入組態並未指定這些欄位。其中包括下列時間戳記欄:
-
ROWTIME— 應用程式內串流中的每一列都有一個名為
ROWTIME
的特殊欄。此資料欄是 Amazon Kinesis Data Analytics 在第一個應用程式內串流 (對應至串流來源) 中插入資料列的時間戳記。 -
Approximate_Arrival_Time:每個 Kinesis Data Analytics 記錄都包含一個稱為
Approximate_Arrival_Time
的值。當串流來源成功接收並儲存記錄時,此值即為大約的到達時間戳記。Kinesis Data Analytics 從串流來源讀取記錄時,會將此資料欄擷取到應用程式內輸入串流中。
這些時間戳記值在以時間為基礎的窗口化查詢中非常有用。如需詳細資訊,請參閱窗口化查詢。
-
-
即時分析標籤會顯示應用程式碼建立的所有其他應用程式內串流。其中還包括錯誤串流。Kinesis Data Analytics 會將任何無法處理的資料列傳送至錯誤串流。如需詳細資訊,請參閱錯誤處理。
選擇
DESTINATION_SQL_STREAM
檢視應用程式碼插入的資料列。請注意應用程式碼未建立的其他資料欄。其中包括ROWTIME
時間戳記欄:Kinesis Data Analytics 只會從來源 (SOURCE_SQL_STREAM_001
) 複製這些值。 -
目的地標籤會顯示 Kinesis Data Analytics 寫入查詢結果的外部目標。您尚未為應用程式輸出設定任何外部目的地。
-
-