View a markdown version of this page

Flussi di dati Kinesis - 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à.

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 l'esecuzione dell'operazione. kinesis:PutRecord Per ulteriori informazioni, consulta Concessione di un AWS IoT regola l'accesso che richiede.

    Nella AWS IoT console, puoi scegliere o creare un ruolo per consentire l'esecuzione AWS IoT di questa azione basata sulla regola.

  • Se si utilizza 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 per utilizzarla per conto del AWS KMS key 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.

Parameters

Quando si crea una AWS IoT regola con questa azione, è necessario specificare le seguenti informazioni:

stream

Flusso di dati Kinesis in cui scrivere i dati.

Supporta i modelli di sostituzione: 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

L'ARN del ruolo IAM che concede il AWS IoT permesso di 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