Copyright	(c) 2013-2021 Brendan Hay
License	Mozilla Public License, v. 2.0.
Maintainer	Brendan Hay <brendan.g.hay+amazonka@gmail.com>
Stability	auto-generated
Portability	non-portable (GHC extensions)
Safe Haskell	None

Amazonka.IoTAnalytics.Types.PipelineActivity

Description

Synopsis

Documentation

data PipelineActivity Source #

An activity that performs a transformation on a message.

See: newPipelineActivity smart constructor.

Constructors

PipelineActivity'

Fields

selectAttributes :: Maybe SelectAttributesActivity
Used to create a new message using only the specified attributes from the original message.
channel :: Maybe ChannelActivity
Determines the source of the messages to be processed.
addAttributes :: Maybe AddAttributesActivity
Adds other attributes based on existing attributes in the message.
deviceRegistryEnrich :: Maybe DeviceRegistryEnrichActivity
Adds data from the IoT device registry to your message.
removeAttributes :: Maybe RemoveAttributesActivity
Removes attributes from a message.
lambda :: Maybe LambdaActivity
Runs a Lambda function to modify the message.
datastore :: Maybe DatastoreActivity
Specifies where to store the processed message data.
deviceShadowEnrich :: Maybe DeviceShadowEnrichActivity
Adds information from the IoT Device Shadow service to a message.
filter' :: Maybe FilterActivity
Filters a message based on its attributes.
math :: Maybe MathActivity
Computes an arithmetic expression using the message's attributes and adds it to the message.

Instances

Instances details

Eq PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods (==) :: PipelineActivity -> PipelineActivity -> Bool # (/=) :: PipelineActivity -> PipelineActivity -> Bool #
Read PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods readsPrec :: Int -> ReadS PipelineActivity # readList :: ReadS [PipelineActivity] # readPrec :: ReadPrec PipelineActivity # readListPrec :: ReadPrec [PipelineActivity] #
Show PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods showsPrec :: Int -> PipelineActivity -> ShowS # show :: PipelineActivity -> String # showList :: [PipelineActivity] -> ShowS #
Generic PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Associated Types type Rep PipelineActivity :: Type -> Type # Methods from :: PipelineActivity -> Rep PipelineActivity x # to :: Rep PipelineActivity x -> PipelineActivity #
NFData PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods rnf :: PipelineActivity -> () #
Hashable PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods hashWithSalt :: Int -> PipelineActivity -> Int # hash :: PipelineActivity -> Int #
ToJSON PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods toJSON :: PipelineActivity -> Value # toEncoding :: PipelineActivity -> Encoding # toJSONList :: [PipelineActivity] -> Value # toEncodingList :: [PipelineActivity] -> Encoding #
FromJSON PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity Methods parseJSON :: Value -> Parser PipelineActivity # parseJSONList :: Value -> Parser [PipelineActivity] #
type Rep PipelineActivity Source #
Instance details Defined in Amazonka.IoTAnalytics.Types.PipelineActivity type Rep PipelineActivity = D1 ('MetaData "PipelineActivity" "Amazonka.IoTAnalytics.Types.PipelineActivity" "libZSservicesZSamazonka-iot-analyticsZSamazonka-iot-analytics" 'False) (C1 ('MetaCons "PipelineActivity'" 'PrefixI 'True) (((S1 ('MetaSel ('Just "selectAttributes") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe SelectAttributesActivity)) :: S1 ('MetaSel ('Just "channel") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe ChannelActivity))) :: (S1 ('MetaSel ('Just "addAttributes") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe AddAttributesActivity)) :: (S1 ('MetaSel ('Just "deviceRegistryEnrich") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe DeviceRegistryEnrichActivity)) :: S1 ('MetaSel ('Just "removeAttributes") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe RemoveAttributesActivity))))) :: ((S1 ('MetaSel ('Just "lambda") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe LambdaActivity)) :: S1 ('MetaSel ('Just "datastore") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe DatastoreActivity))) :: (S1 ('MetaSel ('Just "deviceShadowEnrich") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe DeviceShadowEnrichActivity)) :: (S1 ('MetaSel ('Just "filter'") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe FilterActivity)) :*: S1 ('MetaSel ('Just "math") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe MathActivity)))))))

newPipelineActivity :: PipelineActivity Source #

Create a value of PipelineActivity with all optional fields omitted.

Use generic-lens or optics to modify other optional fields.

The following record fields are available, with the corresponding lenses provided for backwards compatibility:

$sel:selectAttributes:PipelineActivity', pipelineActivity_selectAttributes - Used to create a new message using only the specified attributes from the original message.

$sel:channel:PipelineActivity', pipelineActivity_channel - Determines the source of the messages to be processed.

$sel:addAttributes:PipelineActivity', pipelineActivity_addAttributes - Adds other attributes based on existing attributes in the message.

$sel:deviceRegistryEnrich:PipelineActivity', pipelineActivity_deviceRegistryEnrich - Adds data from the IoT device registry to your message.

$sel:removeAttributes:PipelineActivity', pipelineActivity_removeAttributes - Removes attributes from a message.

$sel:lambda:PipelineActivity', pipelineActivity_lambda - Runs a Lambda function to modify the message.

$sel:datastore:PipelineActivity', pipelineActivity_datastore - Specifies where to store the processed message data.

$sel:deviceShadowEnrich:PipelineActivity', pipelineActivity_deviceShadowEnrich - Adds information from the IoT Device Shadow service to a message.

$sel:filter':PipelineActivity', pipelineActivity_filter - Filters a message based on its attributes.

$sel:math:PipelineActivity', pipelineActivity_math - Computes an arithmetic expression using the message's attributes and adds it to the message.

pipelineActivity_selectAttributes :: Lens' PipelineActivity (Maybe SelectAttributesActivity) Source #

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

pipelineActivity_channel :: Lens' PipelineActivity (Maybe ChannelActivity) Source #

Determines the source of the messages to be processed.

pipelineActivity_addAttributes :: Lens' PipelineActivity (Maybe AddAttributesActivity) Source #

Adds other attributes based on existing attributes in the message.

pipelineActivity_deviceRegistryEnrich :: Lens' PipelineActivity (Maybe DeviceRegistryEnrichActivity) Source #

Adds data from the IoT device registry to your message.

pipelineActivity_removeAttributes :: Lens' PipelineActivity (Maybe RemoveAttributesActivity) Source #

Removes attributes from a message.

pipelineActivity_lambda :: Lens' PipelineActivity (Maybe LambdaActivity) Source #

Runs a Lambda function to modify the message.

pipelineActivity_datastore :: Lens' PipelineActivity (Maybe DatastoreActivity) Source #

Specifies where to store the processed message data.

pipelineActivity_deviceShadowEnrich :: Lens' PipelineActivity (Maybe DeviceShadowEnrichActivity) Source #

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

pipelineActivity_filter :: Lens' PipelineActivity (Maybe FilterActivity) Source #

Filters a message based on its attributes.

pipelineActivity_math :: Lens' PipelineActivity (Maybe MathActivity) Source #

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