重新處理頻道消息 - AWS IoT Analytics

AWS IoT Analytics 不再提供給新客戶。的現有客戶 AWS IoT Analytics 可以繼續正常使用服務。進一步了解

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

重新處理頻道消息

AWS IoT Analytics使您能夠重新處理通道數據。在下列情況中,這可能非常有用:

  • 您想要重新播放現有的擷取資料,而不是從頭開始。

  • 您對管道進行更新,並想將現有的資料 up-to-date 有變更的。

  • 您希望包括在更改客户託管存儲選項、渠道權限或數據存儲之前攝入的數據。

參數

當您通過管道重新處理通道消息時AWS IoT Analytics,則必須指定下列資訊:

StartPipelineReprocessing

通過管道開始重新處理頻道消息。

ChannelMessages

指定要重新處理的一組或多組通道消息。

如果您使用channelMessages物件,則不能指定startTimeendTime

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 存儲體中。

  1. 登入 AWS IoT Analytics 主控台

  2. 在導覽窗格中,選擇管道

  3. 選擇您的目標管道。

  4. 選擇重新處理消息動作

  5. 管道重新處理頁面上,選擇S3 物件為了重新處理消息

    所以此AWS IoT Analytics主控台還提供下列選項:

    • 所有可用範圍-重新處理頻道中的所有有效數據。

    • 過去 120 天-重新處理過去 120 天內到達的數據。

    • 過去 90 天-重新處理過去 90 天內到達的資料。

    • 過去 30 天-重新處理過去 30 天內到達的資料。

    • 定製範圍-重新處理在指定時間範圍內到達的數據。您可以選擇任何時間範圍。

  6. 輸入存儲頻道消息的 Amazon S3 obejct 的密鑰。

    若要查找項,請執行下列作業:

    1. 前往Amazon S3 主控台

    2. 選擇目標 Amazon S3 物件。

    3. 根據屬性,在物件概觀部分中,複製密鑰。

  7. 選擇開始重新處理

重新處理頻道消息 (API)

當您使用StartPipelineReprocessingAPI,請留意以下事項:

  • 所以此startTimeendTime參數指定原始資料的採集時間,但這只是粗略估計。您可以四捨五入到最接近的 1 小時。所以此startTime是包含的,但endTime是排他的。

  • 命令會以非同步方式啟動重新處理,並立即傳回。

  • 不保證重新處理訊息會依其原本收到的順序來處理。只會大致相同,但不完全一樣。

  • 你最多可以彌補 1000StartPipelineReprocessingAPI 請求每 24 小時通過管道重新處理相同頻道消息。

  • 重新處理您的原始資料會產生額外的成本。

如需詳細資訊,請參閲 。StartPipelineReprocessingAPI, 在AWS IoT AnalyticsAPI 參考

取消渠道重新處理活動

要取消管道重新處理活動,請使用CancelPipelineReprocessingAPI 或選擇取消重新處理活動頁面中的AWS IoT Analytics主控台。如果取消重新處理,則不會重新處理剩餘的數據。您必須啟動另一個重新處理請求。

使用DescribePipelineAPI 來檢查重新處理的狀態。請參reprocessingSummaries欄位。