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 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 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ê 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 acesso ao Firehose 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) Se o stream do Firehose deve ser entregue em lote usando o. 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 stream 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

A função do IAM que permite acesso ao stream do Firehose. 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 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