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

Inherits:
Struct
  • Object
show all
Defined in:
gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb

Overview

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

An activity that performs a transformation on a message.

Constant Summary collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#add_attributesTypes::AddAttributesActivity

Adds other attributes based on existing attributes in the message.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#channelTypes::ChannelActivity

Determines the source of the messages to be processed.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#datastoreTypes::DatastoreActivity

Specifies where to store the processed message data.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#device_registry_enrichTypes::DeviceRegistryEnrichActivity

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



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#device_shadow_enrichTypes::DeviceShadowEnrichActivity

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



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#filterTypes::FilterActivity

Filters a message based on its attributes.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#lambdaTypes::LambdaActivity

Runs a Lambda function to modify the message.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#mathTypes::MathActivity

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

Returns:



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#remove_attributesTypes::RemoveAttributesActivity

Removes attributes from a message.



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end

#select_attributesTypes::SelectAttributesActivity

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



2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
# File 'gems/aws-sdk-iotanalytics/lib/aws-sdk-iotanalytics/types.rb', line 2699

class PipelineActivity < Struct.new(
  :channel,
  :lambda,
  :datastore,
  :add_attributes,
  :remove_attributes,
  :select_attributes,
  :filter,
  :math,
  :device_registry_enrich,
  :device_shadow_enrich)
  SENSITIVE = []
  include Aws::Structure
end