使用SQL編輯器 - 亞馬遜 Kinesis SQL 應用程式資料分析開發人員指南

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

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

使用SQL編輯器

接下來,您可以找到有關SQL編輯器部分以及每個部分的工作方式的信息。在SQL編輯器中,您可以自行撰寫程式碼,或選擇「SQL從範本新增」。範SQL本提供範例程式SQL碼,可協助您撰寫常見的 Amazon Kinesis Data Analytics 應用程式。本指南中的範例應用程式使用其中一些範本。如需詳細資訊,請參閱Kinesis Data Analytics for SQL 範例

顯示即時分析標籤和應用程式內串流的SQL編輯器螢幕擷取畫面。

來源資料標籤

來源資料標籤可識別串流來源。它也會識別此來源映射的應用程式內輸入串流,並提供應用程式輸入組態。

顯示源數據選項卡的SQL編輯器屏幕截圖,並突出顯示流來源。

Amazon Kinesis Data Analytics 提供下列時間戳記欄,因此您不需要在輸入組態中提供明確的映射:

  • ROWTIME— 應用程式內串流中的每一列都有一個名為ROWTIME的特殊欄。此資料欄是 Kinesis 資料分析在第一個應用程式內串流中插入資料列時的時間戳記。

  • Approximate_Arrival_Time:串流來源上的記錄包含 Approximate_Arrival_Timestamp 欄。當串流來源成功接收並儲存相關記錄時,此即為大約的到達時間戳記。Kinesis Data Analytics 會將此資料欄擷取至應用程式內輸入串流作為 Approximate_Arrival_Time。Amazon Kinesis Data Analytics 僅會在對應至串流來源的應用程式內輸入串流中提供此資料欄。

這些時間戳記值在以時間為基礎的窗口化查詢中非常有用。如需詳細資訊,請參閱窗口化查詢

即時分析標籤

即時分析標籤會顯示應用程式碼建立的所有應用程式內串流。這組串流包括 Amazon Kinesis Data Analytics 提供給所有應用程式的錯誤串流 (error_stream)。

顯示即時分析標籤的SQL編輯器螢幕擷取畫面,並反白顯示應用程式內串流

目的地標籤

目的地標籤可讓您設定應用程式輸出,以保留應用程式內串流至外部目的地。您可以設定輸出,將任何應用程式內串流的資料保存至外部目的地。如需詳細資訊,請參閱設定應用程式輸出