Eine Pipeline erstellen

Eine Pipeline verarbeitet Nachrichten von einem Kanal und ermöglicht es Ihnen, die Nachrichten zu verarbeiten und zu filtern, bevor Sie sie in einem Datenspeicher speichern. Um einen Kanal mit einem Datenspeicher zu verbinden, müssen Sie eine Pipeline erstellen. Die einfachste mögliche Pipeline enthält keine Aktivitäten außer die Angabe des Kanals, der die Daten erfasst, und die Identifikation des Datenspeichers, an den die Nachrichten gesendet werden. Informationen zu komplizierteren Pipelines finden Sie unter Pipeline-Aktivitäten.

Wir empfehlen, mit einer Pipeline zu beginnen, die nichts anderes tut, als einen Kanal mit einem Datenspeicher zu verbinden. Nachdem Sie dann bestätigt haben, dass Rohdaten in den Datenspeicher eingespeist werden, können Sie weitere Pipeline-Aktivitäten zur Verarbeitung dieser Daten einführen.

Führen Sie den folgenden Befehl aus, um eine Pipeline zu erstellen.

aws iotanalytics create-pipeline --cli-input-json file://mypipeline.json

Die Datei mypipeline.json enthält den folgenden Inhalt.

{
    "pipelineName": "mypipeline",
    "pipelineActivities": [
        {
            "channel": {
                "name": "mychannelactivity",
                "channelName": "mychannel",
                "next": "mystoreactivity"
            }
        },
        {
            "datastore": {
                "name": "mystoreactivity",
                "datastoreName": "mydatastore"
            }
        }
    ]
}

Führen Sie den folgenden Befehl aus, um Ihre vorhandenen Pipelines aufzulisten.

aws iotanalytics list-pipelines

Führen Sie den folgenden Befehl aus, um die Konfiguration einer einzelnen Pipeline anzuzeigen.

aws iotanalytics describe-pipeline  --pipeline-name mypipeline