class Aws::IoTAnalytics::Types::PipelineActivity

An activity that performs a transformation on a message.

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

data as a hash:

    {
      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",
      },
    }

@!attribute [rw] channel

Determines the source of the messages to be processed.
@return [Types::ChannelActivity]

@!attribute [rw] lambda

Runs a Lambda function to modify the message.
@return [Types::LambdaActivity]

@!attribute [rw] datastore

Specifies where to store the processed message data.
@return [Types::DatastoreActivity]

@!attribute [rw] add_attributes

Adds other attributes based on existing attributes in the message.
@return [Types::AddAttributesActivity]

@!attribute [rw] remove_attributes

Removes attributes from a message.
@return [Types::RemoveAttributesActivity]

@!attribute [rw] select_attributes

Used to create a new message using only the specified attributes
from the original message.
@return [Types::SelectAttributesActivity]

@!attribute [rw] filter

Filters a message based on its attributes.
@return [Types::FilterActivity]

@!attribute [rw] math

Computes an arithmetic expression using the message's attributes
and adds it to the message.
@return [Types::MathActivity]

@!attribute [rw] device_registry_enrich

Adds data from the IoT device registry to your message.
@return [Types::DeviceRegistryEnrichActivity]

@!attribute [rw] device_shadow_enrich

Adds information from the IoT Device Shadow service to a message.
@return [Types::DeviceShadowEnrichActivity]

Constants

SENSITIVE