Kinesis Data Streams - 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á.

Kinesis Data Streams

A ação Kinesis Data Streams (kinesis) grava dados de uma mensagem MQTT no Amazon Kinesis Data Streams.

Requisitos

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

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

    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ê usa uma chave AWS KMS gerenciada pelo cliente AWS KMS key (chave KMS) para criptografar dados em repouso no Kinesis Data Streams, o serviço deve ter permissão para usá-la em nome do chamador. AWS KMS key Para obter mais informações, consulte Permissões de uso geradas pelo usuário AWS KMS keys no Guia do desenvolvedor do Amazon Kinesis Data Streams.

Parâmetros

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

stream

O fluxo de dados do Kinesis no qual os dados serão gravados.

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

partitionKey

A chave de partição usada para determinar em qual fragmento os dados são gravados. A chave de partição geralmente é composta de uma expressão (por exemplo, ${topic()} ou ${timestamp()}).

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

roleArn

O ARN da função do IAM que concede AWS IoT permissão para acessar o stream de dados do Kinesis. Para ter mais informações, consulte Requisitos.

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

Exemplos

O exemplo de JSON a seguir define uma ação do Kinesis Data Streams em uma regra. AWS IoT 

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'", 
        "ruleDisabled": false, 
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "kinesis": {
                    "streamName": "my_kinesis_stream", 
                    "partitionKey": "${topic()}",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis"
                }
            }
        ] 
    }
}

O exemplo de JSON a seguir define uma ação do Kinesis com modelos de substituição em uma regra. AWS IoT 

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'",
        "ruleDisabled": false,
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "kinesis": {
                    "streamName": "${topic()}",
                    "partitionKey": "${timestamp()}",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis"
                }
            }
        ]
    }
}

Consulte também