CfnPipePropsMixin

class aws_cdk.mixins_preview.aws_pipes.mixins.CfnPipePropsMixin(props, *, strategy=None)

Bases: Mixin

Specifies a pipe.

Amazon EventBridge Pipes connect event sources to targets and reduces the need for specialized knowledge and integration code. .. epigraph:

As an aid to help you jumpstart developing CloudFormation templates, the EventBridge console enables you to create templates from the existing pipes in your account. For more information, see `Generate an CloudFormation template from EventBridge Pipes <https://docs.aws.amazon.com/eventbridge/latest/userguide/pipes-generate-template.html>`_ in the *Amazon EventBridge User Guide* .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html
CloudformationResource:: AWS::Pipes::Pipe
Mixin:: true
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 import mixins
from aws_cdk.mixins_preview.aws_pipes import mixins as pipes_mixins

cfn_pipe_props_mixin = pipes_mixins.CfnPipePropsMixin(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"
        )
    )
),
    strategy=mixins.PropertyMergeStrategy.OVERRIDE
)

Create a mixin to apply properties to AWS::Pipes::Pipe.

Parameters:

props (Union[CfnPipeMixinProps, Dict[str, Any]]) – L1 properties to apply.
strategy (Optional[PropertyMergeStrategy]) – (experimental) Strategy for merging nested properties. Default: - PropertyMergeStrategy.MERGE

Methods

apply_to(construct)

Apply the mixin properties to the construct.

Parameters:: construct (IConstruct)
Return type:: IConstruct

supports(construct)

Check if this mixin supports the given construct.

Parameters:: construct (IConstruct)
Return type:: bool

Attributes

CFN_PROPERTY_KEYS = ['description', 'desiredState', 'enrichment', 'enrichmentParameters', 'kmsKeyIdentifier', 'logConfiguration', 'name', 'roleArn', 'source', 'sourceParameters', 'tags', 'target', 'targetParameters']

Static Methods

classmethod is_mixin(x)

(experimental) Checks if x is a Mixin.

Parameters:: x (Any) – Any object.
Return type:: bool
Returns:: true if x is an object created from a class which extends Mixin.
Stability:: experimental

AwsVpcConfigurationProperty

class CfnPipePropsMixin.AwsVpcConfigurationProperty(*, assign_public_ip=None, security_groups=None, subnets=None)

Bases: object

This structure specifies the VPC subnets and security groups for the task, and whether a public IP address is to be used.

This structure is relevant only for ECS tasks that use the awsvpc network mode.

Parameters:

assign_public_ip (Optional[str]) – Specifies whether the task’s elastic network interface receives a public IP address. You can specify ENABLED only when LaunchType in EcsParameters is set to FARGATE .
security_groups (Optional[Sequence[str]]) – Specifies the security groups associated with the task. These security groups must all be in the same VPC. You can specify as many as five security groups. If you do not specify a security group, the default security group for the VPC is used.
subnets (Optional[Sequence[str]]) – Specifies the subnets associated with the task. These subnets must all be in the same VPC. You can specify as many as 16 subnets.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-awsvpcconfiguration.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

aws_vpc_configuration_property = pipes_mixins.CfnPipePropsMixin.AwsVpcConfigurationProperty(
    assign_public_ip="assignPublicIp",
    security_groups=["securityGroups"],
    subnets=["subnets"]
)

Attributes

assign_public_ip

Specifies whether the task’s elastic network interface receives a public IP address.

You can specify ENABLED only when LaunchType in EcsParameters is set to FARGATE .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-awsvpcconfiguration.html#cfn-pipes-pipe-awsvpcconfiguration-assignpublicip

security_groups

Specifies the security groups associated with the task.

These security groups must all be in the same VPC. You can specify as many as five security groups. If you do not specify a security group, the default security group for the VPC is used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-awsvpcconfiguration.html#cfn-pipes-pipe-awsvpcconfiguration-securitygroups

subnets

Specifies the subnets associated with the task.

These subnets must all be in the same VPC. You can specify as many as 16 subnets.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-awsvpcconfiguration.html#cfn-pipes-pipe-awsvpcconfiguration-subnets

BatchArrayPropertiesProperty

class CfnPipePropsMixin.BatchArrayPropertiesProperty(*, size=None)

Bases: object

The array properties for the submitted job, such as the size of the array.

The array size can be between 2 and 10,000. If you specify array properties for a job, it becomes an array job. This parameter is used only if the target is an AWS Batch job.

Parameters:: size (Union[int, float, None]) – The size of the array, if this is an array batch job. Default: - 0
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batcharrayproperties.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

batch_array_properties_property = pipes_mixins.CfnPipePropsMixin.BatchArrayPropertiesProperty(
    size=123
)

Attributes

size

The size of the array, if this is an array batch job.

Default:

0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batcharrayproperties.html#cfn-pipes-pipe-batcharrayproperties-size

BatchContainerOverridesProperty

class CfnPipePropsMixin.BatchContainerOverridesProperty(*, command=None, environment=None, instance_type=None, resource_requirements=None)

Bases: object

The overrides that are sent to a container.

Parameters:

command (Optional[Sequence[str]]) – The command to send to the container that overrides the default command from the Docker image or the task definition.
environment (Union[IResolvable, Sequence[Union[IResolvable, BatchEnvironmentVariableProperty, Dict[str, Any]]], None]) – The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. .. epigraph:: Environment variables cannot start with “ AWS Batch “. This naming convention is reserved for variables that AWS Batch sets.
instance_type (Optional[str]) – The instance type to use for a multi-node parallel job. .. epigraph:: This parameter isn’t applicable to single-node container jobs or jobs that run on Fargate resources, and shouldn’t be provided.
resource_requirements (Union[IResolvable, Sequence[Union[IResolvable, BatchResourceRequirementProperty, Dict[str, Any]]], None]) – The type and amount of resources to assign to a container. This overrides the settings in the job definition. The supported resources include GPU , MEMORY , and VCPU .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.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

batch_container_overrides_property = 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"
    )]
)

Attributes

command

The command to send to the container that overrides the default command from the Docker image or the task definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.html#cfn-pipes-pipe-batchcontaineroverrides-command

environment

The environment variables to send to the container.

You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. .. epigraph:

Environment variables cannot start with " ``AWS Batch`` ". This naming convention is reserved for variables that AWS Batch sets.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.html#cfn-pipes-pipe-batchcontaineroverrides-environment

instance_type

The instance type to use for a multi-node parallel job.

This parameter isn’t applicable to single-node container jobs or jobs that run on Fargate resources, and shouldn’t be provided.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.html#cfn-pipes-pipe-batchcontaineroverrides-instancetype

resource_requirements

The type and amount of resources to assign to a container.

This overrides the settings in the job definition. The supported resources include GPU , MEMORY , and VCPU .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.html#cfn-pipes-pipe-batchcontaineroverrides-resourcerequirements

BatchEnvironmentVariableProperty

class CfnPipePropsMixin.BatchEnvironmentVariableProperty(*, name=None, value=None)

Bases: object

The environment variables to send to the container.

You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. .. epigraph:

Environment variables cannot start with " ``AWS Batch`` ". This naming convention is reserved for variables that AWS Batch sets.

Parameters:

name (Optional[str]) – The name of the key-value pair. For environment variables, this is the name of the environment variable.
value (Optional[str]) – The value of the key-value pair. For environment variables, this is the value of the environment variable.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchenvironmentvariable.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

batch_environment_variable_property = pipes_mixins.CfnPipePropsMixin.BatchEnvironmentVariableProperty(
    name="name",
    value="value"
)

Attributes

name

The name of the key-value pair.

For environment variables, this is the name of the environment variable.

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

value

The value of the key-value pair.

For environment variables, this is the value of the environment variable.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchenvironmentvariable.html#cfn-pipes-pipe-batchenvironmentvariable-value

BatchJobDependencyProperty

class CfnPipePropsMixin.BatchJobDependencyProperty(*, job_id=None, type=None)

Bases: object

An object that represents an AWS Batch job dependency.

Parameters:

job_id (Optional[str]) – The job ID of the AWS Batch job that’s associated with this dependency.
type (Optional[str]) – The type of the job dependency.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchjobdependency.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

batch_job_dependency_property = pipes_mixins.CfnPipePropsMixin.BatchJobDependencyProperty(
    job_id="jobId",
    type="type"
)

Attributes

job_id

The job ID of the AWS Batch job that’s associated with this dependency.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchjobdependency.html#cfn-pipes-pipe-batchjobdependency-jobid

type

The type of the job dependency.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchjobdependency.html#cfn-pipes-pipe-batchjobdependency-type

BatchResourceRequirementProperty

class CfnPipePropsMixin.BatchResourceRequirementProperty(*, type=None, value=None)

Bases: object

The type and amount of a resource to assign to a container.

The supported resources include GPU , MEMORY , and VCPU .

Parameters:

type (Optional[str]) – The type of resource to assign to a container. The supported resources include GPU , MEMORY , and VCPU .
value (Optional[str]) –
The quantity of the specified resource to reserve for the container. The values vary based on the type specified. - type=”GPU” - The number of physical GPUs to reserve for the container. Make sure that the number of GPUs reserved for all containers in a job doesn’t exceed the number of available GPUs on the compute resource that the job is launched on. .. epigraph:: GPUs aren’t available for jobs that are running on Fargate resources. - type=”MEMORY” - The memory hard limit (in MiB) present to the container. This parameter is supported for jobs that are running on EC2 resources. If your container attempts to exceed the memory specified, the container is terminated. This parameter maps to Memory in the Create a container section of the Docker Remote API and the --memory option to docker run . You must specify at least 4 MiB of memory for a job. This is required but can be specified in several places for multi-node parallel (MNP) jobs. It must be specified for each node at least once. This parameter maps to Memory in the Create a container section of the Docker Remote API and the --memory option to docker run . .. epigraph:: If you’re trying to maximize your resource utilization by providing your jobs as much memory as possible for a particular instance type, see Memory management in the AWS Batch User Guide . For jobs that are running on Fargate resources, then value is the hard limit (in MiB), and must match one of the supported values and the VCPU values must be one of the values supported for that memory value. - value = 512 - VCPU = 0.25 - value = 1024 - VCPU = 0.25 or 0.5 - value = 2048 - VCPU = 0.25, 0.5, or 1 - value = 3072 - VCPU = 0.5, or 1 - value = 4096 - VCPU = 0.5, 1, or 2 - value = 5120, 6144, or 7168 - VCPU = 1 or 2 - value = 8192 - VCPU = 1, 2, 4, or 8 - value = 9216, 10240, 11264, 12288, 13312, 14336, or 15360 - VCPU = 2 or 4 - value = 16384 - VCPU = 2, 4, or 8 - value = 17408, 18432, 19456, 21504, 22528, 23552, 25600, 26624, 27648, 29696, or 30720 - VCPU = 4 - value = 20480, 24576, or 28672 - VCPU = 4 or 8 - value = 36864, 45056, 53248, or 61440 - VCPU = 8 - value = 32768, 40960, 49152, or 57344 - VCPU = 8 or 16 - value = 65536, 73728, 81920, 90112, 98304, 106496, 114688, or 122880 - VCPU = 16 - type=”VCPU” - The number of vCPUs reserved for the container. This parameter maps to CpuShares in the Create a container section of the Docker Remote API and the --cpu-shares option to docker run . Each vCPU is equivalent to 1,024 CPU shares. For EC2 resources, you must specify at least one vCPU. This is required but can be specified in several places; it must be specified for each node at least once. The default for the Fargate On-Demand vCPU resource count quota is 6 vCPUs. For more information about Fargate quotas, see AWS Fargate quotas in the AWS General Reference . For jobs that are running on Fargate resources, then value must match one of the supported values and the MEMORY values must be one of the values supported for that VCPU value. The supported values are 0.25, 0.5, 1, 2, 4, 8, and 16 - value = 0.25 - MEMORY = 512, 1024, or 2048 - value = 0.5 - MEMORY = 1024, 2048, 3072, or 4096 - value = 1 - MEMORY = 2048, 3072, 4096, 5120, 6144, 7168, or 8192 - value = 2 - MEMORY = 4096, 5120, 6144, 7168, 8192, 9216, 10240, 11264, 12288, 13312, 14336, 15360, or 16384 - value = 4 - MEMORY = 8192, 9216, 10240, 11264, 12288, 13312, 14336, 15360, 16384, 17408, 18432, 19456, 20480, 21504, 22528, 23552, 24576, 25600, 26624, 27648, 28672, 29696, or 30720 - value = 8 - MEMORY = 16384, 20480, 24576, 28672, 32768, 36864, 40960, 45056, 49152, 53248, 57344, or 61440 - value = 16 - MEMORY = 32768, 40960, 49152, 57344, 65536, 73728, 81920, 90112, 98304, 106496, 114688, or 122880

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchresourcerequirement.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

batch_resource_requirement_property = pipes_mixins.CfnPipePropsMixin.BatchResourceRequirementProperty(
    type="type",
    value="value"
)

Attributes

type

The type of resource to assign to a container.

The supported resources include GPU , MEMORY , and VCPU .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchresourcerequirement.html#cfn-pipes-pipe-batchresourcerequirement-type

value

The quantity of the specified resource to reserve for the container. The values vary based on the type specified.

type=”GPU” - The number of physical GPUs to reserve for the container. Make sure that the number of GPUs reserved for all containers in a job doesn’t exceed the number of available GPUs on the compute resource that the job is launched on.

GPUs aren’t available for jobs that are running on Fargate resources.

type=”MEMORY” - The memory hard limit (in MiB) present to the container. This parameter is supported for jobs that are running on EC2 resources. If your container attempts to exceed the memory specified, the container is terminated. This parameter maps to Memory in the Create a container section of the Docker Remote API and the --memory option to docker run . You must specify at least 4 MiB of memory for a job. This is required but can be specified in several places for multi-node parallel (MNP) jobs. It must be specified for each node at least once. This parameter maps to Memory in the Create a container section of the Docker Remote API and the --memory option to docker run .

If you’re trying to maximize your resource utilization by providing your jobs as much memory as possible for a particular instance type, see Memory management in the AWS Batch User Guide .

For jobs that are running on Fargate resources, then value is the hard limit (in MiB), and must match one of the supported values and the VCPU values must be one of the values supported for that memory value.

value = 512 - VCPU = 0.25
value = 1024 - VCPU = 0.25 or 0.5
value = 2048 - VCPU = 0.25, 0.5, or 1
value = 3072 - VCPU = 0.5, or 1
value = 4096 - VCPU = 0.5, 1, or 2
value = 5120, 6144, or 7168 - VCPU = 1 or 2
value = 8192 - VCPU = 1, 2, 4, or 8
value = 9216, 10240, 11264, 12288, 13312, 14336, or 15360 - VCPU = 2 or 4
value = 16384 - VCPU = 2, 4, or 8
value = 17408, 18432, 19456, 21504, 22528, 23552, 25600, 26624, 27648, 29696, or 30720 - VCPU = 4
value = 20480, 24576, or 28672 - VCPU = 4 or 8
value = 36864, 45056, 53248, or 61440 - VCPU = 8
value = 32768, 40960, 49152, or 57344 - VCPU = 8 or 16
value = 65536, 73728, 81920, 90112, 98304, 106496, 114688, or 122880 - VCPU = 16
type=”VCPU” - The number of vCPUs reserved for the container. This parameter maps to CpuShares in the Create a container section of the Docker Remote API and the --cpu-shares option to docker run . Each vCPU is equivalent to 1,024 CPU shares. For EC2 resources, you must specify at least one vCPU. This is required but can be specified in several places; it must be specified for each node at least once.

The default for the Fargate On-Demand vCPU resource count quota is 6 vCPUs. For more information about Fargate quotas, see AWS Fargate quotas in the AWS General Reference .

For jobs that are running on Fargate resources, then value must match one of the supported values and the MEMORY values must be one of the values supported for that VCPU value. The supported values are 0.25, 0.5, 1, 2, 4, 8, and 16

value = 0.25 - MEMORY = 512, 1024, or 2048
value = 0.5 - MEMORY = 1024, 2048, 3072, or 4096
value = 1 - MEMORY = 2048, 3072, 4096, 5120, 6144, 7168, or 8192
value = 2 - MEMORY = 4096, 5120, 6144, 7168, 8192, 9216, 10240, 11264, 12288, 13312, 14336, 15360, or 16384
value = 4 - MEMORY = 8192, 9216, 10240, 11264, 12288, 13312, 14336, 15360, 16384, 17408, 18432, 19456, 20480, 21504, 22528, 23552, 24576, 25600, 26624, 27648, 28672, 29696, or 30720
value = 8 - MEMORY = 16384, 20480, 24576, 28672, 32768, 36864, 40960, 45056, 49152, 53248, 57344, or 61440
value = 16 - MEMORY = 32768, 40960, 49152, 57344, 65536, 73728, 81920, 90112, 98304, 106496, 114688, or 122880

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchresourcerequirement.html#cfn-pipes-pipe-batchresourcerequirement-value

BatchRetryStrategyProperty

class CfnPipePropsMixin.BatchRetryStrategyProperty(*, attempts=None)

Bases: object

The retry strategy that’s associated with a job.

For more information, see Automated job retries in the AWS Batch User Guide .

Parameters:: attempts (Union[int, float, None]) – The number of times to move a job to the RUNNABLE status. If the value of attempts is greater than one, the job is retried on failure the same number of attempts as the value. Default: - 0
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchretrystrategy.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

batch_retry_strategy_property = pipes_mixins.CfnPipePropsMixin.BatchRetryStrategyProperty(
    attempts=123
)

Attributes

attempts

The number of times to move a job to the RUNNABLE status.

If the value of attempts is greater than one, the job is retried on failure the same number of attempts as the value.

Default:

0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchretrystrategy.html#cfn-pipes-pipe-batchretrystrategy-attempts

CapacityProviderStrategyItemProperty

class CfnPipePropsMixin.CapacityProviderStrategyItemProperty(*, base=None, capacity_provider=None, weight=None)

Bases: object

The details of a capacity provider strategy.

To learn more, see CapacityProviderStrategyItem in the Amazon ECS API Reference.

Parameters:

base (Union[int, float, None]) – The base value designates how many tasks, at a minimum, to run on the specified capacity provider. Only one capacity provider in a capacity provider strategy can have a base defined. If no value is specified, the default value of 0 is used. Default: - 0
capacity_provider (Optional[str]) – The short name of the capacity provider.
weight (Union[int, float, None]) – The weight value designates the relative percentage of the total number of tasks launched that should use the specified capacity provider. The weight value is taken into consideration after the base value, if defined, is satisfied. Default: - 0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-capacityproviderstrategyitem.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

capacity_provider_strategy_item_property = pipes_mixins.CfnPipePropsMixin.CapacityProviderStrategyItemProperty(
    base=123,
    capacity_provider="capacityProvider",
    weight=123
)

Attributes

base

The base value designates how many tasks, at a minimum, to run on the specified capacity provider.

Only one capacity provider in a capacity provider strategy can have a base defined. If no value is specified, the default value of 0 is used.

Default:

0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-capacityproviderstrategyitem.html#cfn-pipes-pipe-capacityproviderstrategyitem-base

capacity_provider

The short name of the capacity provider.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-capacityproviderstrategyitem.html#cfn-pipes-pipe-capacityproviderstrategyitem-capacityprovider

weight

The weight value designates the relative percentage of the total number of tasks launched that should use the specified capacity provider.

The weight value is taken into consideration after the base value, if defined, is satisfied.

Default:

0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-capacityproviderstrategyitem.html#cfn-pipes-pipe-capacityproviderstrategyitem-weight

CloudwatchLogsLogDestinationProperty

class CfnPipePropsMixin.CloudwatchLogsLogDestinationProperty(*, log_group_arn=None)

Bases: object

Represents the Amazon CloudWatch Logs logging configuration settings for the pipe.

Parameters:: log_group_arn (Optional[str]) – The AWS Resource Name (ARN) for the CloudWatch log group to which EventBridge sends the log records.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-cloudwatchlogslogdestination.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

cloudwatch_logs_log_destination_property = pipes_mixins.CfnPipePropsMixin.CloudwatchLogsLogDestinationProperty(
    log_group_arn="logGroupArn"
)

Attributes

log_group_arn

The AWS Resource Name (ARN) for the CloudWatch log group to which EventBridge sends the log records.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-cloudwatchlogslogdestination.html#cfn-pipes-pipe-cloudwatchlogslogdestination-loggrouparn

DeadLetterConfigProperty

class CfnPipePropsMixin.DeadLetterConfigProperty(*, arn=None)

Bases: object

A DeadLetterConfig object that contains information about a dead-letter queue configuration.

Parameters:: arn (Optional[str]) – The ARN of the specified target for the dead-letter queue. For Amazon Kinesis stream and Amazon DynamoDB stream sources, specify either an Amazon SNS topic or Amazon SQS queue ARN.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-deadletterconfig.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

dead_letter_config_property = pipes_mixins.CfnPipePropsMixin.DeadLetterConfigProperty(
    arn="arn"
)

Attributes

arn

The ARN of the specified target for the dead-letter queue.

For Amazon Kinesis stream and Amazon DynamoDB stream sources, specify either an Amazon SNS topic or Amazon SQS queue ARN.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-deadletterconfig.html#cfn-pipes-pipe-deadletterconfig-arn

DimensionMappingProperty

class CfnPipePropsMixin.DimensionMappingProperty(*, dimension_name=None, dimension_value=None, dimension_value_type=None)

Bases: object

Maps source data to a dimension in the target Timestream for LiveAnalytics table.

For more information, see Amazon Timestream for LiveAnalytics concepts

Parameters:

dimension_name (Optional[str]) – The metadata attributes of the time series. For example, the name and Availability Zone of an Amazon EC2 instance or the name of the manufacturer of a wind turbine are dimensions.
dimension_value (Optional[str]) – Dynamic path to the dimension value in the source event.
dimension_value_type (Optional[str]) – The data type of the dimension for the time-series data.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-dimensionmapping.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

dimension_mapping_property = pipes_mixins.CfnPipePropsMixin.DimensionMappingProperty(
    dimension_name="dimensionName",
    dimension_value="dimensionValue",
    dimension_value_type="dimensionValueType"
)

Attributes

dimension_name

The metadata attributes of the time series.

For example, the name and Availability Zone of an Amazon EC2 instance or the name of the manufacturer of a wind turbine are dimensions.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-dimensionmapping.html#cfn-pipes-pipe-dimensionmapping-dimensionname

dimension_value

Dynamic path to the dimension value in the source event.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-dimensionmapping.html#cfn-pipes-pipe-dimensionmapping-dimensionvalue

dimension_value_type

The data type of the dimension for the time-series data.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-dimensionmapping.html#cfn-pipes-pipe-dimensionmapping-dimensionvaluetype

EcsContainerOverrideProperty

class CfnPipePropsMixin.EcsContainerOverrideProperty(*, command=None, cpu=None, environment=None, environment_files=None, memory=None, memory_reservation=None, name=None, resource_requirements=None)

Bases: object

The overrides that are sent to a container.

An empty container override can be passed in. An example of an empty container override is {"containerOverrides": [ ] } . If a non-empty container override is specified, the name parameter must be included.

Parameters:

command (Optional[Sequence[str]]) – The command to send to the container that overrides the default command from the Docker image or the task definition. You must also specify a container name.
cpu (Union[int, float, None]) – The number of cpu units reserved for the container, instead of the default value from the task definition. You must also specify a container name.
environment (Union[IResolvable, Sequence[Union[IResolvable, EcsEnvironmentVariableProperty, Dict[str, Any]]], None]) – The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. You must also specify a container name.
environment_files (Union[IResolvable, Sequence[Union[IResolvable, EcsEnvironmentFileProperty, Dict[str, Any]]], None]) – A list of files containing the environment variables to pass to a container, instead of the value from the container definition.
memory (Union[int, float, None]) – The hard limit (in MiB) of memory to present to the container, instead of the default value from the task definition. If your container attempts to exceed the memory specified here, the container is killed. You must also specify a container name.
memory_reservation (Union[int, float, None]) – The soft limit (in MiB) of memory to reserve for the container, instead of the default value from the task definition. You must also specify a container name.
name (Optional[str]) – The name of the container that receives the override. This parameter is required if any override is specified.
resource_requirements (Union[IResolvable, Sequence[Union[IResolvable, EcsResourceRequirementProperty, Dict[str, Any]]], None]) – The type and amount of a resource to assign to a container, instead of the default value from the task definition. The only supported resource is a GPU.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.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

ecs_container_override_property = 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"
    )]
)

Attributes

command

The command to send to the container that overrides the default command from the Docker image or the task definition.

You must also specify a container name.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-command

cpu

The number of cpu units reserved for the container, instead of the default value from the task definition.

You must also specify a container name.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-cpu

environment

The environment variables to send to the container.

You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. You must also specify a container name.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-environment

environment_files

A list of files containing the environment variables to pass to a container, instead of the value from the container definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-environmentfiles

memory

The hard limit (in MiB) of memory to present to the container, instead of the default value from the task definition.

If your container attempts to exceed the memory specified here, the container is killed. You must also specify a container name.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-memory

memory_reservation

The soft limit (in MiB) of memory to reserve for the container, instead of the default value from the task definition.

You must also specify a container name.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-memoryreservation

name

The name of the container that receives the override.

This parameter is required if any override is specified.

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

resource_requirements

The type and amount of a resource to assign to a container, instead of the default value from the task definition.

The only supported resource is a GPU.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html#cfn-pipes-pipe-ecscontaineroverride-resourcerequirements

EcsEnvironmentFileProperty

class CfnPipePropsMixin.EcsEnvironmentFileProperty(*, type=None, value=None)

Bases: object

A list of files containing the environment variables to pass to a container.

You can specify up to ten environment files. The file must have a .env file extension. Each line in an environment file should contain an environment variable in VARIABLE=VALUE format. Lines beginning with # are treated as comments and are ignored. For more information about the environment variable file syntax, see Declare default environment variables in file .

If there are environment variables specified using the environment parameter in a container definition, they take precedence over the variables contained within an environment file. If multiple environment files are specified that contain the same variable, they’re processed from the top down. We recommend that you use unique variable names. For more information, see Specifying environment variables in the Amazon Elastic Container Service Developer Guide .

This parameter is only supported for tasks hosted on Fargate using the following platform versions:

Linux platform version 1.4.0 or later.
Windows platform version 1.0.0 or later.

Parameters:

type (Optional[str]) – The file type to use. The only supported value is s3 .
value (Optional[str]) – The Amazon Resource Name (ARN) of the Amazon S3 object containing the environment variable file.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentfile.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

ecs_environment_file_property = pipes_mixins.CfnPipePropsMixin.EcsEnvironmentFileProperty(
    type="type",
    value="value"
)

Attributes

type

The file type to use.

The only supported value is s3 .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentfile.html#cfn-pipes-pipe-ecsenvironmentfile-type

value

The Amazon Resource Name (ARN) of the Amazon S3 object containing the environment variable file.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentfile.html#cfn-pipes-pipe-ecsenvironmentfile-value

EcsEnvironmentVariableProperty

class CfnPipePropsMixin.EcsEnvironmentVariableProperty(*, name=None, value=None)

Bases: object

The environment variables to send to the container.

You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. You must also specify a container name.

Parameters:

name (Optional[str]) – The name of the key-value pair. For environment variables, this is the name of the environment variable.
value (Optional[str]) – The value of the key-value pair. For environment variables, this is the value of the environment variable.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentvariable.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

ecs_environment_variable_property = pipes_mixins.CfnPipePropsMixin.EcsEnvironmentVariableProperty(
    name="name",
    value="value"
)

Attributes

name

The name of the key-value pair.

For environment variables, this is the name of the environment variable.

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

value

The value of the key-value pair.

For environment variables, this is the value of the environment variable.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentvariable.html#cfn-pipes-pipe-ecsenvironmentvariable-value

EcsEphemeralStorageProperty

class CfnPipePropsMixin.EcsEphemeralStorageProperty(*, size_in_gib=None)

Bases: object

The amount of ephemeral storage to allocate for the task.

This parameter is used to expand the total amount of ephemeral storage available, beyond the default amount, for tasks hosted on Fargate. For more information, see Fargate task storage in the Amazon ECS User Guide for Fargate . .. epigraph:

This parameter is only supported for tasks hosted on Fargate using Linux platform version ``1.4.0`` or later. This parameter is not supported for Windows containers on Fargate.

Parameters:: size_in_gib (Union[int, float, None]) – The total amount, in GiB, of ephemeral storage to set for the task. The minimum supported value is 21 GiB and the maximum supported value is 200 GiB. Default: - 0
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsephemeralstorage.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

ecs_ephemeral_storage_property = pipes_mixins.CfnPipePropsMixin.EcsEphemeralStorageProperty(
    size_in_gi_b=123
)

Attributes

size_in_gib

The total amount, in GiB, of ephemeral storage to set for the task.

The minimum supported value is 21 GiB and the maximum supported value is 200 GiB.

Default:

0

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsephemeralstorage.html#cfn-pipes-pipe-ecsephemeralstorage-sizeingib

EcsInferenceAcceleratorOverrideProperty

class CfnPipePropsMixin.EcsInferenceAcceleratorOverrideProperty(*, device_name=None, device_type=None)

Bases: object

Details on an Elastic Inference accelerator task override.

This parameter is used to override the Elastic Inference accelerator specified in the task definition. For more information, see Working with Amazon Elastic Inference on Amazon ECS in the Amazon Elastic Container Service Developer Guide .

Parameters:

device_name (Optional[str]) – The Elastic Inference accelerator device name to override for the task. This parameter must match a deviceName specified in the task definition.
device_type (Optional[str]) – The Elastic Inference accelerator type to use.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsinferenceacceleratoroverride.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

ecs_inference_accelerator_override_property = pipes_mixins.CfnPipePropsMixin.EcsInferenceAcceleratorOverrideProperty(
    device_name="deviceName",
    device_type="deviceType"
)

Attributes

device_name

The Elastic Inference accelerator device name to override for the task.

This parameter must match a deviceName specified in the task definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsinferenceacceleratoroverride.html#cfn-pipes-pipe-ecsinferenceacceleratoroverride-devicename

device_type

The Elastic Inference accelerator type to use.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsinferenceacceleratoroverride.html#cfn-pipes-pipe-ecsinferenceacceleratoroverride-devicetype

EcsResourceRequirementProperty

class CfnPipePropsMixin.EcsResourceRequirementProperty(*, type=None, value=None)

Bases: object

The type and amount of a resource to assign to a container.

The supported resource types are GPUs and Elastic Inference accelerators. For more information, see Working with GPUs on Amazon ECS or Working with Amazon Elastic Inference on Amazon ECS in the Amazon Elastic Container Service Developer Guide

Parameters:

type (Optional[str]) – The type of resource to assign to a container. The supported values are GPU or InferenceAccelerator .
value (Optional[str]) – The value for the specified resource type. If the GPU type is used, the value is the number of physical GPUs the Amazon ECS container agent reserves for the container. The number of GPUs that’s reserved for all containers in a task can’t exceed the number of available GPUs on the container instance that the task is launched on. If the InferenceAccelerator type is used, the value matches the deviceName for an InferenceAccelerator specified in a task definition.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsresourcerequirement.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

ecs_resource_requirement_property = pipes_mixins.CfnPipePropsMixin.EcsResourceRequirementProperty(
    type="type",
    value="value"
)

Attributes

type

The type of resource to assign to a container.

The supported values are GPU or InferenceAccelerator .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsresourcerequirement.html#cfn-pipes-pipe-ecsresourcerequirement-type

value

The value for the specified resource type.

If the GPU type is used, the value is the number of physical GPUs the Amazon ECS container agent reserves for the container. The number of GPUs that’s reserved for all containers in a task can’t exceed the number of available GPUs on the container instance that the task is launched on.

If the InferenceAccelerator type is used, the value matches the deviceName for an InferenceAccelerator specified in a task definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsresourcerequirement.html#cfn-pipes-pipe-ecsresourcerequirement-value

EcsTaskOverrideProperty

class CfnPipePropsMixin.EcsTaskOverrideProperty(*, container_overrides=None, cpu=None, ephemeral_storage=None, execution_role_arn=None, inference_accelerator_overrides=None, memory=None, task_role_arn=None)

Bases: object

The overrides that are associated with a task.

Parameters:

container_overrides (Union[IResolvable, Sequence[Union[IResolvable, EcsContainerOverrideProperty, Dict[str, Any]]], None]) – One or more container overrides that are sent to a task.
cpu (Optional[str]) – The cpu override for the task.
ephemeral_storage (Union[IResolvable, EcsEphemeralStorageProperty, Dict[str, Any], None]) – The ephemeral storage setting override for the task. .. epigraph:: This parameter is only supported for tasks hosted on Fargate that use the following platform versions: - Linux platform version 1.4.0 or later. - Windows platform version 1.0.0 or later.
execution_role_arn (Optional[str]) – The Amazon Resource Name (ARN) of the task execution IAM role override for the task. For more information, see Amazon ECS task execution IAM role in the Amazon Elastic Container Service Developer Guide .
inference_accelerator_overrides (Union[IResolvable, Sequence[Union[IResolvable, EcsInferenceAcceleratorOverrideProperty, Dict[str, Any]]], None]) – The Elastic Inference accelerator override for the task.
memory (Optional[str]) – The memory override for the task.
task_role_arn (Optional[str]) – The Amazon Resource Name (ARN) of the IAM role that containers in this task can assume. All containers in this task are granted the permissions that are specified in this role. For more information, see IAM Role for Tasks in the Amazon Elastic Container Service Developer Guide .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.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

ecs_task_override_property = 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"
)

Attributes

container_overrides

One or more container overrides that are sent to a task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-containeroverrides

cpu

The cpu override for the task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-cpu

ephemeral_storage

The ephemeral storage setting override for the task.

This parameter is only supported for tasks hosted on Fargate that use the following platform versions:

Linux platform version 1.4.0 or later.

Windows platform version 1.0.0 or later.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-ephemeralstorage

execution_role_arn

The Amazon Resource Name (ARN) of the task execution IAM role override for the task.

For more information, see Amazon ECS task execution IAM role in the Amazon Elastic Container Service Developer Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-executionrolearn

inference_accelerator_overrides

The Elastic Inference accelerator override for the task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-inferenceacceleratoroverrides

memory

The memory override for the task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-memory

task_role_arn

The Amazon Resource Name (ARN) of the IAM role that containers in this task can assume.

All containers in this task are granted the permissions that are specified in this role. For more information, see IAM Role for Tasks in the Amazon Elastic Container Service Developer Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html#cfn-pipes-pipe-ecstaskoverride-taskrolearn

FilterCriteriaProperty

class CfnPipePropsMixin.FilterCriteriaProperty(*, filters=None)

Bases: object

The collection of event patterns used to filter events.

To remove a filter, specify a FilterCriteria object with an empty array of Filter objects.

For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .

Parameters:: filters (Union[IResolvable, Sequence[Union[IResolvable, FilterProperty, Dict[str, Any]]], None]) – The event patterns.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filtercriteria.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

filter_criteria_property = pipes_mixins.CfnPipePropsMixin.FilterCriteriaProperty(
    filters=[pipes_mixins.CfnPipePropsMixin.FilterProperty(
        pattern="pattern"
    )]
)

Attributes

filters

The event patterns.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filtercriteria.html#cfn-pipes-pipe-filtercriteria-filters

FilterProperty

class CfnPipePropsMixin.FilterProperty(*, pattern=None)

Bases: object

Filter events using an event pattern.

For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .

Parameters:: pattern (Optional[str]) – The event pattern.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filter.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

filter_property = pipes_mixins.CfnPipePropsMixin.FilterProperty(
    pattern="pattern"
)

Attributes

pattern

The event pattern.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filter.html#cfn-pipes-pipe-filter-pattern

FirehoseLogDestinationProperty

class CfnPipePropsMixin.FirehoseLogDestinationProperty(*, delivery_stream_arn=None)

Bases: object

Represents the Amazon Data Firehose logging configuration settings for the pipe.

Parameters:: delivery_stream_arn (Optional[str]) – The Amazon Resource Name (ARN) of the Firehose delivery stream to which EventBridge delivers the pipe log records.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-firehoselogdestination.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

firehose_log_destination_property = pipes_mixins.CfnPipePropsMixin.FirehoseLogDestinationProperty(
    delivery_stream_arn="deliveryStreamArn"
)

Attributes

delivery_stream_arn

The Amazon Resource Name (ARN) of the Firehose delivery stream to which EventBridge delivers the pipe log records.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-firehoselogdestination.html#cfn-pipes-pipe-firehoselogdestination-deliverystreamarn

MQBrokerAccessCredentialsProperty

class CfnPipePropsMixin.MQBrokerAccessCredentialsProperty(*, basic_auth=None)

Bases: object

The AWS Secrets Manager secret that stores your broker credentials.

Parameters:: basic_auth (Optional[str]) – The ARN of the Secrets Manager secret.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mqbrokeraccesscredentials.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

m_qBroker_access_credentials_property = pipes_mixins.CfnPipePropsMixin.MQBrokerAccessCredentialsProperty(
    basic_auth="basicAuth"
)

Attributes

basic_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mqbrokeraccesscredentials.html#cfn-pipes-pipe-mqbrokeraccesscredentials-basicauth

MSKAccessCredentialsProperty

class CfnPipePropsMixin.MSKAccessCredentialsProperty(*, client_certificate_tls_auth=None, sasl_scram512_auth=None)

Bases: object

The AWS Secrets Manager secret that stores your stream credentials.

Parameters:

client_certificate_tls_auth (Optional[str]) – The ARN of the Secrets Manager secret.
sasl_scram512_auth (Optional[str]) – The ARN of the Secrets Manager secret.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mskaccesscredentials.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

m_sKAccess_credentials_property = pipes_mixins.CfnPipePropsMixin.MSKAccessCredentialsProperty(
    client_certificate_tls_auth="clientCertificateTlsAuth",
    sasl_scram512_auth="saslScram512Auth"
)

Attributes

client_certificate_tls_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mskaccesscredentials.html#cfn-pipes-pipe-mskaccesscredentials-clientcertificatetlsauth

sasl_scram512_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mskaccesscredentials.html#cfn-pipes-pipe-mskaccesscredentials-saslscram512auth

MultiMeasureAttributeMappingProperty

class CfnPipePropsMixin.MultiMeasureAttributeMappingProperty(*, measure_value=None, measure_value_type=None, multi_measure_attribute_name=None)

Bases: object

A mapping of a source event data field to a measure in a Timestream for LiveAnalytics record.

Parameters:

measure_value (Optional[str]) – Dynamic path to the measurement attribute in the source event.
measure_value_type (Optional[str]) – Data type of the measurement attribute in the source event.
multi_measure_attribute_name (Optional[str]) – Target measure name to be used.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasureattributemapping.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

multi_measure_attribute_mapping_property = pipes_mixins.CfnPipePropsMixin.MultiMeasureAttributeMappingProperty(
    measure_value="measureValue",
    measure_value_type="measureValueType",
    multi_measure_attribute_name="multiMeasureAttributeName"
)

Attributes

measure_value

Dynamic path to the measurement attribute in the source event.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasureattributemapping.html#cfn-pipes-pipe-multimeasureattributemapping-measurevalue

measure_value_type

Data type of the measurement attribute in the source event.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasureattributemapping.html#cfn-pipes-pipe-multimeasureattributemapping-measurevaluetype

multi_measure_attribute_name

Target measure name to be used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasureattributemapping.html#cfn-pipes-pipe-multimeasureattributemapping-multimeasureattributename

MultiMeasureMappingProperty

class CfnPipePropsMixin.MultiMeasureMappingProperty(*, multi_measure_attribute_mappings=None, multi_measure_name=None)

Bases: object

Maps multiple measures from the source event to the same Timestream for LiveAnalytics record.

For more information, see Amazon Timestream for LiveAnalytics concepts

Parameters:

multi_measure_attribute_mappings (Union[IResolvable, Sequence[Union[IResolvable, MultiMeasureAttributeMappingProperty, Dict[str, Any]]], None]) – Mappings that represent multiple source event fields mapped to measures in the same Timestream for LiveAnalytics record.
multi_measure_name (Optional[str]) – The name of the multiple measurements per record (multi-measure).

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasuremapping.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

multi_measure_mapping_property = 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"
)

Attributes

multi_measure_attribute_mappings

Mappings that represent multiple source event fields mapped to measures in the same Timestream for LiveAnalytics record.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasuremapping.html#cfn-pipes-pipe-multimeasuremapping-multimeasureattributemappings

multi_measure_name

The name of the multiple measurements per record (multi-measure).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-multimeasuremapping.html#cfn-pipes-pipe-multimeasuremapping-multimeasurename

NetworkConfigurationProperty

class CfnPipePropsMixin.NetworkConfigurationProperty(*, awsvpc_configuration=None)

Bases: object

This structure specifies the network configuration for an Amazon ECS task.

Parameters:: awsvpc_configuration (Union[IResolvable, AwsVpcConfigurationProperty, Dict[str, Any], None]) – Use this structure to specify the VPC subnets and security groups for the task, and whether a public IP address is to be used. This structure is relevant only for ECS tasks that use the awsvpc network mode.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-networkconfiguration.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

network_configuration_property = pipes_mixins.CfnPipePropsMixin.NetworkConfigurationProperty(
    awsvpc_configuration=pipes_mixins.CfnPipePropsMixin.AwsVpcConfigurationProperty(
        assign_public_ip="assignPublicIp",
        security_groups=["securityGroups"],
        subnets=["subnets"]
    )
)

Attributes

awsvpc_configuration

Use this structure to specify the VPC subnets and security groups for the task, and whether a public IP address is to be used.

This structure is relevant only for ECS tasks that use the awsvpc network mode.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-networkconfiguration.html#cfn-pipes-pipe-networkconfiguration-awsvpcconfiguration

PipeEnrichmentHttpParametersProperty

class CfnPipePropsMixin.PipeEnrichmentHttpParametersProperty(*, header_parameters=None, path_parameter_values=None, query_string_parameters=None)

Bases: object

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.

In the latter case, these are merged with any InvocationParameters specified on the Connection, with any values from the Connection taking precedence.

Parameters:

header_parameters (Union[Mapping[str, str], IResolvable, None]) – The headers that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.
path_parameter_values (Optional[Sequence[str]]) – The path parameter values to be used to populate API Gateway REST API or EventBridge ApiDestination path wildcards (“*”).
query_string_parameters (Union[Mapping[str, str], IResolvable, None]) – The query string keys/values that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmenthttpparameters.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

pipe_enrichment_http_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeEnrichmentHttpParametersProperty(
    header_parameters={
        "header_parameters_key": "headerParameters"
    },
    path_parameter_values=["pathParameterValues"],
    query_string_parameters={
        "query_string_parameters_key": "queryStringParameters"
    }
)

Attributes

header_parameters

The headers that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmenthttpparameters.html#cfn-pipes-pipe-pipeenrichmenthttpparameters-headerparameters

path_parameter_values

The path parameter values to be used to populate API Gateway REST API or EventBridge ApiDestination path wildcards (“*”).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmenthttpparameters.html#cfn-pipes-pipe-pipeenrichmenthttpparameters-pathparametervalues

query_string_parameters

The query string keys/values that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmenthttpparameters.html#cfn-pipes-pipe-pipeenrichmenthttpparameters-querystringparameters

PipeEnrichmentParametersProperty

class CfnPipePropsMixin.PipeEnrichmentParametersProperty(*, http_parameters=None, input_template=None)

Bases: object

The parameters required to set up enrichment on your pipe.

Parameters:

http_parameters (Union[IResolvable, PipeEnrichmentHttpParametersProperty, Dict[str, Any], None]) – Contains the HTTP parameters to use when the target is a API Gateway REST endpoint or EventBridge ApiDestination. If you specify an API Gateway REST API or EventBridge ApiDestination as a target, you can use this parameter to specify headers, path parameters, and query string keys/values as part of your target invoking request. If you’re using ApiDestinations, the corresponding Connection can also have these values configured. In case of any conflicting keys, values from the Connection take precedence.
input_template (Optional[str]) – Valid JSON text passed to the enrichment. In this case, nothing from the event itself is passed to the enrichment. For more information, see The JavaScript Object Notation (JSON) Data Interchange Format . To remove an input template, specify an empty string.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmentparameters.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

pipe_enrichment_parameters_property = 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"
)

Attributes

http_parameters

Contains the HTTP parameters to use when the target is a API Gateway REST endpoint or EventBridge ApiDestination.

If you specify an API Gateway REST API or EventBridge ApiDestination as a target, you can use this parameter to specify headers, path parameters, and query string keys/values as part of your target invoking request. If you’re using ApiDestinations, the corresponding Connection can also have these values configured. In case of any conflicting keys, values from the Connection take precedence.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmentparameters.html#cfn-pipes-pipe-pipeenrichmentparameters-httpparameters

input_template

Valid JSON text passed to the enrichment.

In this case, nothing from the event itself is passed to the enrichment. For more information, see The JavaScript Object Notation (JSON) Data Interchange Format .

To remove an input template, specify an empty string.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmentparameters.html#cfn-pipes-pipe-pipeenrichmentparameters-inputtemplate

PipeLogConfigurationProperty

class CfnPipePropsMixin.PipeLogConfigurationProperty(*, cloudwatch_logs_log_destination=None, firehose_log_destination=None, include_execution_data=None, level=None, s3_log_destination=None)

Bases: object

Represents the configuration settings for the logs to which this pipe should report events.

Parameters:

cloudwatch_logs_log_destination (Union[IResolvable, CloudwatchLogsLogDestinationProperty, Dict[str, Any], None]) – The logging configuration settings for the pipe.
firehose_log_destination (Union[IResolvable, FirehoseLogDestinationProperty, Dict[str, Any], None]) – The Amazon Data Firehose logging configuration settings for the pipe.
include_execution_data (Optional[Sequence[str]]) – Whether the execution data (specifically, the payload , awsRequest , and awsResponse fields) is included in the log messages for this pipe. This applies to all log destinations for the pipe. For more information, see Including execution data in logs in the Amazon EventBridge User Guide . Allowed values: ALL
level (Optional[str]) – The level of logging detail to include. This applies to all log destinations for the pipe.
s3_log_destination (Union[IResolvable, S3LogDestinationProperty, Dict[str, Any], None]) – The Amazon S3 logging configuration settings for the pipe.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.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

pipe_log_configuration_property = 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"
    )
)

Attributes

cloudwatch_logs_log_destination

The logging configuration settings for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html#cfn-pipes-pipe-pipelogconfiguration-cloudwatchlogslogdestination

firehose_log_destination

The Amazon Data Firehose logging configuration settings for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html#cfn-pipes-pipe-pipelogconfiguration-firehoselogdestination

include_execution_data

Whether the execution data (specifically, the payload , awsRequest , and awsResponse fields) is included in the log messages for this pipe.

This applies to all log destinations for the pipe.

For more information, see Including execution data in logs in the Amazon EventBridge User Guide .

Allowed values: ALL

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html#cfn-pipes-pipe-pipelogconfiguration-includeexecutiondata

level

The level of logging detail to include.

This applies to all log destinations for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html#cfn-pipes-pipe-pipelogconfiguration-level

s3_log_destination

The Amazon S3 logging configuration settings for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html#cfn-pipes-pipe-pipelogconfiguration-s3logdestination

PipeSourceActiveMQBrokerParametersProperty

class CfnPipePropsMixin.PipeSourceActiveMQBrokerParametersProperty(*, batch_size=None, credentials=None, maximum_batching_window_in_seconds=None, queue_name=None)

Bases: object

The parameters for using an Active MQ broker as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
credentials (Union[IResolvable, MQBrokerAccessCredentialsProperty, Dict[str, Any], None]) – The credentials needed to access the resource.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
queue_name (Optional[str]) – The name of the destination queue to consume.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.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

pipe_source_active_mQBroker_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeSourceActiveMQBrokerParametersProperty(
    batch_size=123,
    credentials=pipes_mixins.CfnPipePropsMixin.MQBrokerAccessCredentialsProperty(
        basic_auth="basicAuth"
    ),
    maximum_batching_window_in_seconds=123,
    queue_name="queueName"
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-batchsize

credentials

The credentials needed to access the resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-credentials

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-maximumbatchingwindowinseconds

queue_name

The name of the destination queue to consume.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-queuename

PipeSourceDynamoDBStreamParametersProperty

class CfnPipePropsMixin.PipeSourceDynamoDBStreamParametersProperty(*, batch_size=None, dead_letter_config=None, maximum_batching_window_in_seconds=None, maximum_record_age_in_seconds=None, maximum_retry_attempts=None, on_partial_batch_item_failure=None, parallelization_factor=None, starting_position=None)

Bases: object

The parameters for using a DynamoDB stream as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
dead_letter_config (Union[IResolvable, DeadLetterConfigProperty, Dict[str, Any], None]) – Define the target queue to send dead-letter queue events to.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
maximum_record_age_in_seconds (Union[int, float, None]) – Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
maximum_retry_attempts (Union[int, float, None]) – Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
on_partial_batch_item_failure (Optional[str]) – Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
parallelization_factor (Union[int, float, None]) – The number of batches to process concurrently from each shard. The default value is 1.
starting_position (Optional[str]) – (Streams only) The position in a stream from which to start reading. Valid values : TRIM_HORIZON | LATEST

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.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

pipe_source_dynamo_dBStream_parameters_property = 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"
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-batchsize

dead_letter_config

Define the target queue to send dead-letter queue events to.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-deadletterconfig

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-maximumbatchingwindowinseconds

maximum_record_age_in_seconds

Discard records older than the specified age.

The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-maximumrecordageinseconds

maximum_retry_attempts

Discard records after the specified number of retries.

The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-maximumretryattempts

on_partial_batch_item_failure

Define how to handle item process failures.

AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-onpartialbatchitemfailure

parallelization_factor

The number of batches to process concurrently from each shard.

The default value is 1.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-parallelizationfactor

starting_position

(Streams only) The position in a stream from which to start reading.

Valid values : TRIM_HORIZON | LATEST

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-startingposition

PipeSourceKinesisStreamParametersProperty

class CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty(*, batch_size=None, dead_letter_config=None, maximum_batching_window_in_seconds=None, maximum_record_age_in_seconds=None, maximum_retry_attempts=None, on_partial_batch_item_failure=None, parallelization_factor=None, starting_position=None, starting_position_timestamp=None)

Bases: object

The parameters for using a Kinesis stream as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
dead_letter_config (Union[IResolvable, DeadLetterConfigProperty, Dict[str, Any], None]) – Define the target queue to send dead-letter queue events to.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
maximum_record_age_in_seconds (Union[int, float, None]) – Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
maximum_retry_attempts (Union[int, float, None]) – Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
on_partial_batch_item_failure (Optional[str]) – Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
parallelization_factor (Union[int, float, None]) – The number of batches to process concurrently from each shard. The default value is 1.
starting_position (Optional[str]) – The position in a stream from which to start reading.
starting_position_timestamp (Optional[str]) – With StartingPosition set to AT_TIMESTAMP , the time from which to start reading, in Unix time seconds.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.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

pipe_source_kinesis_stream_parameters_property = 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"
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-batchsize

dead_letter_config

Define the target queue to send dead-letter queue events to.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-deadletterconfig

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumbatchingwindowinseconds

maximum_record_age_in_seconds

Discard records older than the specified age.

The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumrecordageinseconds

maximum_retry_attempts

Discard records after the specified number of retries.

The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumretryattempts

on_partial_batch_item_failure

Define how to handle item process failures.

AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-onpartialbatchitemfailure

parallelization_factor

The number of batches to process concurrently from each shard.

The default value is 1.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-parallelizationfactor

starting_position

The position in a stream from which to start reading.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-startingposition

starting_position_timestamp

With StartingPosition set to AT_TIMESTAMP , the time from which to start reading, in Unix time seconds.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-startingpositiontimestamp

PipeSourceManagedStreamingKafkaParametersProperty

class CfnPipePropsMixin.PipeSourceManagedStreamingKafkaParametersProperty(*, batch_size=None, consumer_group_id=None, credentials=None, maximum_batching_window_in_seconds=None, starting_position=None, topic_name=None)

Bases: object

The parameters for using an MSK stream as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
consumer_group_id (Optional[str]) – The name of the destination queue to consume.
credentials (Union[IResolvable, MSKAccessCredentialsProperty, Dict[str, Any], None]) – The credentials needed to access the resource.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
starting_position (Optional[str]) – The position in a stream from which to start reading.
topic_name (Optional[str]) – The name of the topic that the pipe will read from.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.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

pipe_source_managed_streaming_kafka_parameters_property = 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"
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-batchsize

consumer_group_id

The name of the destination queue to consume.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-consumergroupid

credentials

The credentials needed to access the resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-credentials

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-maximumbatchingwindowinseconds

starting_position

The position in a stream from which to start reading.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-startingposition

topic_name

The name of the topic that the pipe will read from.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html#cfn-pipes-pipe-pipesourcemanagedstreamingkafkaparameters-topicname

PipeSourceParametersProperty

class CfnPipePropsMixin.PipeSourceParametersProperty(*, active_mq_broker_parameters=None, dynamo_db_stream_parameters=None, filter_criteria=None, kinesis_stream_parameters=None, managed_streaming_kafka_parameters=None, rabbit_mq_broker_parameters=None, self_managed_kafka_parameters=None, sqs_queue_parameters=None)

Bases: object

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

Parameters:

active_mq_broker_parameters (Union[IResolvable, PipeSourceActiveMQBrokerParametersProperty, Dict[str, Any], None]) – The parameters for using an Active MQ broker as a source.
dynamo_db_stream_parameters (Union[IResolvable, PipeSourceDynamoDBStreamParametersProperty, Dict[str, Any], None]) – The parameters for using a DynamoDB stream as a source.
filter_criteria (Union[IResolvable, FilterCriteriaProperty, Dict[str, Any], None]) –
The collection of event patterns used to filter events. To remove a filter, specify a FilterCriteria object with an empty array of Filter objects. For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .
kinesis_stream_parameters (Union[IResolvable, PipeSourceKinesisStreamParametersProperty, Dict[str, Any], None]) – The parameters for using a Kinesis stream as a source.
managed_streaming_kafka_parameters (Union[IResolvable, PipeSourceManagedStreamingKafkaParametersProperty, Dict[str, Any], None]) – The parameters for using an MSK stream as a source.
rabbit_mq_broker_parameters (Union[IResolvable, PipeSourceRabbitMQBrokerParametersProperty, Dict[str, Any], None]) – The parameters for using a Rabbit MQ broker as a source.
self_managed_kafka_parameters (Union[IResolvable, PipeSourceSelfManagedKafkaParametersProperty, Dict[str, Any], None]) – The parameters for using a self-managed Apache Kafka stream as a source. A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .
sqs_queue_parameters (Union[IResolvable, PipeSourceSqsQueueParametersProperty, Dict[str, Any], None]) – The parameters for using a Amazon SQS stream as a source.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.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

pipe_source_parameters_property = 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
    )
)

Attributes

active_mq_broker_parameters

The parameters for using an Active MQ broker as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-activemqbrokerparameters

dynamo_db_stream_parameters

The parameters for using a DynamoDB stream as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-dynamodbstreamparameters

filter_criteria

The collection of event patterns used to filter events.

To remove a filter, specify a FilterCriteria object with an empty array of Filter objects.

For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-filtercriteria

kinesis_stream_parameters

The parameters for using a Kinesis stream as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-kinesisstreamparameters

managed_streaming_kafka_parameters

The parameters for using an MSK stream as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-managedstreamingkafkaparameters

rabbit_mq_broker_parameters

The parameters for using a Rabbit MQ broker as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-rabbitmqbrokerparameters

self_managed_kafka_parameters

The parameters for using a self-managed Apache Kafka stream as a source.

A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-selfmanagedkafkaparameters

sqs_queue_parameters

The parameters for using a Amazon SQS stream as a source.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html#cfn-pipes-pipe-pipesourceparameters-sqsqueueparameters

PipeSourceRabbitMQBrokerParametersProperty

class CfnPipePropsMixin.PipeSourceRabbitMQBrokerParametersProperty(*, batch_size=None, credentials=None, maximum_batching_window_in_seconds=None, queue_name=None, virtual_host=None)

Bases: object

The parameters for using a Rabbit MQ broker as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
credentials (Union[IResolvable, MQBrokerAccessCredentialsProperty, Dict[str, Any], None]) – The credentials needed to access the resource.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
queue_name (Optional[str]) – The name of the destination queue to consume.
virtual_host (Optional[str]) – The name of the virtual host associated with the source broker.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.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

pipe_source_rabbit_mQBroker_parameters_property = 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"
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html#cfn-pipes-pipe-pipesourcerabbitmqbrokerparameters-batchsize

credentials

The credentials needed to access the resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html#cfn-pipes-pipe-pipesourcerabbitmqbrokerparameters-credentials

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html#cfn-pipes-pipe-pipesourcerabbitmqbrokerparameters-maximumbatchingwindowinseconds

queue_name

The name of the destination queue to consume.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html#cfn-pipes-pipe-pipesourcerabbitmqbrokerparameters-queuename

virtual_host

The name of the virtual host associated with the source broker.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html#cfn-pipes-pipe-pipesourcerabbitmqbrokerparameters-virtualhost

PipeSourceSelfManagedKafkaParametersProperty

class CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty(*, additional_bootstrap_servers=None, batch_size=None, consumer_group_id=None, credentials=None, maximum_batching_window_in_seconds=None, server_root_ca_certificate=None, starting_position=None, topic_name=None, vpc=None)

Bases: object

The parameters for using a self-managed Apache Kafka stream as a source.

A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .

Parameters:

additional_bootstrap_servers (Optional[Sequence[str]]) – An array of server URLs.
batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
consumer_group_id (Optional[str]) – The name of the destination queue to consume.
credentials (Union[IResolvable, SelfManagedKafkaAccessConfigurationCredentialsProperty, Dict[str, Any], None]) – The credentials needed to access the resource.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.
server_root_ca_certificate (Optional[str]) – The ARN of the Secrets Manager secret used for certification.
starting_position (Optional[str]) – The position in a stream from which to start reading.
topic_name (Optional[str]) – The name of the topic that the pipe will read from.
vpc (Union[IResolvable, SelfManagedKafkaAccessConfigurationVpcProperty, Dict[str, Any], None]) – This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.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

pipe_source_self_managed_kafka_parameters_property = 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"]
    )
)

Attributes

additional_bootstrap_servers

An array of server URLs.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-additionalbootstrapservers

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-batchsize

consumer_group_id

The name of the destination queue to consume.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-consumergroupid

credentials

The credentials needed to access the resource.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-credentials

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-maximumbatchingwindowinseconds

server_root_ca_certificate

The ARN of the Secrets Manager secret used for certification.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-serverrootcacertificate

starting_position

The position in a stream from which to start reading.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-startingposition

topic_name

The name of the topic that the pipe will read from.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-topicname

vpc

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html#cfn-pipes-pipe-pipesourceselfmanagedkafkaparameters-vpc

PipeSourceSqsQueueParametersProperty

class CfnPipePropsMixin.PipeSourceSqsQueueParametersProperty(*, batch_size=None, maximum_batching_window_in_seconds=None)

Bases: object

The parameters for using a Amazon SQS stream as a source.

Parameters:

batch_size (Union[int, float, None]) – The maximum number of records to include in each batch.
maximum_batching_window_in_seconds (Union[int, float, None]) – The maximum length of a time to wait for events.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.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

pipe_source_sqs_queue_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeSourceSqsQueueParametersProperty(
    batch_size=123,
    maximum_batching_window_in_seconds=123
)

Attributes

batch_size

The maximum number of records to include in each batch.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html#cfn-pipes-pipe-pipesourcesqsqueueparameters-batchsize

maximum_batching_window_in_seconds

The maximum length of a time to wait for events.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html#cfn-pipes-pipe-pipesourcesqsqueueparameters-maximumbatchingwindowinseconds

PipeTargetBatchJobParametersProperty

class CfnPipePropsMixin.PipeTargetBatchJobParametersProperty(*, array_properties=None, container_overrides=None, depends_on=None, job_definition=None, job_name=None, parameters=None, retry_strategy=None)

Bases: object

The parameters for using an AWS Batch job as a target.

Parameters:

array_properties (Union[IResolvable, BatchArrayPropertiesProperty, Dict[str, Any], None]) – The array properties for the submitted job, such as the size of the array. The array size can be between 2 and 10,000. If you specify array properties for a job, it becomes an array job. This parameter is used only if the target is an AWS Batch job.
container_overrides (Union[IResolvable, BatchContainerOverridesProperty, Dict[str, Any], None]) – The overrides that are sent to a container.
depends_on (Union[IResolvable, Sequence[Union[IResolvable, BatchJobDependencyProperty, Dict[str, Any]]], None]) – A list of dependencies for the job. A job can depend upon a maximum of 20 jobs. You can specify a SEQUENTIAL type dependency without specifying a job ID for array jobs so that each child array job completes sequentially, starting at index 0. You can also specify an N_TO_N type dependency with a job ID for array jobs. In that case, each index child of this job must wait for the corresponding index child of each dependency to complete before it can begin.
job_definition (Optional[str]) – The job definition used by this job. This value can be one of name , name:revision , or the Amazon Resource Name (ARN) for the job definition. If name is specified without a revision then the latest active revision is used.
job_name (Optional[str]) – The name of the job. It can be up to 128 letters long. The first character must be alphanumeric, can contain uppercase and lowercase letters, numbers, hyphens (-), and underscores (_).
parameters (Union[Mapping[str, str], IResolvable, None]) – Additional parameters passed to the job that replace parameter substitution placeholders that are set in the job definition. Parameters are specified as a key and value pair mapping. Parameters included here override any corresponding parameter defaults from the job definition.
retry_strategy (Union[IResolvable, BatchRetryStrategyProperty, Dict[str, Any], None]) – The retry strategy to use for failed jobs. When a retry strategy is specified here, it overrides the retry strategy defined in the job definition.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.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

pipe_target_batch_job_parameters_property = 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
    )
)

Attributes

array_properties

The array properties for the submitted job, such as the size of the array.

The array size can be between 2 and 10,000. If you specify array properties for a job, it becomes an array job. This parameter is used only if the target is an AWS Batch job.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-arrayproperties

container_overrides

The overrides that are sent to a container.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-containeroverrides

depends_on

A list of dependencies for the job.

A job can depend upon a maximum of 20 jobs. You can specify a SEQUENTIAL type dependency without specifying a job ID for array jobs so that each child array job completes sequentially, starting at index 0. You can also specify an N_TO_N type dependency with a job ID for array jobs. In that case, each index child of this job must wait for the corresponding index child of each dependency to complete before it can begin.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-dependson

job_definition

The job definition used by this job.

This value can be one of name , name:revision , or the Amazon Resource Name (ARN) for the job definition. If name is specified without a revision then the latest active revision is used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-jobdefinition

job_name

The name of the job.

It can be up to 128 letters long. The first character must be alphanumeric, can contain uppercase and lowercase letters, numbers, hyphens (-), and underscores (_).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-jobname

parameters

Additional parameters passed to the job that replace parameter substitution placeholders that are set in the job definition.

Parameters are specified as a key and value pair mapping. Parameters included here override any corresponding parameter defaults from the job definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-parameters

retry_strategy

The retry strategy to use for failed jobs.

When a retry strategy is specified here, it overrides the retry strategy defined in the job definition.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html#cfn-pipes-pipe-pipetargetbatchjobparameters-retrystrategy

PipeTargetCloudWatchLogsParametersProperty

class CfnPipePropsMixin.PipeTargetCloudWatchLogsParametersProperty(*, log_stream_name=None, timestamp=None)

Bases: object

The parameters for using an CloudWatch Logs log stream as a target.

Parameters:

log_stream_name (Optional[str]) – The name of the log stream.
timestamp (Optional[str]) – A dynamic path parameter to a field in the payload containing the time the event occurred, expressed as the number of milliseconds after Jan 1, 1970 00:00:00 UTC. The value cannot be a static timestamp as the provided timestamp would be applied to all events delivered by the Pipe, regardless of when they are actually delivered. If no dynamic path parameter is provided, the default value is the time the invocation is processed by the Pipe.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetcloudwatchlogsparameters.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

pipe_target_cloud_watch_logs_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetCloudWatchLogsParametersProperty(
    log_stream_name="logStreamName",
    timestamp="timestamp"
)

Attributes

log_stream_name

The name of the log stream.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetcloudwatchlogsparameters.html#cfn-pipes-pipe-pipetargetcloudwatchlogsparameters-logstreamname

timestamp

00 UTC.

The value cannot be a static timestamp as the provided timestamp would be applied to all events delivered by the Pipe, regardless of when they are actually delivered.

If no dynamic path parameter is provided, the default value is the time the invocation is processed by the Pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetcloudwatchlogsparameters.html#cfn-pipes-pipe-pipetargetcloudwatchlogsparameters-timestamp
Type:: A dynamic path parameter to a field in the payload containing the time the event occurred, expressed as the number of milliseconds after Jan 1, 1970 00
Type:: 00

PipeTargetEcsTaskParametersProperty

class CfnPipePropsMixin.PipeTargetEcsTaskParametersProperty(*, capacity_provider_strategy=None, enable_ecs_managed_tags=None, enable_execute_command=None, group=None, launch_type=None, network_configuration=None, overrides=None, placement_constraints=None, placement_strategy=None, platform_version=None, propagate_tags=None, reference_id=None, tags=None, task_count=None, task_definition_arn=None)

Bases: object

The parameters for using an Amazon ECS task as a target.

Parameters:

capacity_provider_strategy (Union[IResolvable, Sequence[Union[IResolvable, CapacityProviderStrategyItemProperty, Dict[str, Any]]], None]) – The capacity provider strategy to use for the task. If a capacityProviderStrategy is specified, the launchType parameter must be omitted. If no capacityProviderStrategy or launchType is specified, the defaultCapacityProviderStrategy for the cluster is used.
enable_ecs_managed_tags (Union[bool, IResolvable, None]) – Specifies whether to enable Amazon ECS managed tags for the task. For more information, see Tagging Your Amazon ECS Resources in the Amazon Elastic Container Service Developer Guide. Default: - false
enable_execute_command (Union[bool, IResolvable, None]) – Whether or not to enable the execute command functionality for the containers in this task. If true, this enables execute command functionality on all containers in the task. Default: - false
group (Optional[str]) – Specifies an Amazon ECS task group for the task. The maximum length is 255 characters.
launch_type (Optional[str]) – Specifies the launch type on which your task is running. The launch type that you specify here must match one of the launch type (compatibilities) of the target task. The FARGATE value is supported only in the Regions where AWS Fargate with Amazon ECS is supported. For more information, see AWS Fargate on Amazon ECS in the Amazon Elastic Container Service Developer Guide .
network_configuration (Union[IResolvable, NetworkConfigurationProperty, Dict[str, Any], None]) – Use this structure if the Amazon ECS task uses the awsvpc network mode. This structure specifies the VPC subnets and security groups associated with the task, and whether a public IP address is to be used. This structure is required if LaunchType is FARGATE because the awsvpc mode is required for Fargate tasks. If you specify NetworkConfiguration when the target ECS task does not use the awsvpc network mode, the task fails.
overrides (Union[IResolvable, EcsTaskOverrideProperty, Dict[str, Any], None]) – The overrides that are associated with a task.
placement_constraints (Union[IResolvable, Sequence[Union[IResolvable, PlacementConstraintProperty, Dict[str, Any]]], None]) – An array of placement constraint objects to use for the task. You can specify up to 10 constraints per task (including constraints in the task definition and those specified at runtime).
placement_strategy (Union[IResolvable, Sequence[Union[IResolvable, PlacementStrategyProperty, Dict[str, Any]]], None]) – The placement strategy objects to use for the task. You can specify a maximum of five strategy rules per task.
platform_version (Optional[str]) – Specifies the platform version for the task. Specify only the numeric portion of the platform version, such as 1.1.0 . This structure is used only if LaunchType is FARGATE . For more information about valid platform versions, see AWS Fargate Platform Versions in the Amazon Elastic Container Service Developer Guide .
propagate_tags (Optional[str]) – Specifies whether to propagate the tags from the task definition to the task. If no value is specified, the tags are not propagated. Tags can only be propagated to the task during task creation. To add tags to a task after task creation, use the TagResource API action.
reference_id (Optional[str]) – The reference ID to use for the task.
tags (Optional[Sequence[Union[CfnTag, Dict[str, Any]]]]) – The metadata that you apply to the task to help you categorize and organize them. Each tag consists of a key and an optional value, both of which you define. To learn more, see RunTask in the Amazon ECS API Reference.
task_count (Union[int, float, None]) – The number of tasks to create based on TaskDefinition . The default is 1.
task_definition_arn (Optional[str]) – The ARN of the task definition to use if the event target is an Amazon ECS task.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.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

pipe_target_ecs_task_parameters_property = 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"
)

Attributes

capacity_provider_strategy

The capacity provider strategy to use for the task.

If a capacityProviderStrategy is specified, the launchType parameter must be omitted. If no capacityProviderStrategy or launchType is specified, the defaultCapacityProviderStrategy for the cluster is used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-capacityproviderstrategy

enable_ecs_managed_tags

Specifies whether to enable Amazon ECS managed tags for the task.

For more information, see Tagging Your Amazon ECS Resources in the Amazon Elastic Container Service Developer Guide.

Default:

false

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-enableecsmanagedtags

enable_execute_command

Whether or not to enable the execute command functionality for the containers in this task.

If true, this enables execute command functionality on all containers in the task.

Default:

false

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-enableexecutecommand

group

Specifies an Amazon ECS task group for the task.

The maximum length is 255 characters.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-group

launch_type

Specifies the launch type on which your task is running.

The launch type that you specify here must match one of the launch type (compatibilities) of the target task. The FARGATE value is supported only in the Regions where AWS Fargate with Amazon ECS is supported. For more information, see AWS Fargate on Amazon ECS in the Amazon Elastic Container Service Developer Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-launchtype

network_configuration

Use this structure if the Amazon ECS task uses the awsvpc network mode.

This structure specifies the VPC subnets and security groups associated with the task, and whether a public IP address is to be used. This structure is required if LaunchType is FARGATE because the awsvpc mode is required for Fargate tasks.

If you specify NetworkConfiguration when the target ECS task does not use the awsvpc network mode, the task fails.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-networkconfiguration

overrides

The overrides that are associated with a task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-overrides

placement_constraints

An array of placement constraint objects to use for the task.

You can specify up to 10 constraints per task (including constraints in the task definition and those specified at runtime).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-placementconstraints

placement_strategy

The placement strategy objects to use for the task.

You can specify a maximum of five strategy rules per task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-placementstrategy

platform_version

Specifies the platform version for the task.

Specify only the numeric portion of the platform version, such as 1.1.0 .

This structure is used only if LaunchType is FARGATE . For more information about valid platform versions, see AWS Fargate Platform Versions in the Amazon Elastic Container Service Developer Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-platformversion

propagate_tags

Specifies whether to propagate the tags from the task definition to the task.

If no value is specified, the tags are not propagated. Tags can only be propagated to the task during task creation. To add tags to a task after task creation, use the TagResource API action.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-propagatetags

reference_id

The reference ID to use for the task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-referenceid

tags

The metadata that you apply to the task to help you categorize and organize them.

Each tag consists of a key and an optional value, both of which you define. To learn more, see RunTask in the Amazon ECS API Reference.

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

task_count

The number of tasks to create based on TaskDefinition .

The default is 1.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-taskcount

task_definition_arn

The ARN of the task definition to use if the event target is an Amazon ECS task.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html#cfn-pipes-pipe-pipetargetecstaskparameters-taskdefinitionarn

PipeTargetEventBridgeEventBusParametersProperty

class CfnPipePropsMixin.PipeTargetEventBridgeEventBusParametersProperty(*, detail_type=None, endpoint_id=None, resources=None, source=None, time=None)

Bases: object

The parameters for using an EventBridge event bus as a target.

Parameters:

detail_type (Optional[str]) – A free-form string, with a maximum of 128 characters, used to decide what fields to expect in the event detail.
endpoint_id (Optional[str]) – The URL subdomain of the endpoint. For example, if the URL for Endpoint is https://abcde.veo.endpoints.event.amazonaws.com, then the EndpointId is abcde.veo .
resources (Optional[Sequence[str]]) – AWS resources, identified by Amazon Resource Name (ARN), which the event primarily concerns. Any number, including zero, may be present.
source (Optional[str]) – The source of the event.
time (Optional[str]) – The time stamp of the event, per RFC3339 . If no time stamp is provided, the time stamp of the PutEvents call is used.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.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

pipe_target_event_bridge_event_bus_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetEventBridgeEventBusParametersProperty(
    detail_type="detailType",
    endpoint_id="endpointId",
    resources=["resources"],
    source="source",
    time="time"
)

Attributes

detail_type

A free-form string, with a maximum of 128 characters, used to decide what fields to expect in the event detail.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.html#cfn-pipes-pipe-pipetargeteventbridgeeventbusparameters-detailtype

endpoint_id

The URL subdomain of the endpoint.

For example, if the URL for Endpoint is https://abcde.veo.endpoints.event.amazonaws.com, then the EndpointId is abcde.veo .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.html#cfn-pipes-pipe-pipetargeteventbridgeeventbusparameters-endpointid

resources

AWS resources, identified by Amazon Resource Name (ARN), which the event primarily concerns.

Any number, including zero, may be present.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.html#cfn-pipes-pipe-pipetargeteventbridgeeventbusparameters-resources

source

The source of the event.

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

time

The time stamp of the event, per RFC3339 . If no time stamp is provided, the time stamp of the PutEvents call is used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.html#cfn-pipes-pipe-pipetargeteventbridgeeventbusparameters-time

PipeTargetHttpParametersProperty

class CfnPipePropsMixin.PipeTargetHttpParametersProperty(*, header_parameters=None, path_parameter_values=None, query_string_parameters=None)

Bases: object

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.

Parameters:

header_parameters (Union[Mapping[str, str], IResolvable, None]) – The headers that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.
path_parameter_values (Optional[Sequence[str]]) – The path parameter values to be used to populate API Gateway REST API or EventBridge ApiDestination path wildcards (“*”).
query_string_parameters (Union[Mapping[str, str], IResolvable, None]) – The query string keys/values that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargethttpparameters.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

pipe_target_http_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetHttpParametersProperty(
    header_parameters={
        "header_parameters_key": "headerParameters"
    },
    path_parameter_values=["pathParameterValues"],
    query_string_parameters={
        "query_string_parameters_key": "queryStringParameters"
    }
)

Attributes

header_parameters

The headers that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargethttpparameters.html#cfn-pipes-pipe-pipetargethttpparameters-headerparameters

path_parameter_values

The path parameter values to be used to populate API Gateway REST API or EventBridge ApiDestination path wildcards (“*”).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargethttpparameters.html#cfn-pipes-pipe-pipetargethttpparameters-pathparametervalues

query_string_parameters

The query string keys/values that need to be sent as part of request invoking the API Gateway REST API or EventBridge ApiDestination.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargethttpparameters.html#cfn-pipes-pipe-pipetargethttpparameters-querystringparameters

PipeTargetKinesisStreamParametersProperty

class CfnPipePropsMixin.PipeTargetKinesisStreamParametersProperty(*, partition_key=None)

Bases: object

The parameters for using a Kinesis stream as a target.

Parameters:: partition_key (Optional[str]) – Determines which shard in the stream the data record is assigned to. Partition keys are Unicode strings with a maximum length limit of 256 characters for each key. Amazon Kinesis Data Streams uses the partition key as input to a hash function that maps the partition key and associated data to a specific shard. Specifically, an MD5 hash function is used to map partition keys to 128-bit integer values and to map associated data records to shards. As a result of this hashing mechanism, all data records with the same partition key map to the same shard within the stream.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetkinesisstreamparameters.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

pipe_target_kinesis_stream_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetKinesisStreamParametersProperty(
    partition_key="partitionKey"
)

Attributes

partition_key

Determines which shard in the stream the data record is assigned to.

Partition keys are Unicode strings with a maximum length limit of 256 characters for each key. Amazon Kinesis Data Streams uses the partition key as input to a hash function that maps the partition key and associated data to a specific shard. Specifically, an MD5 hash function is used to map partition keys to 128-bit integer values and to map associated data records to shards. As a result of this hashing mechanism, all data records with the same partition key map to the same shard within the stream.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetkinesisstreamparameters.html#cfn-pipes-pipe-pipetargetkinesisstreamparameters-partitionkey

PipeTargetLambdaFunctionParametersProperty

class CfnPipePropsMixin.PipeTargetLambdaFunctionParametersProperty(*, invocation_type=None)

Bases: object

The parameters for using a Lambda function as a target.

Parameters:

invocation_type (Optional[str]) –

Specify whether to invoke the function synchronously or asynchronously. - REQUEST_RESPONSE (default) - Invoke synchronously. This corresponds to the RequestResponse option in the InvocationType parameter for the Lambda Invoke API. - FIRE_AND_FORGET - Invoke asynchronously. This corresponds to the Event option in the InvocationType parameter for the Lambda Invoke API. For more information, see Invocation types in the Amazon EventBridge User Guide .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetlambdafunctionparameters.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

pipe_target_lambda_function_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetLambdaFunctionParametersProperty(
    invocation_type="invocationType"
)

Attributes

invocation_type

Specify whether to invoke the function synchronously or asynchronously.

REQUEST_RESPONSE (default) - Invoke synchronously. This corresponds to the RequestResponse option in the InvocationType parameter for the Lambda Invoke API.
FIRE_AND_FORGET - Invoke asynchronously. This corresponds to the Event option in the InvocationType parameter for the Lambda Invoke API.

For more information, see Invocation types in the Amazon EventBridge User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetlambdafunctionparameters.html#cfn-pipes-pipe-pipetargetlambdafunctionparameters-invocationtype

PipeTargetParametersProperty

class CfnPipePropsMixin.PipeTargetParametersProperty(*, batch_job_parameters=None, cloud_watch_logs_parameters=None, ecs_task_parameters=None, event_bridge_event_bus_parameters=None, http_parameters=None, input_template=None, kinesis_stream_parameters=None, lambda_function_parameters=None, redshift_data_parameters=None, sage_maker_pipeline_parameters=None, sqs_queue_parameters=None, step_function_state_machine_parameters=None, timestream_parameters=None)

Bases: object

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 .

Parameters:

batch_job_parameters (Union[IResolvable, PipeTargetBatchJobParametersProperty, Dict[str, Any], None]) – The parameters for using an AWS Batch job as a target.
cloud_watch_logs_parameters (Union[IResolvable, PipeTargetCloudWatchLogsParametersProperty, Dict[str, Any], None]) – The parameters for using an CloudWatch Logs log stream as a target.
ecs_task_parameters (Union[IResolvable, PipeTargetEcsTaskParametersProperty, Dict[str, Any], None]) – The parameters for using an Amazon ECS task as a target.
event_bridge_event_bus_parameters (Union[IResolvable, PipeTargetEventBridgeEventBusParametersProperty, Dict[str, Any], None]) – The parameters for using an EventBridge event bus as a target.
http_parameters (Union[IResolvable, PipeTargetHttpParametersProperty, Dict[str, Any], None]) – These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.
input_template (Optional[str]) –
Valid JSON text passed to the target. In this case, nothing from the event itself is passed to the target. For more information, see The JavaScript Object Notation (JSON) Data Interchange Format . To remove an input template, specify an empty string.
kinesis_stream_parameters (Union[IResolvable, PipeTargetKinesisStreamParametersProperty, Dict[str, Any], None]) – The parameters for using a Kinesis stream as a target.
lambda_function_parameters (Union[IResolvable, PipeTargetLambdaFunctionParametersProperty, Dict[str, Any], None]) – The parameters for using a Lambda function as a target.
redshift_data_parameters (Union[IResolvable, PipeTargetRedshiftDataParametersProperty, Dict[str, Any], None]) – These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.
sage_maker_pipeline_parameters (Union[IResolvable, PipeTargetSageMakerPipelineParametersProperty, Dict[str, Any], None]) – The parameters for using a SageMaker AI pipeline as a target.
sqs_queue_parameters (Union[IResolvable, PipeTargetSqsQueueParametersProperty, Dict[str, Any], None]) – The parameters for using a Amazon SQS stream as a target.
step_function_state_machine_parameters (Union[IResolvable, PipeTargetStateMachineParametersProperty, Dict[str, Any], None]) – The parameters for using a Step Functions state machine as a target.
timestream_parameters (Union[IResolvable, PipeTargetTimestreamParametersProperty, Dict[str, Any], None]) – The parameters for using a Timestream for LiveAnalytics table as a target.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.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

pipe_target_parameters_property = 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

batch_job_parameters

The parameters for using an AWS Batch job as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-batchjobparameters

cloud_watch_logs_parameters

The parameters for using an CloudWatch Logs log stream as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-cloudwatchlogsparameters

ecs_task_parameters

The parameters for using an Amazon ECS task as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-ecstaskparameters

event_bridge_event_bus_parameters

The parameters for using an EventBridge event bus as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-eventbridgeeventbusparameters

http_parameters

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-httpparameters

input_template

Valid JSON text passed to the target.

In this case, nothing from the event itself is passed to the target. For more information, see The JavaScript Object Notation (JSON) Data Interchange Format .

To remove an input template, specify an empty string.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-inputtemplate

kinesis_stream_parameters

The parameters for using a Kinesis stream as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-kinesisstreamparameters

lambda_function_parameters

The parameters for using a Lambda function as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-lambdafunctionparameters

redshift_data_parameters

These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-redshiftdataparameters

sage_maker_pipeline_parameters

The parameters for using a SageMaker AI pipeline as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-sagemakerpipelineparameters

sqs_queue_parameters

The parameters for using a Amazon SQS stream as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-sqsqueueparameters

step_function_state_machine_parameters

The parameters for using a Step Functions state machine as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-stepfunctionstatemachineparameters

timestream_parameters

The parameters for using a Timestream for LiveAnalytics table as a target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-timestreamparameters

PipeTargetRedshiftDataParametersProperty

class CfnPipePropsMixin.PipeTargetRedshiftDataParametersProperty(*, database=None, db_user=None, secret_manager_arn=None, sqls=None, statement_name=None, with_event=None)

Bases: object

These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.

Parameters:

database (Optional[str]) – The name of the database. Required when authenticating using temporary credentials.
db_user (Optional[str]) – The database user name. Required when authenticating using temporary credentials.
secret_manager_arn (Optional[str]) – The name or ARN of the secret that enables access to the database. Required when authenticating using Secrets Manager.
sqls (Optional[Sequence[str]]) – The SQL statement text to run.
statement_name (Optional[str]) – The name of the SQL statement. You can name the SQL statement when you create it to identify the query.
with_event (Union[bool, IResolvable, None]) – Indicates whether to send an event back to EventBridge after the SQL statement runs. Default: - false

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.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

pipe_target_redshift_data_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetRedshiftDataParametersProperty(
    database="database",
    db_user="dbUser",
    secret_manager_arn="secretManagerArn",
    sqls=["sqls"],
    statement_name="statementName",
    with_event=False
)

Attributes

database

The name of the database.

Required when authenticating using temporary credentials.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-database

db_user

The database user name.

Required when authenticating using temporary credentials.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-dbuser

secret_manager_arn

The name or ARN of the secret that enables access to the database.

Required when authenticating using Secrets Manager.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-secretmanagerarn

sqls

The SQL statement text to run.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-sqls

statement_name

The name of the SQL statement.

You can name the SQL statement when you create it to identify the query.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-statementname

with_event

Indicates whether to send an event back to EventBridge after the SQL statement runs.

Default:

false

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html#cfn-pipes-pipe-pipetargetredshiftdataparameters-withevent

PipeTargetSageMakerPipelineParametersProperty

class CfnPipePropsMixin.PipeTargetSageMakerPipelineParametersProperty(*, pipeline_parameter_list=None)

Bases: object

The parameters for using a SageMaker AI pipeline as a target.

Parameters:: pipeline_parameter_list (Union[IResolvable, Sequence[Union[IResolvable, SageMakerPipelineParameterProperty, Dict[str, Any]]], None]) – List of Parameter names and values for SageMaker AI Model Building Pipeline execution.
See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsagemakerpipelineparameters.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

pipe_target_sage_maker_pipeline_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetSageMakerPipelineParametersProperty(
    pipeline_parameter_list=[pipes_mixins.CfnPipePropsMixin.SageMakerPipelineParameterProperty(
        name="name",
        value="value"
    )]
)

Attributes

pipeline_parameter_list

List of Parameter names and values for SageMaker AI Model Building Pipeline execution.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsagemakerpipelineparameters.html#cfn-pipes-pipe-pipetargetsagemakerpipelineparameters-pipelineparameterlist

PipeTargetSqsQueueParametersProperty

class CfnPipePropsMixin.PipeTargetSqsQueueParametersProperty(*, message_deduplication_id=None, message_group_id=None)

Bases: object

The parameters for using a Amazon SQS stream as a target.

Parameters:

message_deduplication_id (Optional[str]) – This parameter applies only to FIFO (first-in-first-out) queues. The token used for deduplication of sent messages.
message_group_id (Optional[str]) – The FIFO message group ID to use as the target.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.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

pipe_target_sqs_queue_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetSqsQueueParametersProperty(
    message_deduplication_id="messageDeduplicationId",
    message_group_id="messageGroupId"
)

Attributes

message_deduplication_id

This parameter applies only to FIFO (first-in-first-out) queues.

The token used for deduplication of sent messages.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagededuplicationid

message_group_id

The FIFO message group ID to use as the target.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagegroupid

PipeTargetStateMachineParametersProperty

class CfnPipePropsMixin.PipeTargetStateMachineParametersProperty(*, invocation_type=None)

Bases: object

The parameters for using a Step Functions state machine as a target.

Parameters:

invocation_type (Optional[str]) –

Specify whether to invoke the Step Functions state machine synchronously or asynchronously. - REQUEST_RESPONSE (default) - Invoke synchronously. For more information, see StartSyncExecution in the AWS Step Functions API Reference . .. epigraph:: REQUEST_RESPONSE is not supported for STANDARD state machine workflows. - FIRE_AND_FORGET - Invoke asynchronously. For more information, see StartExecution in the AWS Step Functions API Reference . For more information, see Invocation types in the Amazon EventBridge User Guide .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetstatemachineparameters.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

pipe_target_state_machine_parameters_property = pipes_mixins.CfnPipePropsMixin.PipeTargetStateMachineParametersProperty(
    invocation_type="invocationType"
)

Attributes

invocation_type

Specify whether to invoke the Step Functions state machine synchronously or asynchronously.

REQUEST_RESPONSE (default) - Invoke synchronously. For more information, see StartSyncExecution in the AWS Step Functions API Reference .

REQUEST_RESPONSE is not supported for STANDARD state machine workflows.

FIRE_AND_FORGET - Invoke asynchronously. For more information, see StartExecution in the AWS Step Functions API Reference .

For more information, see Invocation types in the Amazon EventBridge User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetstatemachineparameters.html#cfn-pipes-pipe-pipetargetstatemachineparameters-invocationtype

PipeTargetTimestreamParametersProperty

class CfnPipePropsMixin.PipeTargetTimestreamParametersProperty(*, dimension_mappings=None, epoch_time_unit=None, multi_measure_mappings=None, single_measure_mappings=None, time_field_type=None, timestamp_format=None, time_value=None, version_value=None)

Bases: object

The parameters for using a Timestream for LiveAnalytics table as a target.

Parameters:

dimension_mappings (Union[IResolvable, Sequence[Union[IResolvable, DimensionMappingProperty, Dict[str, Any]]], None]) –
Map source data to dimensions in the target Timestream for LiveAnalytics table. For more information, see Amazon Timestream for LiveAnalytics concepts
epoch_time_unit (Optional[str]) – The granularity of the time units used. Default is MILLISECONDS . Required if TimeFieldType is specified as EPOCH .
multi_measure_mappings (Union[IResolvable, Sequence[Union[IResolvable, MultiMeasureMappingProperty, Dict[str, Any]]], None]) – Maps multiple measures from the source event to the same record in the specified Timestream for LiveAnalytics table.
single_measure_mappings (Union[IResolvable, Sequence[Union[IResolvable, SingleMeasureMappingProperty, Dict[str, Any]]], None]) – Mappings of single source data fields to individual records in the specified Timestream for LiveAnalytics table.
time_field_type (Optional[str]) – The type of time value used. The default is EPOCH .
timestamp_format (Optional[str]) – How to format the timestamps. For example, yyyy-MM-dd'T'HH:mm:ss'Z' . Required if TimeFieldType is specified as TIMESTAMP_FORMAT .
time_value (Optional[str]) – Dynamic path to the source data field that represents the time value for your data.
version_value (Optional[str]) – 64 bit version value or source data field that represents the version value for your data. Write requests with a higher version number will update the existing measure values of the record and version. In cases where the measure value is the same, the version will still be updated. Default value is 1. Timestream for LiveAnalytics does not support updating partial measure values in a record. Write requests for duplicate data with a higher version number will update the existing measure value and version. In cases where the measure value is the same, Version will still be updated. Default value is 1 . .. epigraph:: Version must be 1 or greater, or you will receive a ValidationException error.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.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

pipe_target_timestream_parameters_property = 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

dimension_mappings

Map source data to dimensions in the target Timestream for LiveAnalytics table.

For more information, see Amazon Timestream for LiveAnalytics concepts

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-dimensionmappings

epoch_time_unit

The granularity of the time units used. Default is MILLISECONDS .

Required if TimeFieldType is specified as EPOCH .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-epochtimeunit

multi_measure_mappings

Maps multiple measures from the source event to the same record in the specified Timestream for LiveAnalytics table.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-multimeasuremappings

single_measure_mappings

Mappings of single source data fields to individual records in the specified Timestream for LiveAnalytics table.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-singlemeasuremappings

time_field_type

The type of time value used.

The default is EPOCH .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-timefieldtype

time_value

Dynamic path to the source data field that represents the time value for your data.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-timevalue

timestamp_format

How to format the timestamps. For example, yyyy-MM-dd'T'HH:mm:ss'Z' .

Required if TimeFieldType is specified as TIMESTAMP_FORMAT .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-timestampformat

version_value

64 bit version value or source data field that represents the version value for your data.

Write requests with a higher version number will update the existing measure values of the record and version. In cases where the measure value is the same, the version will still be updated.

Default value is 1.

Timestream for LiveAnalytics does not support updating partial measure values in a record.

Write requests for duplicate data with a higher version number will update the existing measure value and version. In cases where the measure value is the same, Version will still be updated. Default value is 1 . .. epigraph:

``Version`` must be ``1`` or greater, or you will receive a ``ValidationException`` error.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargettimestreamparameters.html#cfn-pipes-pipe-pipetargettimestreamparameters-versionvalue

PlacementConstraintProperty

class CfnPipePropsMixin.PlacementConstraintProperty(*, expression=None, type=None)

Bases: object

An object representing a constraint on task placement.

To learn more, see Task Placement Constraints in the Amazon Elastic Container Service Developer Guide.

Parameters:

expression (Optional[str]) – A cluster query language expression to apply to the constraint. You cannot specify an expression if the constraint type is distinctInstance . To learn more, see Cluster Query Language in the Amazon Elastic Container Service Developer Guide.
type (Optional[str]) – The type of constraint. Use distinctInstance to ensure that each task in a particular group is running on a different container instance. Use memberOf to restrict the selection to a group of valid candidates.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementconstraint.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

placement_constraint_property = pipes_mixins.CfnPipePropsMixin.PlacementConstraintProperty(
    expression="expression",
    type="type"
)

Attributes

expression

A cluster query language expression to apply to the constraint.

You cannot specify an expression if the constraint type is distinctInstance . To learn more, see Cluster Query Language in the Amazon Elastic Container Service Developer Guide.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementconstraint.html#cfn-pipes-pipe-placementconstraint-expression

type

The type of constraint.

Use distinctInstance to ensure that each task in a particular group is running on a different container instance. Use memberOf to restrict the selection to a group of valid candidates.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementconstraint.html#cfn-pipes-pipe-placementconstraint-type

PlacementStrategyProperty

class CfnPipePropsMixin.PlacementStrategyProperty(*, field=None, type=None)

Bases: object

The task placement strategy for a task or service.

To learn more, see Task Placement Strategies in the Amazon Elastic Container Service Service Developer Guide.

Parameters:

field (Optional[str]) – The field to apply the placement strategy against. For the spread placement strategy, valid values are instanceId (or host, which has the same effect), or any platform or custom attribute that is applied to a container instance, such as attribute:ecs.availability-zone. For the binpack placement strategy, valid values are cpu and memory. For the random placement strategy, this field is not used.
type (Optional[str]) – The type of placement strategy. The random placement strategy randomly places tasks on available candidates. The spread placement strategy spreads placement across available candidates evenly based on the field parameter. The binpack strategy places tasks on available candidates that have the least available amount of the resource that is specified with the field parameter. For example, if you binpack on memory, a task is placed on the instance with the least amount of remaining memory (but still enough to run the task).

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementstrategy.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

placement_strategy_property = pipes_mixins.CfnPipePropsMixin.PlacementStrategyProperty(
    field="field",
    type="type"
)

Attributes

field

The field to apply the placement strategy against.

For the spread placement strategy, valid values are instanceId (or host, which has the same effect), or any platform or custom attribute that is applied to a container instance, such as attribute:ecs.availability-zone. For the binpack placement strategy, valid values are cpu and memory. For the random placement strategy, this field is not used.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementstrategy.html#cfn-pipes-pipe-placementstrategy-field

type

The type of placement strategy.

The random placement strategy randomly places tasks on available candidates. The spread placement strategy spreads placement across available candidates evenly based on the field parameter. The binpack strategy places tasks on available candidates that have the least available amount of the resource that is specified with the field parameter. For example, if you binpack on memory, a task is placed on the instance with the least amount of remaining memory (but still enough to run the task).

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementstrategy.html#cfn-pipes-pipe-placementstrategy-type

S3LogDestinationProperty

class CfnPipePropsMixin.S3LogDestinationProperty(*, bucket_name=None, bucket_owner=None, output_format=None, prefix=None)

Bases: object

Represents the Amazon S3 logging configuration settings for the pipe.

Parameters:

bucket_name (Optional[str]) – The name of the Amazon S3 bucket to which EventBridge delivers the log records for the pipe.
bucket_owner (Optional[str]) – The AWS account that owns the Amazon S3 bucket to which EventBridge delivers the log records for the pipe.
output_format (Optional[str]) – The format EventBridge uses for the log records. EventBridge currently only supports json formatting.
prefix (Optional[str]) – The prefix text with which to begin Amazon S3 log object names. For more information, see Organizing objects using prefixes in the Amazon Simple Storage Service User Guide .

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.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

s3_log_destination_property = pipes_mixins.CfnPipePropsMixin.S3LogDestinationProperty(
    bucket_name="bucketName",
    bucket_owner="bucketOwner",
    output_format="outputFormat",
    prefix="prefix"
)

Attributes

bucket_name

The name of the Amazon S3 bucket to which EventBridge delivers the log records for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.html#cfn-pipes-pipe-s3logdestination-bucketname

bucket_owner

The AWS account that owns the Amazon S3 bucket to which EventBridge delivers the log records for the pipe.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.html#cfn-pipes-pipe-s3logdestination-bucketowner

output_format

The format EventBridge uses for the log records.

EventBridge currently only supports json formatting.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.html#cfn-pipes-pipe-s3logdestination-outputformat

prefix

The prefix text with which to begin Amazon S3 log object names.

For more information, see Organizing objects using prefixes in the Amazon Simple Storage Service User Guide .

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.html#cfn-pipes-pipe-s3logdestination-prefix

SageMakerPipelineParameterProperty

class CfnPipePropsMixin.SageMakerPipelineParameterProperty(*, name=None, value=None)

Bases: object

Name/Value pair of a parameter to start execution of a SageMaker AI Model Building Pipeline.

Parameters:

name (Optional[str]) – Name of parameter to start execution of a SageMaker AI Model Building Pipeline.
value (Optional[str]) – Value of parameter to start execution of a SageMaker AI Model Building Pipeline.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-sagemakerpipelineparameter.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

sage_maker_pipeline_parameter_property = pipes_mixins.CfnPipePropsMixin.SageMakerPipelineParameterProperty(
    name="name",
    value="value"
)

Attributes

name

Name of parameter to start execution of a SageMaker AI Model Building Pipeline.

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

value

Value of parameter to start execution of a SageMaker AI Model Building Pipeline.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-sagemakerpipelineparameter.html#cfn-pipes-pipe-sagemakerpipelineparameter-value

SelfManagedKafkaAccessConfigurationCredentialsProperty

class CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationCredentialsProperty(*, basic_auth=None, client_certificate_tls_auth=None, sasl_scram256_auth=None, sasl_scram512_auth=None)

Bases: object

The AWS Secrets Manager secret that stores your stream credentials.

Parameters:

basic_auth (Optional[str]) – The ARN of the Secrets Manager secret.
client_certificate_tls_auth (Optional[str]) – The ARN of the Secrets Manager secret.
sasl_scram256_auth (Optional[str]) – The ARN of the Secrets Manager secret.
sasl_scram512_auth (Optional[str]) – The ARN of the Secrets Manager secret.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.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

self_managed_kafka_access_configuration_credentials_property = pipes_mixins.CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationCredentialsProperty(
    basic_auth="basicAuth",
    client_certificate_tls_auth="clientCertificateTlsAuth",
    sasl_scram256_auth="saslScram256Auth",
    sasl_scram512_auth="saslScram512Auth"
)

Attributes

basic_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials-basicauth

client_certificate_tls_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials-clientcertificatetlsauth

sasl_scram256_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials-saslscram256auth

sasl_scram512_auth

The ARN of the Secrets Manager secret.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials-saslscram512auth

SelfManagedKafkaAccessConfigurationVpcProperty

class CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationVpcProperty(*, security_group=None, subnets=None)

Bases: object

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

Parameters:

security_group (Optional[Sequence[str]]) – Specifies the security groups associated with the stream. These security groups must all be in the same VPC. You can specify as many as five security groups.
subnets (Optional[Sequence[str]]) – Specifies the subnets associated with the stream. These subnets must all be in the same VPC. You can specify as many as 16 subnets.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc.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

self_managed_kafka_access_configuration_vpc_property = pipes_mixins.CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationVpcProperty(
    security_group=["securityGroup"],
    subnets=["subnets"]
)

Attributes

security_group

Specifies the security groups associated with the stream.

These security groups must all be in the same VPC. You can specify as many as five security groups.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc-securitygroup

subnets

Specifies the subnets associated with the stream.

These subnets must all be in the same VPC. You can specify as many as 16 subnets.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc.html#cfn-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc-subnets

SingleMeasureMappingProperty

class CfnPipePropsMixin.SingleMeasureMappingProperty(*, measure_name=None, measure_value=None, measure_value_type=None)

Bases: object

Maps a single source data field to a single record in the specified Timestream for LiveAnalytics table.

For more information, see Amazon Timestream for LiveAnalytics concepts

Parameters:

measure_name (Optional[str]) – Target measure name for the measurement attribute in the Timestream table.
measure_value (Optional[str]) – Dynamic path of the source field to map to the measure in the record.
measure_value_type (Optional[str]) – Data type of the source field.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-singlemeasuremapping.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

single_measure_mapping_property = pipes_mixins.CfnPipePropsMixin.SingleMeasureMappingProperty(
    measure_name="measureName",
    measure_value="measureValue",
    measure_value_type="measureValueType"
)

Attributes

measure_name

Target measure name for the measurement attribute in the Timestream table.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-singlemeasuremapping.html#cfn-pipes-pipe-singlemeasuremapping-measurename

measure_value

Dynamic path of the source field to map to the measure in the record.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-singlemeasuremapping.html#cfn-pipes-pipe-singlemeasuremapping-measurevalue

measure_value_type

Data type of the source field.

See:: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-singlemeasuremapping.html#cfn-pipes-pipe-singlemeasuremapping-measurevaluetype