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 kinesis Streams () grava dados MQTT de uma mensagem no Amazon Kinesis Data Streams.

Requisitos

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

  • Uma IAM função que AWS IoT pode ser assumida para realizar a kinesis:PutRecord operação. Para obter 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ê usa uma AWS KMS key (KMSchave) AWS KMS gerenciada pelo cliente para criptografar dados em repouso no Kinesis Data Streams, o serviço deve ter permissão para usar AWS KMS key o em nome do chamador. 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

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

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

Exemplos

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

{
    "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 JSON exemplo 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