View a markdown version of this page

Kinesis Data Streams - AWS IoT Core
ExigencesParametersExemplesConsultez aussi

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Kinesis Data Streams

L'action Kinesis Data Streams kinesis () écrit les données d'un message MQTT dans Amazon Kinesis Data Streams.

Exigences

Cette action réglementaire est assortie des exigences suivantes :

  • Un rôle IAM que AWS IoT vous pouvez assumer pour effectuer l'kinesis:PutRecordopération. Pour de plus amples informations, veuillez consulter Octroi d'un AWS IoT réglez l'accès dont il a besoin.

    Dans la AWS IoT console, vous pouvez choisir ou créer un rôle pour permettre AWS IoT d'exécuter cette action de règle.

  • Si vous utilisez une clé KMS AWS KMS gérée par le client AWS KMS key pour chiffrer les données au repos dans Kinesis Data Streams, le service doit être autorisé à les utiliser au nom de AWS KMS key l'appelant. Pour de plus amples informations, veuillez consulter Permissions to use user-generated AWS KMS keys dans le Amazon Kinesis Data Streams Developer Guide.

Parameters

Lorsque vous créez une AWS IoT règle avec cette action, vous devez spécifier les informations suivantes :

stream

Le Flux de donnees Kinesis dans lequel écrire les données.

Supporte les modèles de substitution  : API et AWS CLI uniquement

partitionKey

Clé de partition utilisée pour déterminer dans quelle partition les données sont écrites. La clé de partition est généralement composée d'une expression (par exemple, ${topic()} ou ${timestamp()}).

Prend en charge les modèles de substitution : Oui

roleArn

L'ARN du rôle IAM qui AWS IoT autorise l'accès au flux de données Kinesis. Pour de plus amples informations, veuillez consulter Exigences.

Prend en charge les modèles de substitution : Non

Exemples

L'exemple JSON suivant définit une action Kinesis Data Streams dans une AWS IoT règle.

{
    "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'exemple JSON suivant définit une action Kinesis avec des modèles de substitution dans une AWS IoT règle.

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

Consultez aussi