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