Network.AWS.IoTAnalytics.RunPipelineActivity

Simulates the results of running a pipeline activity on a message payload.

Creating a Request

runPipelineActivity

Arguments

:: PipelineActivity

rpaPipelineActivity

-> NonEmpty ByteString

rpaPayloads

-> RunPipelineActivity

Creates a value of RunPipelineActivity with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

• rpaPipelineActivity - The pipeline activity that is run. This must not be a channel activity or a datastore 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.
• rpaPayloads - The sample message payloads on which the pipeline activity is run.

data RunPipelineActivity

See: runPipelineActivity smart constructor.

Instances

Eq RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

(==) :: RunPipelineActivity -> RunPipelineActivity -> Bool

(/=) :: RunPipelineActivity -> RunPipelineActivity -> Bool

Data RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> RunPipelineActivity -> c RunPipelineActivity

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c RunPipelineActivity

toConstr :: RunPipelineActivity -> Constr

dataTypeOf :: RunPipelineActivity -> DataType

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c RunPipelineActivity)

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c RunPipelineActivity)

gmapT :: (forall b. Data b => b -> b) -> RunPipelineActivity -> RunPipelineActivity

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> RunPipelineActivity -> r

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> RunPipelineActivity -> r

gmapQ :: (forall d. Data d => d -> u) -> RunPipelineActivity -> [u]

gmapQi :: Int -> (forall d. Data d => d -> u) -> RunPipelineActivity -> u

gmapM :: Monad m => (forall d. Data d => d -> m d) -> RunPipelineActivity -> m RunPipelineActivity

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> RunPipelineActivity -> m RunPipelineActivity

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> RunPipelineActivity -> m RunPipelineActivity

Read RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

readsPrec :: Int -> ReadS RunPipelineActivity

readList :: ReadS [RunPipelineActivity]

readPrec :: ReadPrec RunPipelineActivity

readListPrec :: ReadPrec [RunPipelineActivity]

Show RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

showsPrec :: Int -> RunPipelineActivity -> ShowS

show :: RunPipelineActivity -> String

showList :: [RunPipelineActivity] -> ShowS

Generic RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Associated Types

type Rep RunPipelineActivity :: Type -> Type

Methods

from :: RunPipelineActivity -> Rep RunPipelineActivity x

to :: Rep RunPipelineActivity x -> RunPipelineActivity

Hashable RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

hashWithSalt :: Int -> RunPipelineActivity -> Int

hash :: RunPipelineActivity -> Int

ToJSON RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

toJSON :: RunPipelineActivity -> Value

toEncoding :: RunPipelineActivity -> Encoding

toJSONList :: [RunPipelineActivity] -> Value

toEncodingList :: [RunPipelineActivity] -> Encoding

AWSRequest RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Associated Types

type Rs RunPipelineActivity :: Type

Methods

request :: RunPipelineActivity -> Request RunPipelineActivity

response :: (MonadResource m, MonadThrow m) => Logger -> Service -> Proxy RunPipelineActivity -> ClientResponse -> m (Response RunPipelineActivity)

ToHeaders RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

toHeaders :: RunPipelineActivity -> [Header]

ToPath RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

toPath :: RunPipelineActivity -> ByteString

ToQuery RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

toQuery :: RunPipelineActivity -> QueryString

NFData RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

rnf :: RunPipelineActivity -> ()

type Rep RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

type Rep RunPipelineActivity = D1 (MetaData "RunPipelineActivity" "Network.AWS.IoTAnalytics.RunPipelineActivity" "amazonka-iot-analytics-1.6.1-II7URRwPIs5C2HKxTKtgRZ" False) (C1 (MetaCons "RunPipelineActivity'" PrefixI True) (S1 (MetaSel (Just "_rpaPipelineActivity") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 PipelineActivity) :*: S1 (MetaSel (Just "_rpaPayloads") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (List1 Base64))))

type Rs RunPipelineActivity

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

type Rs RunPipelineActivity = RunPipelineActivityResponse

Request Lenses

rpaPipelineActivity :: Lens' RunPipelineActivity PipelineActivity

The pipeline activity that is run. This must not be a channel activity or a datastore 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.

rpaPayloads :: Lens' RunPipelineActivity (NonEmpty ByteString)

The sample message payloads on which the pipeline activity is run.

Destructuring the Response

runPipelineActivityResponse

Arguments

:: Int

rparsResponseStatus

-> RunPipelineActivityResponse

Creates a value of RunPipelineActivityResponse with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

• rparsLogResult - In case the pipeline activity fails, the log message that is generated.
• rparsPayloads - The enriched or transformed sample message payloads as base64-encoded strings. (The results of running the pipeline activity on each input sample message payload, encoded in base64.)
• rparsResponseStatus - -- | The response status code.

data RunPipelineActivityResponse

See: runPipelineActivityResponse smart constructor.

Instances

Eq RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

(==) :: RunPipelineActivityResponse -> RunPipelineActivityResponse -> Bool

(/=) :: RunPipelineActivityResponse -> RunPipelineActivityResponse -> Bool

Data RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> RunPipelineActivityResponse -> c RunPipelineActivityResponse

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c RunPipelineActivityResponse

toConstr :: RunPipelineActivityResponse -> Constr

dataTypeOf :: RunPipelineActivityResponse -> DataType

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c RunPipelineActivityResponse)

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c RunPipelineActivityResponse)

gmapT :: (forall b. Data b => b -> b) -> RunPipelineActivityResponse -> RunPipelineActivityResponse

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> RunPipelineActivityResponse -> r

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> RunPipelineActivityResponse -> r

gmapQ :: (forall d. Data d => d -> u) -> RunPipelineActivityResponse -> [u]

gmapQi :: Int -> (forall d. Data d => d -> u) -> RunPipelineActivityResponse -> u

gmapM :: Monad m => (forall d. Data d => d -> m d) -> RunPipelineActivityResponse -> m RunPipelineActivityResponse

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> RunPipelineActivityResponse -> m RunPipelineActivityResponse

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> RunPipelineActivityResponse -> m RunPipelineActivityResponse

Read RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

readsPrec :: Int -> ReadS RunPipelineActivityResponse

readList :: ReadS [RunPipelineActivityResponse]

readPrec :: ReadPrec RunPipelineActivityResponse

readListPrec :: ReadPrec [RunPipelineActivityResponse]

Show RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

showsPrec :: Int -> RunPipelineActivityResponse -> ShowS

show :: RunPipelineActivityResponse -> String

showList :: [RunPipelineActivityResponse] -> ShowS

Generic RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Associated Types

type Rep RunPipelineActivityResponse :: Type -> Type

Methods

from :: RunPipelineActivityResponse -> Rep RunPipelineActivityResponse x

to :: Rep RunPipelineActivityResponse x -> RunPipelineActivityResponse

NFData RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

Methods

rnf :: RunPipelineActivityResponse -> ()

type Rep RunPipelineActivityResponse

Defined in Network.AWS.IoTAnalytics.RunPipelineActivity

type Rep RunPipelineActivityResponse = D1 (MetaData "RunPipelineActivityResponse" "Network.AWS.IoTAnalytics.RunPipelineActivity" "amazonka-iot-analytics-1.6.1-II7URRwPIs5C2HKxTKtgRZ" False) (C1 (MetaCons "RunPipelineActivityResponse'" PrefixI True) (S1 (MetaSel (Just "_rparsLogResult") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_rparsPayloads") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (List1 Base64))) :*: S1 (MetaSel (Just "_rparsResponseStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Int))))

Response Lenses

rparsLogResult :: Lens' RunPipelineActivityResponse (Maybe Text)

In case the pipeline activity fails, the log message that is generated.

rparsPayloads :: Lens' RunPipelineActivityResponse (Maybe (NonEmpty ByteString))

The enriched or transformed sample message payloads as base64-encoded strings. (The results of running the pipeline activity on each input sample message payload, encoded in base64.)

rparsResponseStatus :: Lens' RunPipelineActivityResponse Int

• - | The response status code.