class Aws::IoTAnalytics::Types::PipelineActivity

@return [Types::DeviceShadowEnrichActivity]
Adds information from the IoT Device Shadow service to a message.
@!attribute [rw] device_shadow_enrich
@return [Types::DeviceRegistryEnrichActivity]
Adds data from the IoT device registry to your message.
@!attribute [rw] device_registry_enrich
@return [Types::MathActivity]
and adds it to the message.
Computes an arithmetic expression using the message’s attributes
@!attribute [rw] math
@return [Types::FilterActivity]
Filters a message based on its attributes.
@!attribute [rw] filter
@return [Types::SelectAttributesActivity]
from the original message.
Used to create a new message using only the specified attributes
@!attribute [rw] select_attributes
@return [Types::RemoveAttributesActivity]
Removes attributes from a message.
@!attribute [rw] remove_attributes
@return [Types::AddAttributesActivity]
Adds other attributes based on existing attributes in the message.
@!attribute [rw] add_attributes
@return [Types::DatastoreActivity]
Specifies where to store the processed message data.
@!attribute [rw] datastore
@return [Types::LambdaActivity]
Runs a Lambda function to modify the message.
@!attribute [rw] lambda
@return [Types::ChannelActivity]
Determines the source of the messages to be processed.
@!attribute [rw] channel
}
},
next: “ActivityName”,
role_arn: “RoleArn”, # required
thing_name: “AttributeName”, # required
attribute: “AttributeName”, # required
name: “ActivityName”, # required
device_shadow_enrich: {
},
next: “ActivityName”,
role_arn: “RoleArn”, # required
thing_name: “AttributeName”, # required
attribute: “AttributeName”, # required
name: “ActivityName”, # required
device_registry_enrich: {
},
next: “ActivityName”,
math: “MathExpression”, # required
attribute: “AttributeName”, # required
name: “ActivityName”, # required
math: {
},
next: “ActivityName”,
filter: “FilterExpression”, # required
name: “ActivityName”, # required
filter: {
},
next: “ActivityName”,
attributes: [“AttributeName”], # required
name: “ActivityName”, # required
select_attributes: {
},
next: “ActivityName”,
attributes: [“AttributeName”], # required
name: “ActivityName”, # required
remove_attributes: {
},
next: “ActivityName”,
},
“AttributeName” => “AttributeName”,
attributes: { # required
name: “ActivityName”, # required
add_attributes: {
},
datastore_name: “DatastoreName”, # required
name: “ActivityName”, # required
datastore: {
},
next: “ActivityName”,
batch_size: 1, # required
lambda_name: “LambdaName”, # required
name: “ActivityName”, # required
lambda: {
},
next: “ActivityName”,
channel_name: “ChannelName”, # required
name: “ActivityName”, # required
channel: {
{
data as a hash:
@note When making an API call, you may pass PipelineActivity
An activity that performs a transformation on a message.