CfnPipeMixinProps

class aws_cdk.mixins_preview.aws_pipes.mixins.CfnPipeMixinProps(*, description=None, desired_state=None, enrichment=None, enrichment_parameters=None, kms_key_identifier=None, log_configuration=None, name=None, role_arn=None, source=None, source_parameters=None, tags=None, target=None, target_parameters=None)

Bases: object

Properties for CfnPipePropsMixin.

Parameters:

description (Optional[str]) – A description of the pipe.
desired_state (Optional[str]) – The state the pipe should be in.
enrichment (Optional[str]) – The ARN of the enrichment resource.
enrichment_parameters (Union[IResolvable, PipeEnrichmentParametersProperty, Dict[str, Any], None]) – The parameters required to set up enrichment on your pipe.
kms_key_identifier (Optional[str]) – The identifier of the AWS customer managed key for EventBridge to use, if you choose to use a customer managed key to encrypt pipe data. The identifier can be the key Amazon Resource Name (ARN), KeyId, key alias, or key alias ARN. To update a pipe that is using the default AWS owned key to use a customer managed key instead, or update a pipe that is using a customer managed key to use a different customer managed key, specify a customer managed key identifier. To update a pipe that is using a customer managed key to use the default AWS owned key , specify an empty string. For more information, see Managing keys in the AWS Key Management Service Developer Guide .
log_configuration (Union[IResolvable, PipeLogConfigurationProperty, Dict[str, Any], None]) – The logging configuration settings for the pipe.
name (Optional[str]) – The name of the pipe.
role_arn (Optional[str]) – The ARN of the role that allows the pipe to send data to the target.
source (Optional[str]) – The ARN of the source resource.
source_parameters (Union[IResolvable, PipeSourceParametersProperty, Dict[str, Any], None]) – The parameters required to set up a source for your pipe.
tags (Optional[Mapping[str, str]]) – The list of key-value pairs to associate with the pipe.
target (Optional[str]) – The ARN of the target resource.
target_parameters (Union[IResolvable, PipeTargetParametersProperty, Dict[str, Any], None]) – The parameters required to set up a target for your pipe. For more information about pipe target parameters, including how to use dynamic path parameters, see Target parameters in the Amazon EventBridge User Guide .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.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_pipes import mixins as pipes_mixins

cfn_pipe_mixin_props = pipes_mixins.CfnPipeMixinProps(
    description="description",
    desired_state="desiredState",
    enrichment="enrichment",
    enrichment_parameters=pipes_mixins.CfnPipePropsMixin.PipeEnrichmentParametersProperty(
        http_parameters=pipes_mixins.CfnPipePropsMixin.PipeEnrichmentHttpParametersProperty(
            header_parameters={
                "header_parameters_key": "headerParameters"
            },
            path_parameter_values=["pathParameterValues"],
            query_string_parameters={
                "query_string_parameters_key": "queryStringParameters"
            }
        ),
        input_template="inputTemplate"
    ),
    kms_key_identifier="kmsKeyIdentifier",
    log_configuration=pipes_mixins.CfnPipePropsMixin.PipeLogConfigurationProperty(
        cloudwatch_logs_log_destination=pipes_mixins.CfnPipePropsMixin.CloudwatchLogsLogDestinationProperty(
            log_group_arn="logGroupArn"
        ),
        firehose_log_destination=pipes_mixins.CfnPipePropsMixin.FirehoseLogDestinationProperty(
            delivery_stream_arn="deliveryStreamArn"
        ),
        include_execution_data=["includeExecutionData"],
        level="level",
        s3_log_destination=pipes_mixins.CfnPipePropsMixin.S3LogDestinationProperty(
            bucket_name="bucketName",
            bucket_owner="bucketOwner",
            output_format="outputFormat",
            prefix="prefix"
        )
    ),
    name="name",
    role_arn="roleArn",
    source="source",
    source_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceParametersProperty(
        active_mq_broker_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceActiveMQBrokerParametersProperty(
            batch_size=123,
            credentials=pipes_mixins.CfnPipePropsMixin.MQBrokerAccessCredentialsProperty(
                basic_auth="basicAuth"
            ),
            maximum_batching_window_in_seconds=123,
            queue_name="queueName"
        ),
        dynamo_db_stream_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceDynamoDBStreamParametersProperty(
            batch_size=123,
            dead_letter_config=pipes_mixins.CfnPipePropsMixin.DeadLetterConfigProperty(
                arn="arn"
            ),
            maximum_batching_window_in_seconds=123,
            maximum_record_age_in_seconds=123,
            maximum_retry_attempts=123,
            on_partial_batch_item_failure="onPartialBatchItemFailure",
            parallelization_factor=123,
            starting_position="startingPosition"
        ),
        filter_criteria=pipes_mixins.CfnPipePropsMixin.FilterCriteriaProperty(
            filters=[pipes_mixins.CfnPipePropsMixin.FilterProperty(
                pattern="pattern"
            )]
        ),
        kinesis_stream_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty(
            batch_size=123,
            dead_letter_config=pipes_mixins.CfnPipePropsMixin.DeadLetterConfigProperty(
                arn="arn"
            ),
            maximum_batching_window_in_seconds=123,
            maximum_record_age_in_seconds=123,
            maximum_retry_attempts=123,
            on_partial_batch_item_failure="onPartialBatchItemFailure",
            parallelization_factor=123,
            starting_position="startingPosition",
            starting_position_timestamp="startingPositionTimestamp"
        ),
        managed_streaming_kafka_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceManagedStreamingKafkaParametersProperty(
            batch_size=123,
            consumer_group_id="consumerGroupId",
            credentials=pipes_mixins.CfnPipePropsMixin.MSKAccessCredentialsProperty(
                client_certificate_tls_auth="clientCertificateTlsAuth",
                sasl_scram512_auth="saslScram512Auth"
            ),
            maximum_batching_window_in_seconds=123,
            starting_position="startingPosition",
            topic_name="topicName"
        ),
        rabbit_mq_broker_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceRabbitMQBrokerParametersProperty(
            batch_size=123,
            credentials=pipes_mixins.CfnPipePropsMixin.MQBrokerAccessCredentialsProperty(
                basic_auth="basicAuth"
            ),
            maximum_batching_window_in_seconds=123,
            queue_name="queueName",
            virtual_host="virtualHost"
        ),
        self_managed_kafka_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty(
            additional_bootstrap_servers=["additionalBootstrapServers"],
            batch_size=123,
            consumer_group_id="consumerGroupId",
            credentials=pipes_mixins.CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationCredentialsProperty(
                basic_auth="basicAuth",
                client_certificate_tls_auth="clientCertificateTlsAuth",
                sasl_scram256_auth="saslScram256Auth",
                sasl_scram512_auth="saslScram512Auth"
            ),
            maximum_batching_window_in_seconds=123,
            server_root_ca_certificate="serverRootCaCertificate",
            starting_position="startingPosition",
            topic_name="topicName",
            vpc=pipes_mixins.CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationVpcProperty(
                security_group=["securityGroup"],
                subnets=["subnets"]
            )
        ),
        sqs_queue_parameters=pipes_mixins.CfnPipePropsMixin.PipeSourceSqsQueueParametersProperty(
            batch_size=123,
            maximum_batching_window_in_seconds=123
        )
    ),
    tags={
        "tags_key": "tags"
    },
    target="target",
    target_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetParametersProperty(
        batch_job_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetBatchJobParametersProperty(
            array_properties=pipes_mixins.CfnPipePropsMixin.BatchArrayPropertiesProperty(
                size=123
            ),
            container_overrides=pipes_mixins.CfnPipePropsMixin.BatchContainerOverridesProperty(
                command=["command"],
                environment=[pipes_mixins.CfnPipePropsMixin.BatchEnvironmentVariableProperty(
                    name="name",
                    value="value"
                )],
                instance_type="instanceType",
                resource_requirements=[pipes_mixins.CfnPipePropsMixin.BatchResourceRequirementProperty(
                    type="type",
                    value="value"
                )]
            ),
            depends_on=[pipes_mixins.CfnPipePropsMixin.BatchJobDependencyProperty(
                job_id="jobId",
                type="type"
            )],
            job_definition="jobDefinition",
            job_name="jobName",
            parameters={
                "parameters_key": "parameters"
            },
            retry_strategy=pipes_mixins.CfnPipePropsMixin.BatchRetryStrategyProperty(
                attempts=123
            )
        ),
        cloud_watch_logs_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetCloudWatchLogsParametersProperty(
            log_stream_name="logStreamName",
            timestamp="timestamp"
        ),
        ecs_task_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetEcsTaskParametersProperty(
            capacity_provider_strategy=[pipes_mixins.CfnPipePropsMixin.CapacityProviderStrategyItemProperty(
                base=123,
                capacity_provider="capacityProvider",
                weight=123
            )],
            enable_ecs_managed_tags=False,
            enable_execute_command=False,
            group="group",
            launch_type="launchType",
            network_configuration=pipes_mixins.CfnPipePropsMixin.NetworkConfigurationProperty(
                awsvpc_configuration=pipes_mixins.CfnPipePropsMixin.AwsVpcConfigurationProperty(
                    assign_public_ip="assignPublicIp",
                    security_groups=["securityGroups"],
                    subnets=["subnets"]
                )
            ),
            overrides=pipes_mixins.CfnPipePropsMixin.EcsTaskOverrideProperty(
                container_overrides=[pipes_mixins.CfnPipePropsMixin.EcsContainerOverrideProperty(
                    command=["command"],
                    cpu=123,
                    environment=[pipes_mixins.CfnPipePropsMixin.EcsEnvironmentVariableProperty(
                        name="name",
                        value="value"
                    )],
                    environment_files=[pipes_mixins.CfnPipePropsMixin.EcsEnvironmentFileProperty(
                        type="type",
                        value="value"
                    )],
                    memory=123,
                    memory_reservation=123,
                    name="name",
                    resource_requirements=[pipes_mixins.CfnPipePropsMixin.EcsResourceRequirementProperty(
                        type="type",
                        value="value"
                    )]
                )],
                cpu="cpu",
                ephemeral_storage=pipes_mixins.CfnPipePropsMixin.EcsEphemeralStorageProperty(
                    size_in_gi_b=123
                ),
                execution_role_arn="executionRoleArn",
                inference_accelerator_overrides=[pipes_mixins.CfnPipePropsMixin.EcsInferenceAcceleratorOverrideProperty(
                    device_name="deviceName",
                    device_type="deviceType"
                )],
                memory="memory",
                task_role_arn="taskRoleArn"
            ),
            placement_constraints=[pipes_mixins.CfnPipePropsMixin.PlacementConstraintProperty(
                expression="expression",
                type="type"
            )],
            placement_strategy=[pipes_mixins.CfnPipePropsMixin.PlacementStrategyProperty(
                field="field",
                type="type"
            )],
            platform_version="platformVersion",
            propagate_tags="propagateTags",
            reference_id="referenceId",
            tags=[CfnTag(
                key="key",
                value="value"
            )],
            task_count=123,
            task_definition_arn="taskDefinitionArn"
        ),
        event_bridge_event_bus_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetEventBridgeEventBusParametersProperty(
            detail_type="detailType",
            endpoint_id="endpointId",
            resources=["resources"],
            source="source",
            time="time"
        ),
        http_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetHttpParametersProperty(
            header_parameters={
                "header_parameters_key": "headerParameters"
            },
            path_parameter_values=["pathParameterValues"],
            query_string_parameters={
                "query_string_parameters_key": "queryStringParameters"
            }
        ),
        input_template="inputTemplate",
        kinesis_stream_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetKinesisStreamParametersProperty(
            partition_key="partitionKey"
        ),
        lambda_function_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetLambdaFunctionParametersProperty(
            invocation_type="invocationType"
        ),
        redshift_data_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetRedshiftDataParametersProperty(
            database="database",
            db_user="dbUser",
            secret_manager_arn="secretManagerArn",
            sqls=["sqls"],
            statement_name="statementName",
            with_event=False
        ),
        sage_maker_pipeline_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetSageMakerPipelineParametersProperty(
            pipeline_parameter_list=[pipes_mixins.CfnPipePropsMixin.SageMakerPipelineParameterProperty(
                name="name",
                value="value"
            )]
        ),
        sqs_queue_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetSqsQueueParametersProperty(
            message_deduplication_id="messageDeduplicationId",
            message_group_id="messageGroupId"
        ),
        step_function_state_machine_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetStateMachineParametersProperty(
            invocation_type="invocationType"
        ),
        timestream_parameters=pipes_mixins.CfnPipePropsMixin.PipeTargetTimestreamParametersProperty(
            dimension_mappings=[pipes_mixins.CfnPipePropsMixin.DimensionMappingProperty(
                dimension_name="dimensionName",
                dimension_value="dimensionValue",
                dimension_value_type="dimensionValueType"
            )],
            epoch_time_unit="epochTimeUnit",
            multi_measure_mappings=[pipes_mixins.CfnPipePropsMixin.MultiMeasureMappingProperty(
                multi_measure_attribute_mappings=[pipes_mixins.CfnPipePropsMixin.MultiMeasureAttributeMappingProperty(
                    measure_value="measureValue",
                    measure_value_type="measureValueType",
                    multi_measure_attribute_name="multiMeasureAttributeName"
                )],
                multi_measure_name="multiMeasureName"
            )],
            single_measure_mappings=[pipes_mixins.CfnPipePropsMixin.SingleMeasureMappingProperty(
                measure_name="measureName",
                measure_value="measureValue",
                measure_value_type="measureValueType"
            )],
            time_field_type="timeFieldType",
            timestamp_format="timestampFormat",
            time_value="timeValue",
            version_value="versionValue"
        )
    )
)

Attributes

description

A description of the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-description

desired_state

The state the pipe should be in.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-desiredstate

enrichment

The ARN of the enrichment resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-enrichment

enrichment_parameters

The parameters required to set up enrichment on your pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-enrichmentparameters

kms_key_identifier

The identifier of the AWS customer managed key for EventBridge to use, if you choose to use a customer managed key to encrypt pipe data.

The identifier can be the key Amazon Resource Name (ARN), KeyId, key alias, or key alias ARN.

To update a pipe that is using the default AWS owned key to use a customer managed key instead, or update a pipe that is using a customer managed key to use a different customer managed key, specify a customer managed key identifier.

To update a pipe that is using a customer managed key to use the default AWS owned key , specify an empty string.

For more information, see Managing keys in the AWS Key Management Service Developer Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-kmskeyidentifier

log_configuration

The logging configuration settings for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-logconfiguration

name

The name of the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-name

role_arn

The ARN of the role that allows the pipe to send data to the target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-rolearn

source

The ARN of the source resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-source

source_parameters

The parameters required to set up a source for your pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-sourceparameters

tags

The list of key-value pairs to associate with the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-tags

target

The ARN of the target resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-target

target_parameters

The parameters required to set up a target for your pipe.

For more information about pipe target parameters, including how to use dynamic path parameters, see Target parameters in the Amazon EventBridge User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html#cfn-pipes-pipe-targetparameters