You are viewing documentation for version 2 of the AWS SDK for Ruby. Version 3 documentation can be found here.

Class: Aws::IoTAnalytics::Types::PipelineActivity

Inherits:
Struct
  • Object
show all
Defined in:
(unknown)

Overview

Note:

When passing PipelineActivity as input to an Aws::Client method, you can use a vanilla 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",
  },
}

An activity that performs a transformation on a message.

Returned by:

Instance Attribute Summary collapse

Instance Attribute Details

#add_attributes ⇒ Types::AddAttributesActivity

Adds other attributes based on existing attributes in the message.

Returns:

#channel ⇒ Types::ChannelActivity

Determines the source of the messages to be processed.

Returns:

#datastore ⇒ Types::DatastoreActivity

Specifies where to store the processed message data.

Returns:

#device_registry_enrich ⇒ Types::DeviceRegistryEnrichActivity

Adds data from the AWS IoT device registry to your message.

Returns:

#device_shadow_enrich ⇒ Types::DeviceShadowEnrichActivity

Adds information from the AWS IoT Device Shadow service to a message.

Returns:

#filter ⇒ Types::FilterActivity

Filters a message based on its attributes.

Returns:

#lambda ⇒ Types::LambdaActivity

Runs a Lambda function to modify the message.

Returns:

#math ⇒ Types::MathActivity

Computes an arithmetic expression using the message\'s attributes and adds it to the message.

Returns:

  • (Types::MathActivity) —

    Computes an arithmetic expression using the message\'s attributes and adds it to the message.

#remove_attributes ⇒ Types::RemoveAttributesActivity

Removes attributes from a message.

Returns:

#select_attributes ⇒ Types::SelectAttributesActivity

Creates a new message using only the specified attributes from the original message.

Returns: