重新处理通道消息 - Amazon IoT Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

重新处理通道消息

Amazon IoT Analytics使您能够重新处理通道数据。这在以下情况下很有用:

  • 您希望重放现有已提取的数据,而不是重新开始。

  • 您希望对管道进行更新,并希望引入带有更改的现有最新数据。

  • 您希望包括在对客户管理的存储选项、渠道权限或数据存储进行更改之前引入的数据。

Parameters

当您通过管道重新处理通道消息时Amazon 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 在Amazon IoT Analytics控制台。

在开始之前,请确保将要重新处理的渠道消息保存在客户管理的 Amazon S3 存储桶中。

  1. 登录到 Amazon IoT Analytics 控制台

  2. 在导航窗格中,选择管道

  3. 选择目标管道。

  4. 选择重新处理消息from操作

  5. 在存储库的管道后处理页面上,选择S3 对象对于 来说为重新处理消息

    这些区域有:Amazon IoT Analytics控制台还提供以下选项:

    • 所有可用范围-重新处理频道中的所有有效数据。

    • Past 120 天-重新处理过去 120 天内到达的数据。

    • Last 90 天-重新处理在最近 90 天内到达的数据。

    • Last 30 天-重新处理在最近 30 天内到达的数据。

    • 自定义范围-重新处理在指定时间范围内到达的数据。您可以选择任何时间范围。

  6. 输入用于存储您的频道消息的 Amazon S3 服务的密钥。

    要查找密钥,请执行以下操作:

    1. 转到Amazon S3 控制台

    2. 选择目标 Amazon S3 对象。

    3. UNDE属性,在对象概述部分中,复制密钥。

  7. 选择启动重新处理

重新处理通道消息 (API)

当您使用StartPipelineReprocessingAPI,请注意以下事项:

  • 这些区域有:startTimeendTime参数指定提取原始数据的时间,不过这些是粗略估计的时间。您可以舍入到最接近的小时。这些区域有:startTime是包容性的,但endTime是独家的。

  • 该命令异步启动重新处理并立即返回。

  • 不保证重新处理消息的顺序与接收时的顺序相同。这大致相同,但不完全一致。

  • 您最多可以弥补 1000StartPipelineReprocessingAPI 请求每 24 小时通过管道重新处理同一频道消息。

  • 重新处理原始数据会产生额外成本。

有关更多信息,请参阅 。StartPipelineReprocessingAPI,在Amazon IoT AnalyticsAPI 参考

取消渠道后处理活动

要取消管道重新处理活动,请使用CancelPipelineReprocessingAPI 或选择取消重新处理活动页面上的Amazon IoT Analytics控制台。如果取消重新处理,则不会重新处理剩余的数据。您必须启动另一个重新处理请求。

使用DescribePipelineAPI 检查重新处理的状态。请参阅reprocessingSummaries字段。