HEX
Server: LiteSpeed
System: Linux ip-172-31-76-142.ec2.internal 4.14.158-129.185.amzn2.x86_64 #1 SMP Tue Dec 24 03:15:32 UTC 2019 x86_64
User: 69b4844ae61d4e92bf26ad98af552775 (1065)
PHP: 7.2.27
Disabled: exec,passthru,shell_exec,system,eval
Upload Files
File: //lib/python2.7/site-packages/awscli/examples/iotanalytics/create-pipeline.rst
**Create an IoT Analytics Pipeline**

The following ``create-pipeline`` example creates a pipeline. A pipeline consumes messages from a channel and allows you to process the messages before storing them in a data store. You must specify both a channel and a data store activity and, optionally, as many as 23 additional activities in the ``pipelineActivities`` array. ::

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

Contents of ``create-pipeline.json``::

    {
        "pipelineName": "mypipeline",
        "pipelineActivities": [
            {
                "channel": {
                    "name": "myChannelActivity",
                    "channelName": "mychannel",
                    "next": "myMathActivity"
                }
            },
            {
                "datastore": {
                    "name": "myDatastoreActivity",
                    "datastoreName": "mydatastore"
                }
            },
            {
                "math": {
                    "name": "myMathActivity",
                    "math": "((temp - 32) * 5.0) / 9.0",
                    "attribute": "tempC",
                    "next": "myDatastoreActivity"
                }
            }
        ],
        "tags": [
            {
                "key": "Environment",
                "value": "Beta"
            }
        ]
    }

Output::

    {
        "pipelineArn": "arn:aws:iotanalytics:us-west-2:123456789012:pipeline/mypipeline",
        "pipelineName": "mypipeline"
    }

For more information, see `CreatePipeline <https://docs.aws.amazon.com/iotanalytics/latest/APIReference/API_CreatePipeline.html>`__ in the *AWS IoT Analytics API Reference*.