步驟 3.3:新增實時分析 (新應用程式碼) - Amazon Kinesis Data Analytics for SQL Applications 開發人員指南

在仔細考慮之後,我們決定在兩個步驟中停止 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查詢,但在接下來的步驟中,您可以使用其中一個提供範例程式碼的範本。

  1. 在 [應用程式中樞] 頁面上,選擇 [移至SQL編輯器]。

    帶有轉到SQL編輯器按鈕的示例應用程序頁面的屏幕截圖。
  2. 在 [您要開始執行 "ExampleApp「嗎? 」對話方塊中,選擇是,啟動應用程式

    控制台發送啟動應用程序的請求(請參閱StartApplication),然後出現SQL編輯器頁面。

  3. 控制台打開編SQL輯器頁面。複查頁面,包括按鈕(SQL從模板添加保存並運行 SQL)和各種標簽。

  4. 在SQL編輯器中,選擇「SQL從範本新增」。

  5. 從可用範本清單中,選擇連續篩選。範例程式碼會從一個應用程式內串流讀取資料 (WHERE 子句會篩選資料列),並將其插入另一個應用程式內串流,如下所示:

    • 此舉會建立應用程式內串流 DESTINATION_SQL_STREAM

    • 此舉會建立幫浦 STREAM_PUMP,並用它從 SOURCE_SQL_STREAM_001 中選取列並插入 DESTINATION_SQL_STREAM

  6. 選擇 [新增此SQL至編輯器]。

  7. 依照下列方式來測試應用程式碼:

    請記住,您已經啟動應用程序(狀態為RUNNING)。儲存組態時,Amazon Kinesis Data Analytics 已持續從串流來源讀取資料,並將資料列加入應用程式內串流 SOURCE_SQL_STREAM_001

    1. 在「SQL編輯器」中,選擇「儲存並執行」SQL。主控台首先發送更新請求,以保存應用程式碼。然後,程式碼會持續執行。

    2. 您可以在即時分析標籤中查看結果。

      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 寫入查詢結果的外部目標。您尚未為應用程式輸出設定任何外部目的地。

後續步驟

步驟 3.4:(選用) 更新應用程式碼