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

创建 AWS IoT 规则

您可以创建 AWS IoT 规则来路由来自互联事物的数据，以便与其他 AWS 服务进行交互。 AWS IoT 规则由以下部分组成：

在创建 AWS IoT 规则之前，必须使用允许访问所需 AWS 资源的策略创建一个IAM角色。 AWS IoT 在实施规则时扮演这个角色。有关更多信息，请参阅授予 AWS IoT 规则所需的访问权限和传递角色权限。

当您创建规则时，请注意在主题上发布的数据量。如果您创建的规则包含通配符主题模式，则这些规则可能会与您的大部分消息匹配。在这种情况下，您可能需要增加目标操作使用的 AWS 资源的容量。另外，如果您创建包含通配符主题模式的重新发布规则，最终可能获得一个造成无限循环的循环规则。

创建规则（控制台）

成功创建规则后，您将在规则页面上看到列出该规则。您可以选择一个规则来打开详细信息页面，在该页面中可以查看规则、编辑规则、停用规则以及删除规则。

创建规则 (CLI)

创建规则 (AWS CLI)

使用 create-topic-rule 命令创建规则：

aws iot create-topic-rule --rule-name myrule --topic-rule-payload file://myrule.json

下面是一个负载文件示例，其中包含将发送至 iot/test 主题的所有消息插入指定 DynamoDB 表的规则。该SQL语句筛选消息，角色ARN授予写入 DynamoDB 表的 AWS IoT 权限。

{
	"sql": "SELECT * FROM 'iot/test'",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"dynamoDB": {
				"tableName": "my-dynamodb-table",
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role",
				"hashKeyField": "topic",
				"hashKeyValue": "${topic(2)}",
				"rangeKeyField": "timestamp",
				"rangeKeyValue": "${timestamp()}"
			}
		}
	]
}

下面是一个负载文件示例，其中包含将发送至 iot/test 主题的所有消息插入指定 S3 存储桶的规则。该SQL语句筛选消息，角色ARN授予写入 Amazon S3 存储桶的 AWS IoT 权限。

{
	"awsIotSqlVersion": "2016-03-23",
	"sql": "SELECT * FROM 'iot/test'",
	"ruleDisabled": false,
	"actions": [
		{
			"s3": {
				"roleArn": "arn:aws:iam::123456789012:role/aws_iot_s3",
				"bucketName": "amzn-s3-demo-bucket",
				"key": "myS3Key"
			}
		}
	]
} 

以下是载荷文件示例，其中包含将数据推送到 Amazon S OpenSearch ervice 的规则：

{
	"sql": "SELECT *, timestamp() as timestamp FROM 'iot/test'",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"OpenSearch": {
				"roleArn": "arn:aws:iam::123456789012:role/aws_iot_es",
				"endpoint": "https://my-endpoint",
				"index": "my-index",
				"type": "my-type",
				"id": "${newuuid()}"
			}
		}
	]
}

下面的负载文件示例包含调用 Lambda 函数的规则：

{
	"sql": "expression",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"lambda": {
				"functionArn": "arn:aws:lambda:us-west-2:123456789012:function:my-lambda-function"
			}
		}
	]
}

以下是载荷文件示例，其中包含发布到 Amazon SNS 主题的规则：

{
	"sql": "expression",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"sns": {
				"targetArn": "arn:aws:sns:us-west-2:123456789012:my-sns-topic",
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role"
			}
		}
	]
}

以下是载荷文件示例，其中包含针对不同MQTT主题重新发布的规则：

{
	"sql": "expression",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"republish": {
				"topic": "my-mqtt-topic",
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role"
			}
		}
	]
}

下面的有效载荷文件示例包含将数据推送至 Amazon Data Firehose 流的规则：

{
	"sql": "SELECT * FROM 'my-topic'",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"firehose": {
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role",
				"deliveryStreamName": "my-stream-name"
			}
		}
	]
}

以下是负载文件示例，其中包含一条规则，如果有效MQTT载荷中的数据被归类为 1，则使用 SageMaker Amazon AI machinelearning_predict 函数重新发布到主题。

{
	"sql": "SELECT * FROM 'iot/test' where machinelearning_predict('my-model', 'arn:aws:iam::123456789012:role/my-iot-aml-role', *).predictedLabel=1",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"republish": {
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role",
				"topic": "my-mqtt-topic"
			}
		}
	]
}

下面是一个示例负载文件，该文件包含将消息发布到 Salesforce IoT Cloud 输入流的规则。

{
	"sql": "expression",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"salesforce": {
				"token": "ABCDEFGHI123456789abcdefghi123456789",
				"url": "https://ingestion-cluster-id.my-env.sfdcnow.com/streams/stream-id/connection-id/my-event"
			}
		}
	]
}

下面是一个负载文件示例，其中包含一个可以开始执行 Step Functions 状态机的规则。

{
	"sql": "expression",
	"ruleDisabled": false,
	"awsIotSqlVersion": "2016-03-23",
	"actions": [
		{
			"stepFunctions": {
				"stateMachineName": "myCoolStateMachine",
				"executionNamePrefix": "coolRunning",
				"roleArn": "arn:aws:iam::123456789012:role/my-iot-role"
			}
		}
	]
}