파이프라인 생성

파이프라인은 채널의 메시지를 사용하고 사용자가 데이터 스토어에 저장하기 전에 메시지를 처리 및 필터링할 수 있습니다. 채널을 데이터 스토어에 연결하려면 파이프라인을 생성합니다. 가장 단순한 파이프라인에는 데이터를 수집할 채널을 지정하고 메시지를 보낼 데이터 스토어를 식별하는 것 외에는 다른 활동이 없습니다. 더 복잡한 파이프라인에 대한 자세한 내용은 파이프라인 활동을 참조하십시오.

처음에는 채널을 데이터 스토어에 연결하는 것 외에는 아무 작업도 수행하지 않는 파이프라인을 만드는 것이 좋습니다. 그러면 원시 데이터가 어떤 경로로 데이터 스토어까지 이동하는지 확인한 다음 이 데이터를 처리할 파이프라인 활동을 추가할 수 있습니다.

다음 명령을 실행해 파이프라인을 생성합니다.

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