Creazione di una pipeline - AWS IoT Analytics

Avviso di fine del supporto: il 15 dicembre 2025, AWS terminerà il supporto per AWS IoT Analytics. Dopo il 15 dicembre 2025, non potrai più accedere alla AWS IoT Analytics console o AWS IoT Analytics alle risorse. Per ulteriori informazioni, consulta AWS IoT Analytics Fine del supporto.

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à.

Creazione di una pipeline

Una pipeline consuma i messaggi da un canale e consente di elaborare e filtrare i messaggi prima di archiviarli in un archivio dati. Per poter collegare un canale a un datastore, devi creare una pipeline. La pipeline più semplice contiene solo le attività di specifica del canale che raccoglie i dati e di identificazione del datastore a cui vengono inviati i messaggi. Per informazioni sulle pipeline più complicate, consulta Pipeline activity.

Consigliamo di iniziare creando una pipeline che non fa altro che connettere un canale a un datastore. Quindi, dopo avere verificato che i flussi di dati non elaborati arrivino al datastore, puoi introdurre ulteriori attività di pipeline per elaborare questi dati.

Eseguite il comando seguente per creare una pipeline.

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

Il file mypipeline.json contiene il seguente contenuto.

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

Eseguite il comando seguente per elencare le pipeline esistenti.

aws iotanalytics list-pipelines

Eseguite il comando seguente per visualizzare la configurazione di una singola pipeline.

aws iotanalytics describe-pipeline  --pipeline-name mypipeline