Network.AWS.IoTAnalytics.CreatePipeline

Creates a pipeline. A pipeline consumes messages from one or more channels and allows you to process the messages before storing them in a data store.

Creating a Request

createPipeline

Arguments

:: Text

cpPipelineName

-> NonEmpty PipelineActivity

cpPipelineActivities

-> CreatePipeline

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

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

• cpPipelineName - The name of the pipeline.
• cpPipelineActivities - A list of pipeline activities. The list can be 1-25 PipelineActivity objects. Activities perform transformations on your messages, such as removing, renaming, or adding message attributes; filtering messages based on attribute values; invoking your Lambda functions on messages for advanced processing; or performing mathematical transformations to normalize device data.

data CreatePipeline

See: createPipeline smart constructor.

Instances

Eq CreatePipeline

Methods

(==) :: CreatePipeline -> CreatePipeline -> Bool

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

Data CreatePipeline

Methods

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

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

toConstr :: CreatePipeline -> Constr

dataTypeOf :: CreatePipeline -> DataType

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

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

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

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

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

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

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

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

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

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

Read CreatePipeline

Methods

readsPrec :: Int -> ReadS CreatePipeline

readList :: ReadS [CreatePipeline]

readPrec :: ReadPrec CreatePipeline

readListPrec :: ReadPrec [CreatePipeline]

Show CreatePipeline

Methods

showsPrec :: Int -> CreatePipeline -> ShowS

show :: CreatePipeline -> String

showList :: [CreatePipeline] -> ShowS

Generic CreatePipeline

Associated Types

type Rep CreatePipeline :: * -> *

Methods

from :: CreatePipeline -> Rep CreatePipeline x

to :: Rep CreatePipeline x -> CreatePipeline

Hashable CreatePipeline

Methods

hashWithSalt :: Int -> CreatePipeline -> Int

hash :: CreatePipeline -> Int

ToJSON CreatePipeline

Methods

toJSON :: CreatePipeline -> Value

toEncoding :: CreatePipeline -> Encoding

toJSONList :: [CreatePipeline] -> Value

toEncodingList :: [CreatePipeline] -> Encoding

NFData CreatePipeline

Methods

rnf :: CreatePipeline -> ()

AWSRequest CreatePipeline

Associated Types

type Rs CreatePipeline :: *

Methods

request :: CreatePipeline -> Request CreatePipeline

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

ToHeaders CreatePipeline

Methods

toHeaders :: CreatePipeline -> [Header]

ToPath CreatePipeline

Methods

toPath :: CreatePipeline -> ByteString

ToQuery CreatePipeline

Methods

toQuery :: CreatePipeline -> QueryString

type Rep CreatePipeline

type Rep CreatePipeline = D1 * (MetaData "CreatePipeline" "Network.AWS.IoTAnalytics.CreatePipeline" "amazonka-iot-analytics-1.6.0-J5q8AVx26VCAr48eVqZbw0" False) (C1 * (MetaCons "CreatePipeline'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cpPipelineName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_cpPipelineActivities") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (List1 PipelineActivity)))))

type Rs CreatePipeline

type Rs CreatePipeline = CreatePipelineResponse

Request Lenses

cpPipelineName :: Lens' CreatePipeline Text

The name of the pipeline.

cpPipelineActivities :: Lens' CreatePipeline (NonEmpty PipelineActivity)

A list of pipeline activities. The list can be 1-25 PipelineActivity objects. Activities perform transformations on your messages, such as removing, renaming, or adding message attributes; filtering messages based on attribute values; invoking your Lambda functions on messages for advanced processing; or performing mathematical transformations to normalize device data.

Destructuring the Response

createPipelineResponse

Arguments

:: Int

cprsResponseStatus

-> CreatePipelineResponse

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

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

• cprsPipelineName - The name of the pipeline.
• cprsPipelineARN - The ARN of the pipeline.
• cprsResponseStatus - -- | The response status code.

data CreatePipelineResponse

See: createPipelineResponse smart constructor.

Instances

Eq CreatePipelineResponse

Methods

(==) :: CreatePipelineResponse -> CreatePipelineResponse -> Bool

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

Data CreatePipelineResponse

Methods

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

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

toConstr :: CreatePipelineResponse -> Constr

dataTypeOf :: CreatePipelineResponse -> DataType

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

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

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

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

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

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

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

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

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

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

Read CreatePipelineResponse

Methods

readsPrec :: Int -> ReadS CreatePipelineResponse

readList :: ReadS [CreatePipelineResponse]

readPrec :: ReadPrec CreatePipelineResponse

readListPrec :: ReadPrec [CreatePipelineResponse]

Show CreatePipelineResponse

Methods

showsPrec :: Int -> CreatePipelineResponse -> ShowS

show :: CreatePipelineResponse -> String

showList :: [CreatePipelineResponse] -> ShowS

Generic CreatePipelineResponse

Associated Types

type Rep CreatePipelineResponse :: * -> *

Methods

from :: CreatePipelineResponse -> Rep CreatePipelineResponse x

to :: Rep CreatePipelineResponse x -> CreatePipelineResponse

NFData CreatePipelineResponse

Methods

rnf :: CreatePipelineResponse -> ()

type Rep CreatePipelineResponse

type Rep CreatePipelineResponse = D1 * (MetaData "CreatePipelineResponse" "Network.AWS.IoTAnalytics.CreatePipeline" "amazonka-iot-analytics-1.6.0-J5q8AVx26VCAr48eVqZbw0" False) (C1 * (MetaCons "CreatePipelineResponse'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cprsPipelineName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) ((:*:) * (S1 * (MetaSel (Just Symbol "_cprsPipelineARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_cprsResponseStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Int)))))

Response Lenses

cprsPipelineName :: Lens' CreatePipelineResponse (Maybe Text)

The name of the pipeline.

cprsPipelineARN :: Lens' CreatePipelineResponse (Maybe Text)

The ARN of the pipeline.

cprsResponseStatus :: Lens' CreatePipelineResponse Int

• - | The response status code.