View a markdown version of this page

Firehose - AWS IoT Core
RequisitiParametersEsempiConsulta anche

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Firehose

L'azione Firehose (firehose) invia i dati da un messaggio MQTT a uno stream Amazon Data Firehose.

Requisiti

Questa operazione della regola presenta i seguenti requisiti:

Parameters

Quando crei una AWS IoT regola con questa azione, devi specificare le seguenti informazioni:

batchMode

(Facoltativo) Se fornire lo stream Firehose come batch utilizzando PutRecordBatch. Il valore predefinito è false.

Quando batchMode è true e l'istruzione SQL della regola restituisce un array, ogni elemento dell'array forma un record nella richiesta PutRecordBatch. L'array risultante non può avere più di 500 record.

Supporta modelli di sostituzione: no

deliveryStreamName

Il flusso Firehose in cui scrivere i dati del messaggio.

Supporta modelli sostitutivi: API e solo AWS CLI

separator

(Facoltativo) Un separatore di caratteri utilizzato per separare i record scritti nello stream Firehose. Se ometti questo parametro, il flusso non utilizza alcun separatore. Valori validi: , (virgola), \t (scheda), \n (nuova riga), \r\n (Nuova riga di Windows).

Supporta modelli di sostituzione: no

roleArn

Il ruolo IAM che consente l'accesso allo stream Firehose. Per ulteriori informazioni, consulta Requisiti.

Supporta modelli di sostituzione: no

Esempi

Il seguente esempio JSON definisce un'azione Firehose in una regola. AWS IoT 

{
    "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"
                }
            }
        ] 
    }
}

Il seguente esempio JSON definisce un'azione Firehose con modelli di sostituzione in una regola. 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"
                }
            }
        ]
    }
}

Consulta anche