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’operazione Kinesis Data Streams (kinesis) scrive i dati da un messaggio MQTT in Amazon Kinesis Data Streams.

Requisiti

Questa operazione della regola presenta i seguenti requisiti:

  • Un ruolo IAM 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, puoi scegliere o creare un ruolo che consenta di AWS IoT eseguire questa azione relativa alla regola.

  • Se utilizzi una chiave KMS AWS KMS gestita dal cliente AWS KMS key per crittografare i dati inattivi in Kinesis Data Streams, il servizio deve disporre dell'autorizzazione a utilizzarla per conto del chiamante. AWS KMS key 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: solo API 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

L'ARN del ruolo IAM che concede l' AWS IoT autorizzazione per accedere al flusso di dati Kinesis. Per ulteriori informazioni, consulta Requisiti.

Supporta modelli di sostituzione: no

Esempi

Il seguente esempio JSON definisce un'azione Kinesis Data Streams in una regola. AWS IoT 

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

Il seguente esempio JSON 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