Amazon IoT 规则操作
Amazon IoT 规则操作将指定规则触发后应执行的操作。您可以定义操作以将数据发送到 Amazon DynamoDB 数据库、将数据发送到 Amazon Kinesis Data Streams、调用 Amazon Lambda 函数,依此类推。Amazon IoT 支持在以下Amazon Web Services 区域中操作服务可用的操作。
规则操作 | 描述 | API 中的名称 |
---|---|---|
Apache Kafka | 将消息发送到 Apache Kafka 集群。 | kafka |
CloudWatch 警报 | 更改 Amazon CloudWatch 告警的状态。 | cloudwatchAlarm |
CloudWatch Logs | 将消息发送到 Amazon CloudWatch Logs。 | cloudwatchLogs |
CloudWatch 指标 | 将消息发送到 CloudWatch 指标。 | cloudwatchMetric |
DynamoDB | 将消息发送到 DynamoDB 表。 | dynamoDB |
DynamoDBv2 | 将消息数据发送到 DynamoDB 表中的多列。 | dynamoDBv2 |
Elasticsearch | 将消息发送到 Elasticsearch 端点。 | elasticsearch |
HTTP | 将消息发布到 HTTPS 端点。 | http |
IoT Analytics | 将消息发送到 Amazon IoT Analytics 通道。 | iotAnalytics |
IoT Events | 将消息发送到 Amazon IoT Events 输入。 | iotEvents |
IoT SiteWise | 将消息数据发送到 Amazon IoT SiteWise 资产属性。 | iotSiteWise |
Kinesis Data Firehose | 将消息发送到 Kinesis Data Firehose 传输流。 | firehose |
Kinesis Data Streams | 将消息发送到 Kinesis 数据流。 | kinesis |
Lambda | 使用消息数据作为输入调用 Lambda 函数。 | lambda |
OpenSearch | 将消息发送到 Amazon OpenSearch Service 终端节点。 | OpenSearch |
Republish | 在另一个 MQTT 主题上重新发布消息。 | republish |
S3 | 将消息存储在 Amazon Simple Storage Service (Amazon S3) 存储桶中。 | s3 |
Salesforce IoT | 将消息发送到 Salesforce IoT 输入流。 | salesforce |
SNS | 将消息发布为 Amazon Simple Notification Service (Amazon SNS) 推送通知。 | sns |
SQS | 将消息发送到 Amazon Simple Queue Service (Amazon SQS) 队列 | sqs |
Step Functions | 启动 Amazon Step Functions 状态机。 | stepFunctions |
Timestream | 将消息发送到 Amazon Timestream 数据库表。 | timestream |
-
您必须在与另一个服务资源相同的 Amazon Web Services 区域 中定义规则,以便规则操作可以与该资源进行交互。
-
Amazon IoT 规则引擎可多次尝试执行一个操作,以防出现间歇性错误。如果所有尝试都失败,将丢弃消息,并且 CloudWatch 日志中将记录此错误。您可以为在发生故障后调用的每条规则指定一个错误操作。有关更多信息,请参阅错误处理(错误操作)。
-
某些规则操作会触发与 Amazon Key Management Service (Amazon KMS) 集成的服务中的操作,以支持静态数据加密。如果您使用客户托管的 Amazon KMS key (KMS 密钥) 对数据进行静态加密,服务必须具有代表调用方使用 KMS 的权限。请参阅相应服务指南中的数据加密主题,以了解如何管理客户托管 KMS 密钥的权限。有关客户托管式 KMS 密钥的更多信息,请参阅 Amazon Key Management Service 开发人员指南中的 Amazon Key Management Service 概念。