CfnDataIntegrationFlowProps

class aws_cdk.aws_scn.CfnDataIntegrationFlowProps(*, instance_id, name, sources, target, transformation, tags=None)

Bases: object

Properties for defining a CfnDataIntegrationFlow.

Parameters:

instance_id (str) – The Amazon Web Services Supply Chain instance identifier.
name (str) – The name of the DataIntegrationFlow.
sources (Union[IResolvable, Sequence[Union[IResolvable, DataIntegrationFlowSourceProperty, Dict[str, Any]]]]) – The source configurations for the DataIntegrationFlow.
target (Union[IResolvable, DataIntegrationFlowTargetProperty, Dict[str, Any]]) – The DataIntegrationFlow target parameters.
transformation (Union[IResolvable, DataIntegrationFlowTransformationProperty, Dict[str, Any]]) – The DataIntegrationFlow transformation parameters.
tags (Optional[Sequence[Union[CfnTag, Dict[str, Any]]]]) – The tags for the DataIntegrationFlow.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-scn-dataintegrationflow.html

ExampleMetadata:

fixture=_generated

Example:

from aws_cdk import CfnTag
# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk import aws_scn as scn

cfn_data_integration_flow_props = scn.CfnDataIntegrationFlowProps(
    instance_id="instanceId",
    name="name",
    sources=[scn.CfnDataIntegrationFlow.DataIntegrationFlowSourceProperty(
        source_name="sourceName",
        source_type="sourceType",

        # the properties below are optional
        dataset_source=scn.CfnDataIntegrationFlow.DatasetSourceConfigurationProperty(
            dataset_identifier="datasetIdentifier",

            # the properties below are optional
            options=scn.CfnDataIntegrationFlow.DatasetOptionsProperty(
                dedupe_records=False,
                dedupe_strategy=scn.CfnDataIntegrationFlow.DedupeStrategyProperty(
                    type="type",

                    # the properties below are optional
                    field_priority=scn.CfnDataIntegrationFlow.FieldPriorityDedupeStrategyConfigurationProperty(
                        fields=[scn.CfnDataIntegrationFlow.FieldPriorityDedupeFieldProperty(
                            name="name",
                            sort_order="sortOrder"
                        )]
                    )
                ),
                load_type="loadType"
            )
        ),
        s3_source=scn.CfnDataIntegrationFlow.S3SourceConfigurationProperty(
            bucket_name="bucketName",
            prefix="prefix",

            # the properties below are optional
            options=scn.CfnDataIntegrationFlow.S3OptionsProperty(
                file_type="fileType"
            )
        )
    )],
    target=scn.CfnDataIntegrationFlow.DataIntegrationFlowTargetProperty(
        target_type="targetType",

        # the properties below are optional
        dataset_target=scn.CfnDataIntegrationFlow.DatasetTargetConfigurationProperty(
            dataset_identifier="datasetIdentifier",

            # the properties below are optional
            options=scn.CfnDataIntegrationFlow.DatasetOptionsProperty(
                dedupe_records=False,
                dedupe_strategy=scn.CfnDataIntegrationFlow.DedupeStrategyProperty(
                    type="type",

                    # the properties below are optional
                    field_priority=scn.CfnDataIntegrationFlow.FieldPriorityDedupeStrategyConfigurationProperty(
                        fields=[scn.CfnDataIntegrationFlow.FieldPriorityDedupeFieldProperty(
                            name="name",
                            sort_order="sortOrder"
                        )]
                    )
                ),
                load_type="loadType"
            )
        )
    ),
    transformation=scn.CfnDataIntegrationFlow.DataIntegrationFlowTransformationProperty(
        transformation_type="transformationType",

        # the properties below are optional
        sql_transformation=scn.CfnDataIntegrationFlow.SqlTransformationConfigurationProperty(
            query="query"
        )
    ),

    # the properties below are optional
    tags=[CfnTag(
        key="key",
        value="value"
    )]
)