Criando um pipeline - AWS IoT Analytics

Aviso de fim do suporte: em 15 de dezembro de 2025, AWS encerrará o suporte para AWS IoT Analytics. Depois de 15 de dezembro de 2025, você não poderá mais acessar o AWS IoT Analytics console ou os AWS IoT Analytics recursos. Para obter mais informações, consulte AWS IoT Analytics Fim do suporte.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Criando um pipeline

Um pipeline consome as mensagens de um canal e permite processar e filtrar as mensagens antes de armazená-las em um datastore. Para conectar um canal a um datastore, crie um pipeline. O pipeline mais simples possível não contém atividades que não sejam especificar o canal que coleta os dados e identificar o datastore para o qual as mensagens são enviadas. Para obter mais informações sobre pipelines mais complicados, consulte Atividades do pipeline.

Ao iniciar, recomendamos criar um pipeline que não faça nada além de conectar um canal a um datastore. Depois, após verificar os fluxos de dados brutos ao datastore, é possível introduzir atividades adicionais do pipeline para processas esses dados.

Execute o comando a seguir para criar um pipeline.

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

O arquivo mypipeline.json contém o conteúdo a seguir.

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

Execute o comando a seguir para listar os pipelines existentes.

aws iotanalytics list-pipelines

Execute o comando a seguir para visualizar a configuração de um pipeline individual.

aws iotanalytics describe-pipeline  --pipeline-name mypipeline