對於新專案,我們建議您使用適用於 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 範例。
來源資料標籤
來源資料標籤可識別串流來源。它也會識別此來源映射的應用程式內輸入串流,並提供應用程式輸入組態。
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
)。
目的地標籤
目的地標籤可讓您設定應用程式輸出,以保留應用程式內串流至外部目的地。您可以設定輸出,將任何應用程式內串流的資料保存至外部目的地。如需詳細資訊,請參閱設定應用程式輸出。