class Aws::IoTAnalytics::Types::RunPipelineActivityRequest

@note When making an API call, you may pass RunPipelineActivityRequest

data as a hash:

    {
      pipeline_activity: { # required
        channel: {
          name: "ActivityName", # required
          channel_name: "ChannelName", # required
          next: "ActivityName",
        },
        lambda: {
          name: "ActivityName", # required
          lambda_name: "LambdaName", # required
          batch_size: 1, # required
          next: "ActivityName",
        },
        datastore: {
          name: "ActivityName", # required
          datastore_name: "DatastoreName", # required
        },
        add_attributes: {
          name: "ActivityName", # required
          attributes: { # required
            "AttributeName" => "AttributeName",
          },
          next: "ActivityName",
        },
        remove_attributes: {
          name: "ActivityName", # required
          attributes: ["AttributeName"], # required
          next: "ActivityName",
        },
        select_attributes: {
          name: "ActivityName", # required
          attributes: ["AttributeName"], # required
          next: "ActivityName",
        },
        filter: {
          name: "ActivityName", # required
          filter: "FilterExpression", # required
          next: "ActivityName",
        },
        math: {
          name: "ActivityName", # required
          attribute: "AttributeName", # required
          math: "MathExpression", # required
          next: "ActivityName",
        },
        device_registry_enrich: {
          name: "ActivityName", # required
          attribute: "AttributeName", # required
          thing_name: "AttributeName", # required
          role_arn: "RoleArn", # required
          next: "ActivityName",
        },
        device_shadow_enrich: {
          name: "ActivityName", # required
          attribute: "AttributeName", # required
          thing_name: "AttributeName", # required
          role_arn: "RoleArn", # required
          next: "ActivityName",
        },
      },
      payloads: ["data"], # required
    }

@!attribute [rw] pipeline_activity

The pipeline activity that is run. This must not be a channel
activity or a data store 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.
@return [Types::PipelineActivity]

@!attribute [rw] payloads

The sample message payloads on which the pipeline activity is run.
@return [Array<String>]

Constants

SENSITIVE