Elasticsearch - AWS IoT Core
RequisitosParâmetrosExemplosConsulte também

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Elasticsearch

A ação Elasticsearch (elasticsearch) grava dados de mensagens MQTT em um domínio do Amazon OpenSearch Service. Em seguida, você pode usar ferramentas como OpenSearch painéis para consultar e visualizar dados no OpenSearch Service.

Atenção

A ação Elasticsearch só pode ser usada por ações de regras existentes. Para criar uma nova ação de regra ou atualizar uma existente, use a ação de regra OpenSearch. Para ter mais informações, consulte OpenSearch.

Requisitos

Esta ação de regra tem os seguintes requisitos:

  • Uma função do IAM que AWS IoT você pode assumir para realizar a es:ESHttpPut operação. Para ter mais informações, consulte Conceder a uma AWS IoT regra o acesso que ela exige.

    No AWS IoT console, você pode escolher ou criar uma função para permitir AWS IoT a execução dessa ação de regra.

  • Se você usar uma chave gerenciada pelo cliente AWS KMS key (chave KMS) para criptografar dados em repouso OpenSearch, o serviço deverá ter permissão para usar a chave KMS em nome do chamador. Para obter mais informações, consulte Criptografia de dados em repouso para o Amazon OpenSearch Service no Amazon OpenSearch Service Developer Guide.

Parâmetros

Ao criar uma AWS IoT regra com essa ação, você deve especificar as seguintes informações:

endpoint

O endpoint do seu domínio de serviço.

Suporta modelos de substituição: API e somente AWS CLI

index

O índice onde você deseja armazenar seus dados.

Compatível com modelos de substituição: Sim

type

O tipo de documento que você está armazenando.

Compatível com modelos de substituição: Sim

id

O identificador exclusivo de cada documento.

Compatível com modelos de substituição: Sim

roleARN

A função do IAM que permite acesso ao domínio do OpenSearch Serviço. Para ter mais informações, consulte Requisitos.

Compatível com modelos de substituição: Não

Exemplos

O exemplo JSON a seguir define uma ação Elasticsearch em uma AWS IoT regra e como você pode especificar os campos para a elasticsearch ação. Para obter mais informações, consulte 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"
                }
            }
        ]
    }
}

O exemplo de JSON a seguir define uma ação do Elasticsearch com modelos de substituição em uma regra. 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"
                }
            }
        ]
    }
}

Consulte também