class Aws::IoTAnalytics::Types::RunPipelineActivityRequest
@note When making an API call, you may pass RunPipelineActivityRequest
data as a hash: { pipeline_activity: { # required 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", }, }, payloads: ["data"], # required }
@!attribute [rw] pipeline_activity
The pipeline activity that is run. This must not be a channel activity or a data store activity because these activities are used in a pipeline only to load the original message and to store the (possibly) transformed message. If a Lambda activity is specified, only short-running Lambda functions (those with a timeout of less than 30 seconds or less) can be used. @return [Types::PipelineActivity]
@!attribute [rw] payloads
The sample message payloads on which the pipeline activity is run. @return [Array<String>]
Constants
- SENSITIVE