Creación de una canalización

Una canalización consume mensajes de un canal y le permite procesar y filtrar los mensajes antes de guardarlos en un almacén de datos. Para conectar un canal a un almacén de datos, cree una canalización. La canalización más sencilla posible no contiene ninguna otra actividad aparte de la especificación del canal que recopila los datos y la identificación del almacén de datos donde se envían los mensajes. Para obtener información sobre otras canalizaciones más complejas, consulte Actividades de canalización.

Para comenzar, recomendamos que cree una canalización que lo único que haga sea conectar un canal a un almacén de datos. A continuación, después de verificar los flujos de datos sin procesar en el almacén de datos, podrá introducir actividades de canalización adicionales para procesarlos.

Ejecute el siguiente comando para crear una canalización.

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

El archivo mypipeline.json contiene el siguiente contenido.

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

Ejecute el siguiente comando para enumerar las canalizaciones existentes.

aws iotanalytics list-pipelines

Ejecute el siguiente comando para ver la configuración de una canalización individual.

aws iotanalytics describe-pipeline  --pipeline-name mypipeline