Firehose - 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á.

Firehose

A ação do Firehose (firehose) envia dados de uma mensagem MQTT para um stream do Amazon Data Firehose.

Requisitos

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

  • Uma função do IAM que AWS IoT você pode assumir para realizar a firehose:PutRecord operação. Para obter 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 o Firehose para enviar dados para um bucket do Amazon S3 e usa AWS KMS um cliente AWS KMS key gerenciado para criptografar dados em repouso no Amazon S3, o Firehose deve ter acesso ao seu bucket e permissão para usá-lo em nome do chamador. AWS KMS key Para obter mais informações, consulte Conceder ao Firehose acesso a um destino do Amazon S3 no Guia do desenvolvedor do Amazon Data Firehose.

Parâmetros

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

batchMode

(Opcional) Especifica se o stream do Firehose deve ser entregue como um lote usando PutRecordBatch. O valor padrão é false.

Quando batchMode é true e a instrução SQL da regra é avaliada para uma matriz, cada elemento da matriz forma um registro na solicitação PutRecordBatch. A matriz resultante não pode ter mais de 500 registros.

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

deliveryStreamName

O fluxo do Firehose no qual gravar os dados da mensagem.

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

separator

(Opcional) Um separador de caracteres usado para separar registros gravados no stream do Firehose. Se você omitir esse parâmetro, o fluxo não usará separador. Valores válidos: , (vírgula), \t (tab), \n (nova linha), \r\n (nova linha do Windows).

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

roleArn

O perfil do IAM que concede acesso ao stream do Firehose. Para obter 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 Firehose em AWS IoT uma regra.

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'", 
        "ruleDisabled": false, 
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "firehose": {
                    "deliveryStreamName": "my_firehose_stream",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_firehose"
                }
            }
        ] 
    }
}

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

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

Consulte também