View a markdown version of this page

Kinesis-Datenströme - AWS IoT Core
VoraussetzungenParametersBeispieleWeitere Informationen finden Sie auch unter

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Kinesis-Datenströme

Die Aktion Kinesis Data Streams (kinesis) schreibt Daten aus einer MQTT-Nachricht in Amazon Kinesis Data Streams.

Voraussetzungen

Diese Regelaktion hat die folgenden Anforderungen:

  • Eine IAM-Rolle, die die Ausführung des AWS IoT Vorgangs übernehmen kann. kinesis:PutRecord Weitere Informationen finden Sie unter Gewährung einer AWS IoT regeln Sie den Zugriff, den es benötigt.

    In der AWS IoT Konsole können Sie eine Rolle auswählen oder erstellen, die AWS IoT die Ausführung dieser Regelaktion ermöglicht.

  • Wenn Sie einen AWS KMS vom Kunden verwalteten AWS KMS key (KMS-Schlüssel) verwenden, um ruhende Daten in Kinesis Data Streams zu verschlüsseln, muss der Dienst die Erlaubnis haben, den im Namen des AWS KMS key Anrufers zu verwenden. Weitere Informationen finden Sie unter Berechtigungen zur Verwendung von benutzergenerierten AWS KMS keys im Amazon Kinesis Data Streams Entwicklerhandbuch.

Parameters

Wenn Sie eine AWS IoT Regel mit dieser Aktion erstellen, müssen Sie die folgenden Informationen angeben:

stream

Der Kinesis Data Stream, in den die Daten geschrieben werden

Unterstützt Substitutionsvorlagen: API und nur AWS CLI

partitionKey

Der Partitionsschlüssel, mit dem bestimmt wird, in welchen Shard die Daten geschrieben werden. Der Partitionsschlüssel besteht in der Regel aus einem Ausdruck (z. B. ${topic()} oder ${timestamp()}).

Unterstützt Ersatzvorlagen: Ja

roleArn

Der ARN der IAM-Rolle, die die AWS IoT Berechtigung zum Zugriff auf den Kinesis-Datenstrom erteilt. Weitere Informationen finden Sie unter Voraussetzungen.

Unterstützt Ersatzvorlagen: Nein

Beispiele

Das folgende JSON-Beispiel definiert eine Kinesis Data Streams-Aktion in einer Regel. 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"
                }
            }
        ] 
    }
}

Das folgende JSON-Beispiel definiert eine Kinesis-Aktion mit Substitutionsvorlagen in einer Regel. 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"
                }
            }
        ]
    }
}

Weitere Informationen finden Sie auch unter