Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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

通过 Amazon CloudWatch Events 获取延迟数据通知

当您使用来自指定时间段的数据创建数据集时，有些消息数据可能无法及时到达以进行处理。为了允许延迟，您可通过应用 queryAction (SQL 查询)，在创建数据集时指定 QueryFilter 的 deltaTime 偏移量。Amazon IoT Analytics 仍会处理在增量时间内到达的数据，并且您的数据集内容存在时间延迟。延迟数据通知功能允许 Amazon IoT Analytics 在数据晚于增量时间到达时，通过 Amazon CloudWatch Events 发送通知。

您可以使用 Amazon IoT Analytics 控制台、API、Amazon Command Line Interface(Amazon CLI) 或 AmazonSDK 为数据集指定延迟数据规则。

在 Amazon IoT Analytics API 中，LateDataRuleConfiguration 对象表示数据集的延迟数据规则设置。此对象是与 CreateDataset 和 UpdateDataset API 操作关联的 Dataset 对象的一部分。

参数

当您使用 Amazon IoT Analytics 为数据集创建延迟数据规则时，必须指定以下信息：

配置延迟数据规则(控制台)

以下步骤介绍了如何使用 Amazon IoT Analytics 控制台配置数据集的延迟数据规则。

配置延迟数据规则(CLI)

在 Amazon IoT Analytics API 中，LateDataRuleConfiguration 对象表示数据集的延迟数据规则设置。此对象是与 CreateDataset 和 UpdateDataset 关联的 Dataset 对象的一部分。您可以使用 API、Amazon CLI、或 AmazonSDK 为数据集指定延迟数据规则。以下示例使用 Amazon CLI。

要使用指定的延迟数据规则创建数据集，请运行以下命令。以下命令假定该 dataset.json 文件位于当前目录中。

aws iotanalytics create-dataset --cli-input-json file://dataset.json

该dataset.json文件应包含以下内容：

{
    "datasetName": "demo_dataset",
    "actions": [
        {
            "actionName": "myDatasetAction",
            "queryAction": {
                "filters": [
                    {
                        "deltaTime": {
                            "offsetSeconds": -180,
                            "timeExpression": "from_unixtime(time)"
                        }
                    }
                ],
                "sqlQuery": "SELECT * FROM demo_datastore"
            }
        }
    ],
    "retentionPeriod": {
        "unlimited": false,
        "numberOfDays": 90
    },
    "lateDataRules": [
        {
            "ruleConfiguration": {
                "deltaTimeSessionWindowConfiguration": {
                    "timeoutInMinutes": timeout
                }
            },
            "ruleName": "demo_rule"
        }
    ]
}

订阅接收延迟数据通知

您可在 CloudWatch Events 中创建规则，定义如何处理从 Amazon IoT Analytics 发送的延迟数据通知。当 CloudWatch Events 收到通知时，它会调用您规则中定义的指定目标操作。

创建 CloudWatch Events 规则的先决条件

在为 Amazon IoT Analytics 创建 CloudWatch Events 规则之前，您应执行以下操作：

有关更多信息，请参阅 Amazon CloudWatch Events 用户指南中的什么是 CloudWatch Events？和 Amazon CloudWatch Events 入门。

延迟数据通知事件

延迟数据通知的事件使用以下格式。

{
	"version": "0",
	"id": "7f51dfa7-ffef-97a5-c625-abddbac5eadd",
	"detail-type": "IoT Analytics Dataset Lifecycle Notification",
	"source": "aws.iotanalytics",
	"account": "123456789012",
	"time": "2020-05-14T02:38:46Z",
	"region": "us-east-2",
	"resources": ["arn:aws:iotanalytics:us-east-2:123456789012:dataset/demo_dataset"],
	"detail": {
		"event-detail-version": "1.0",
		"dataset-name": "demo_dataset",
		"late-data-rule-name": "demo_rule",
		"version-ids": ["78244852-8737-4650-aa4d-3071a01338fa"],
		"message": null
	}
}

创建 CloudWatch Events 规则以接收延迟数据通知

以下步骤介绍了如何创建规则来向 Amazon SQS 队列发送 Amazon IoT Analytics 延迟数据通知。