Flussi di dati Kinesis - AWS IoT Core
RequisitiParametriEsempiConsulta 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à.

Flussi di dati Kinesis

L'azione Kinesis Data kinesis Streams () scrive i dati MQTT da un messaggio ad Amazon Kinesis Data Streams.

Requisiti

Questa operazione della regola presenta i seguenti requisiti:

  • Un IAM ruolo che AWS IoT può assumere per eseguire l'operazione. kinesis:PutRecord Per ulteriori informazioni, consulta Concedere a qualsiasi AWS IoT regola l'accesso richiesto.

    Nella AWS IoT console, è possibile scegliere o creare un ruolo per consentire l'esecuzione di questa azione relativa AWS IoT alla regola.

  • Se si utilizza una AWS KMS key (KMSchiave) AWS KMS gestita dal cliente per crittografare i dati inattivi in Kinesis Data Streams, il servizio deve disporre dell'autorizzazione a AWS KMS key utilizzarla per conto del chiamante. Per ulteriori informazioni, consulta Autorizzazioni per l'uso di AWS KMS keys generate dall'utente nella Guida per gli sviluppatori di Amazon Kinesis Data Streams.

Parametri

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

stream

Flusso di dati Kinesis in cui scrivere i dati.

Supporta modelli sostitutivi: API e solo AWS CLI

partitionKey

Chiave di partizione usata per determinare in quale shard vengono scritti i dati. La chiave di partizione è in genere composta da un'espressione (ad esempio, ${topic()} o ${timestamp()}).

Supporta modelli di sostituzione: sì

roleArn

Il ARN IAM ruolo che concede l' AWS IoT autorizzazione all'accesso al flusso di dati Kinesis. Per ulteriori informazioni, consulta Requisiti.

Supporta modelli di sostituzione: no

Esempi

L'JSONesempio seguente definisce un'azione AWS IoT Kinesis Data Streams in una regola.

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

L'JSONesempio seguente definisce un'azione Kinesis con modelli di sostituzione in una regola. 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"
                }
            }
        ]
    }
}

Consulta anche