PipelineActivity

import type { PipelineActivity } from "https://aws-api.deno.dev/v0.3/services/iotanalytics.ts?docs=full";

An activity that performs a transformation on a message.

interface PipelineActivity {

addAttributes?: AddAttributesActivity | null;

channel?: ChannelActivity | null;

datastore?: DatastoreActivity | null;

deviceRegistryEnrich?: DeviceRegistryEnrichActivity | null;

deviceShadowEnrich?: DeviceShadowEnrichActivity | null;

filter?: FilterActivity | null;

lambda?: LambdaActivity | null;

math?: MathActivity | null;

removeAttributes?: RemoveAttributesActivity | null;

selectAttributes?: SelectAttributesActivity | null;

}

§Properties

addAttributes?: AddAttributesActivity | null

Adds other attributes based on existing attributes in the message.

channel?: ChannelActivity | null

Determines the source of the messages to be processed.

datastore?: DatastoreActivity | null

Specifies where to store the processed message data.

deviceRegistryEnrich?: DeviceRegistryEnrichActivity | null

Adds data from the IoT device registry to your message.

deviceShadowEnrich?: DeviceShadowEnrichActivity | null

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

filter?: FilterActivity | null

Filters a message based on its attributes.

lambda?: LambdaActivity | null

Runs a Lambda function to modify the message.

math?: MathActivity | null

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

removeAttributes?: RemoveAttributesActivity | null

Removes attributes from a message.

selectAttributes?: SelectAttributesActivity | null

Used to create a new message using only the specified attributes from the original message.