Table Of Contents

Feedback

User Guide

First time using the AWS CLI? See the User Guide for help getting started.

Note: You are viewing the documentation for an older major version of the AWS CLI (version 1).

AWS CLI version 2, the latest major version of AWS CLI, is now stable and recommended for general use. To view this page for the AWS CLI version 2, click here. For more information see the AWS CLI version 2 installation instructions and migration guide.

[ aws . iotanalytics ]

run-pipeline-activity

Description

Simulates the results of running a pipeline activity on a message payload.

See also: AWS API Documentation

See 'aws help' for descriptions of global parameters.

Synopsis

  run-pipeline-activity
--pipeline-activity <value>
--payloads <value>
[--cli-input-json <value>]
[--generate-cli-skeleton <value>]

Options

--pipeline-activity (structure)

The pipeline activity that is run. This must not be a 'channel' activity or a 'datastore' activity because these activities are used in a pipeline only to load the original message and to store the (possibly) transformed message. If a 'lambda' activity is specified, only short-running Lambda functions (those with a timeout of less than 30 seconds or less) can be used.

Shorthand Syntax:

channel={name=string,channelName=string,next=string},lambda={name=string,lambdaName=string,batchSize=integer,next=string},datastore={name=string,datastoreName=string},addAttributes={name=string,attributes={KeyName1=string,KeyName2=string},next=string},removeAttributes={name=string,attributes=[string,string],next=string},selectAttributes={name=string,attributes=[string,string],next=string},filter={name=string,filter=string,next=string},math={name=string,attribute=string,math=string,next=string},deviceRegistryEnrich={name=string,attribute=string,thingName=string,roleArn=string,next=string},deviceShadowEnrich={name=string,attribute=string,thingName=string,roleArn=string,next=string}

JSON Syntax:

{
  "channel": {
    "name": "string",
    "channelName": "string",
    "next": "string"
  },
  "lambda": {
    "name": "string",
    "lambdaName": "string",
    "batchSize": integer,
    "next": "string"
  },
  "datastore": {
    "name": "string",
    "datastoreName": "string"
  },
  "addAttributes": {
    "name": "string",
    "attributes": {"string": "string"
      ...},
    "next": "string"
  },
  "removeAttributes": {
    "name": "string",
    "attributes": ["string", ...],
    "next": "string"
  },
  "selectAttributes": {
    "name": "string",
    "attributes": ["string", ...],
    "next": "string"
  },
  "filter": {
    "name": "string",
    "filter": "string",
    "next": "string"
  },
  "math": {
    "name": "string",
    "attribute": "string",
    "math": "string",
    "next": "string"
  },
  "deviceRegistryEnrich": {
    "name": "string",
    "attribute": "string",
    "thingName": "string",
    "roleArn": "string",
    "next": "string"
  },
  "deviceShadowEnrich": {
    "name": "string",
    "attribute": "string",
    "thingName": "string",
    "roleArn": "string",
    "next": "string"
  }
}

--payloads (list)

The sample message payloads on which the pipeline activity is run.

Syntax:

blob blob ...

--cli-input-json (string) Performs service operation based on the JSON string provided. The JSON string follows the format provided by --generate-cli-skeleton. If other arguments are provided on the command line, the CLI values will override the JSON-provided values. It is not possible to pass arbitrary binary values using a JSON-provided value as the string will be taken literally.

--generate-cli-skeleton (string) Prints a JSON skeleton to standard output without sending an API request. If provided with no value or the value input, prints a sample input JSON that can be used as an argument for --cli-input-json. If provided with the value output, it validates the command inputs and returns a sample output JSON for that command.

See 'aws help' for descriptions of global parameters.

Examples

To simulate a pipeline activity

The following run-pipeline-activity example simulates the results of running a pipeline activity on a message payload.

aws iotanalytics run-pipeline-activity \
    --pipeline-activity file://maths.json \
    --payloads file://payloads.json

Contents of maths.json:

{
    "math": {
        "name": "MyMathActivity",
        "math": "((temp - 32) * 5.0) / 9.0",
        "attribute": "tempC"
    }
}

Contents of payloads.json:

[
    "{\"humidity\": 52, \"temp\": 68 }",
    "{\"humidity\": 52, \"temp\": 32 }"
]

Output:

{
    "logResult": "",
    "payloads": [
        "eyJodW1pZGl0eSI6NTIsInRlbXAiOjY4LCJ0ZW1wQyI6MjB9",
        "eyJodW1pZGl0eSI6NTIsInRlbXAiOjMyLCJ0ZW1wQyI6MH0="
    ]
}

For more information, see RunPipelineActivity in the AWS IoT Analytics API Reference.

Output

payloads -> (list)

The enriched or transformed sample message payloads as base64-encoded strings. (The results of running the pipeline activity on each input sample message payload, encoded in base64.)

(blob)

logResult -> (string)

In case the pipeline activity fails, the log message that is generated.