CfnPipelineMixinProps

class aws_cdk.mixins_preview.aws_iotanalytics.mixins.CfnPipelineMixinProps(*, pipeline_activities=None, pipeline_name=None, tags=None)

Bases: object

Properties for CfnPipelinePropsMixin.

Parameters:

• pipeline_activities (Union[IResolvable, Sequence[Union[IResolvable, ActivityProperty, Dict[str, Any]]], None]) – A list of “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. The list can be 2-25 PipelineActivity objects and must contain both a channel and a datastore activity. Each entry in the list must contain only one activity, for example: pipelineActivities = [ { "channel": { ... } }, { "lambda": { ... } }, ... ]

• pipeline_name (Optional[str]) – The name of the pipeline.

• tags (Optional[Sequence[Union[CfnTag, Dict[str, Any]]]]) – Metadata which can be used to manage the pipeline. For more information, see Tag .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-iotanalytics-pipeline.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_iotanalytics import mixins as iotanalytics_mixins

cfn_pipeline_mixin_props = iotanalytics_mixins.CfnPipelineMixinProps(
    pipeline_activities=[iotanalytics_mixins.CfnPipelinePropsMixin.ActivityProperty(
        add_attributes=iotanalytics_mixins.CfnPipelinePropsMixin.AddAttributesProperty(
            attributes={
                "attributes_key": "attributes"
            },
            name="name",
            next="next"
        ),
        channel=iotanalytics_mixins.CfnPipelinePropsMixin.ChannelProperty(
            channel_name="channelName",
            name="name",
            next="next"
        ),
        datastore=iotanalytics_mixins.CfnPipelinePropsMixin.DatastoreProperty(
            datastore_name="datastoreName",
            name="name"
        ),
        device_registry_enrich=iotanalytics_mixins.CfnPipelinePropsMixin.DeviceRegistryEnrichProperty(
            attribute="attribute",
            name="name",
            next="next",
            role_arn="roleArn",
            thing_name="thingName"
        ),
        device_shadow_enrich=iotanalytics_mixins.CfnPipelinePropsMixin.DeviceShadowEnrichProperty(
            attribute="attribute",
            name="name",
            next="next",
            role_arn="roleArn",
            thing_name="thingName"
        ),
        filter=iotanalytics_mixins.CfnPipelinePropsMixin.FilterProperty(
            filter="filter",
            name="name",
            next="next"
        ),
        lambda_=iotanalytics_mixins.CfnPipelinePropsMixin.LambdaProperty(
            batch_size=123,
            lambda_name="lambdaName",
            name="name",
            next="next"
        ),
        math=iotanalytics_mixins.CfnPipelinePropsMixin.MathProperty(
            attribute="attribute",
            math="math",
            name="name",
            next="next"
        ),
        remove_attributes=iotanalytics_mixins.CfnPipelinePropsMixin.RemoveAttributesProperty(
            attributes=["attributes"],
            name="name",
            next="next"
        ),
        select_attributes=iotanalytics_mixins.CfnPipelinePropsMixin.SelectAttributesProperty(
            attributes=["attributes"],
            name="name",
            next="next"
        )
    )],
    pipeline_name="pipelineName",
    tags=[CfnTag(
        key="key",
        value="value"
    )]
)

Attributes

pipeline_activities

A list of “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.

The list can be 2-25 PipelineActivity objects and must contain both a channel and a datastore activity. Each entry in the list must contain only one activity, for example:

pipelineActivities = [ { "channel": { ... } }, { "lambda": { ... } }, ... ]

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-iotanalytics-pipeline.html#cfn-iotanalytics-pipeline-pipelineactivities

pipeline_name

The name of the pipeline.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-iotanalytics-pipeline.html#cfn-iotanalytics-pipeline-pipelinename

tags

Metadata which can be used to manage the pipeline.

For more information, see Tag .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-iotanalytics-pipeline.html#cfn-iotanalytics-pipeline-tags