创建管道 - AWS IoT Analytics
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

创建管道

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

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

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

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