创建管道

管道使用来自通道的消息，并在将消息存储在数据存储之前允许您处理和筛选消息。要将通道连接到数据存储，请创建一个管道。最简单的管道除了指定收集数据的通道和标识将向其发送消息的数据存储之外，不包含任何其他活动。有关更复杂管道的信息，请参阅管道活动。

在开始时，我们建议您创建一个管道，该管道仅将通道连接到数据存储，而不执行任何其他操作。然后，在确认原始数据流到数据存储后，您可以引入额外的管道活动以处理该数据。

运行以下命令以创建管道。

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

mypipeline.json 文件包含以下内容。

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

运行以下命令可列出现有管道。

aws iotanalytics list-pipelines

运行以下命令可查看单个管道的配置。

aws iotanalytics describe-pipeline  --pipeline-name mypipeline