本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
重新处理通道消息
Amazon IoT Analytics使您能够重新处理频道数据。这在以下情况下会很有用:
-
您希望重放现有已提取的数据,而不是重新开始。
-
您想要更新管道并希望带来现有数据 up-to-date 随着更改。
-
您希望包括在更改客户托管存储选项、渠道权限或数据存储之前提取的数据。
参数
当你通过渠道重新处理频道消息时Amazon 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 对象中的频道数据Amazon IoT Analytics控制台。
在开始之前,请确保要重新处理的渠道消息保存在客户托管的 Amazon S3 存储桶中。
-
在导航窗格中,选择管道.
-
选择目标管道。
-
选择重新处理消息从操作.
-
在存储库的管道重新处理页面,选择S3 对象为了重新处理消息.
这些区域有:Amazon IoT Analytics控制台还提供以下选项:
-
所有可用的范围-重新处理频道中的所有有效数据。
-
Last 120 Days-重新处理过去 120 天内到达的数据。
-
最近 90 天-重新处理最近 90 天内到达的数据。
-
最近 30 天-重新处理最近 30 天内到达的数据。
-
自定义范围-重新处理在指定时间范围内到达的数据。你可以选择任何时间范围。
-
-
输入存储频道消息的 Amazon S3 对象的密钥。
要查找密钥,请执行以下操作:
-
选择目标 Amazon S3 对象。
-
UNDER属性,在对象概述部分中,复制密钥。
-
选择开始再处理.
重新处理频道消息 (API)
当您使用StartPipelineReprocessing
API,请注意以下几点:
-
这些区域有:
startTime
和endTime
参数指定提取原始数据的时间,不过这些是粗略估计的时间。您可以舍入到最接近的小时。这些区域有:startTime
是包容性的,但endTime
是独家的。 -
该命令异步启动重新处理并立即返回。
-
不保证重新处理消息的顺序与接收时的顺序相同。这大致相同,但不完全一致。
-
你最多可以弥补 1000
StartPipelineReprocessing
API 请求每 24 小时通过管道重新处理相同的频道消息。 -
重新处理原始数据会产生额外的成本。
有关更多信息,请参阅 。StartPipelineReprocessingAPI,在Amazon IoT AnalyticsAPI 参考.
取消渠道再处理活动
要取消管道再处理活动,请使用CancelPipelineReprocessingAPI 或者选择取消重新处理在活动中的页面Amazon IoT Analytics控制台。如果取消再处理,剩余的数据将不会被重新处理。你必须开始另一个再处理请求。
使用DescribePipeline查看重新处理的状态的 API。请参阅reprocessingSummaries
响应中的字段。