AWS IoT Analytics 不再提供給新客戶。的現有客戶 AWS IoT Analytics 可以繼續正常使用服務。進一步了解
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
重新處理頻道消息
AWS IoT Analytics使您能夠重新處理通道數據。在下列情況中,這可能非常有用:
-
您想要重新播放現有的擷取資料,而不是從頭開始。
-
您對管道進行更新,並想將現有的資料 up-to-date 有變更的。
-
您希望包括在更改客户託管存儲選項、渠道權限或數據存儲之前攝入的數據。
參數
當您通過管道重新處理通道消息時AWS IoT Analytics,則必須指定下列資訊:
StartPipelineReprocessing
-
通過管道開始重新處理頻道消息。
ChannelMessages
-
指定要重新處理的一組或多組通道消息。
如果您使用
channelMessages
物件,則不能指定startTime
和endTime
。s3Paths
-
指定標識保存頻道消息的 Amazon Simple Storage Service (Amazon S3) 物件的一個或多個密鑰。您必須使用密鑰的完整路徑。
路徑範例:
00:00:00/1582940490000_1582940520000_123456789012_mychannel_0_2118.0.json.gz
類型:字串陣列
陣列成員約束:1-100 個項目。
長度限制:1-1024 個字符。
endTime
-
重新處理的頻道資料結束時間 (不包括)。
如果您指定的
endTime
參數,則不得使用channelMessages
物件。類型:時間戳記
startTime
-
經重新處理的原始訊息資料開始時間 (包含)。
如果您指定的
startTime
參數,則不得使用channelMessages
物件。類型:時間戳記
pipelineName
-
要開始重新處理的管道名稱。
類型:字串
長度限制:1-128 個字元。
重新處理頻道消息 (主控台)
本教程介紹如何重新處理 Amazon S3 在AWS IoT Analytics主控台。
開始之前,請確定您想要重新處理的頻道消息已保存在客户管理的 Amazon S3 存儲體中。
-
在導覽窗格中,選擇管道。
-
選擇您的目標管道。
-
選擇重新處理消息從動作。
-
在管道重新處理頁面上,選擇S3 物件為了重新處理消息。
所以此AWS IoT Analytics主控台還提供下列選項:
-
所有可用範圍-重新處理頻道中的所有有效數據。
-
過去 120 天-重新處理過去 120 天內到達的數據。
-
過去 90 天-重新處理過去 90 天內到達的資料。
-
過去 30 天-重新處理過去 30 天內到達的資料。
-
定製範圍-重新處理在指定時間範圍內到達的數據。您可以選擇任何時間範圍。
-
-
輸入存儲頻道消息的 Amazon S3 obejct 的密鑰。
若要查找項,請執行下列作業:
-
選擇目標 Amazon S3 物件。
-
根據屬性,在物件概觀部分中,複製密鑰。
-
選擇開始重新處理。
重新處理頻道消息 (API)
當您使用StartPipelineReprocessing
API,請留意以下事項:
-
所以此
startTime
和endTime
參數指定原始資料的採集時間,但這只是粗略估計。您可以四捨五入到最接近的 1 小時。所以此startTime
是包含的,但endTime
是排他的。 -
命令會以非同步方式啟動重新處理,並立即傳回。
-
不保證重新處理訊息會依其原本收到的順序來處理。只會大致相同,但不完全一樣。
-
你最多可以彌補 1000
StartPipelineReprocessing
API 請求每 24 小時通過管道重新處理相同頻道消息。 -
重新處理您的原始資料會產生額外的成本。
如需詳細資訊,請參閲 。StartPipelineReprocessingAPI, 在AWS IoT AnalyticsAPI 參考。
取消渠道重新處理活動
要取消管道重新處理活動,請使用CancelPipelineReprocessingAPI 或選擇取消重新處理在活動頁面中的AWS IoT Analytics主控台。如果取消重新處理,則不會重新處理剩餘的數據。您必須啟動另一個重新處理請求。
使用DescribePipelineAPI 來檢查重新處理的狀態。請參reprocessingSummaries
欄位。