本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
Elasticsearch (elasticsearch) 操作将MQTT消息中的数据写入亚马逊 OpenSearch 服务域。然后，您可以使用 OpenSearch 仪表板等工具在 Ser OpenSearch vice 中查询和可视化数据。
警告
Elasticsearch 操作只能由现有规则操作使用。要创建新的规则操作或更新现有规则操作，请使用 OpenSearch 规则而不是操作。有关更多信息，请参阅 OpenSearch。
要求
此规则操作具有以下要求：
-
AWS IoT 可以IAM担任执行
es:ESHttpPut操作的角色。有关更多信息，请参阅 授予 AWS IoT 规则所需的访问权限。在 AWS IoT 控制台中，您可以选择或创建 AWS IoT 允许执行此规则操作的角色。
-
如果您使用客户托管 AWS KMS key （KMS密钥）对中的静态数据进行加密 OpenSearch，则服务必须有权代表呼叫者使用该KMS密钥。有关更多信息，请参阅《亚马逊服务开发者指南》中的亚马逊 OpenSearch 服务静态数据加密。 OpenSearch
参数
使用此操作创建 AWS IoT 规则时，必须指定以下信息：
示例
以下JSON示例定义了 AWS IoT 规则中的 Elasticsearch 操作以及如何为该elasticsearch操作指定字段。有关更多信息，请参阅 ElasticsearchAction。
{
"topicRulePayload": {
"sql": "SELECT *, timestamp() as timestamp FROM 'iot/test'",
"ruleDisabled": false,
"awsIotSqlVersion": "2016-03-23",
"actions": [
{
"elasticsearch": {
"endpoint": "https://my-endpoint",
"index": "my-index",
"type": "my-type",
"id": "${newuuid()}",
"roleArn": "arn:aws:iam::123456789012:role/aws_iot_es"
}
}
]
}
}以下JSON示例定义了一个在规则中使用替换模板的 Elasticsearch 操作。 AWS IoT
{ "topicRulePayload": { "sql": "SELECT * FROM 'some/topic'", "ruleDisabled": false, "awsIotSqlVersion": "2016-03-23", "actions": [ { "elasticsearch": { "endpoint": "https://my-endpoint", "index": "${topic()}", "type": "${type}", "id": "${newuuid()}", "roleArn": "arn:aws:iam::123456789012:role/aws_iot_es" } } ] } }
另请参阅
