Select your cookie preferences

We use essential cookies and similar tools that are necessary to provide our site and services. We use performance cookies to collect anonymous statistics, so we can understand how customers use our site and make improvements. Essential cookies cannot be deactivated, but you can choose “Customize” or “Decline” to decline performance cookies.

If you agree, AWS and approved third parties will also use cookies to provide useful site features, remember your preferences, and display relevant content, including relevant advertising. To accept or decline all non-essential cookies, choose “Accept” or “Decline.” To make more detailed choices, choose “Customize.”

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_attributesTypes::AddAttributesActivity

Adds other attributes based on existing attributes in the message.

Returns:

#channelTypes::ChannelActivity

Determines the source of the messages to be processed.

Returns:

#datastoreTypes::DatastoreActivity

Specifies where to store the processed message data.

Returns:

#device_registry_enrichTypes::DeviceRegistryEnrichActivity

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

Returns:

#device_shadow_enrichTypes::DeviceShadowEnrichActivity

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

Returns:

#filterTypes::FilterActivity

Filters a message based on its attributes.

Returns:

#lambdaTypes::LambdaActivity

Runs a Lambda function to modify the message.

Returns:

#mathTypes::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_attributesTypes::RemoveAttributesActivity

Removes attributes from a message.

Returns:

#select_attributesTypes::SelectAttributesActivity

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

Returns: