Skip to content

Type definitions#

Index > EventBridgePipes > Type definitions

Auto-generated documentation for EventBridgePipes type annotations stubs module mypy-boto3-pipes.

TimestampTypeDef#

# TimestampTypeDef definition

TimestampTypeDef = Union[
    datetime,
    str,
]

AwsVpcConfigurationUnionTypeDef#

# AwsVpcConfigurationUnionTypeDef definition

AwsVpcConfigurationUnionTypeDef = Union[
    AwsVpcConfigurationTypeDef,  # (1)
    AwsVpcConfigurationOutputTypeDef,  # (2)
]
  1. See AwsVpcConfigurationTypeDef
  2. See AwsVpcConfigurationOutputTypeDef

PipeEnrichmentHttpParametersUnionTypeDef#

# PipeEnrichmentHttpParametersUnionTypeDef definition

PipeEnrichmentHttpParametersUnionTypeDef = Union[
    PipeEnrichmentHttpParametersTypeDef,  # (1)
    PipeEnrichmentHttpParametersOutputTypeDef,  # (2)
]
  1. See PipeEnrichmentHttpParametersTypeDef
  2. See PipeEnrichmentHttpParametersOutputTypeDef

PipeTargetEventBridgeEventBusParametersUnionTypeDef#

# PipeTargetEventBridgeEventBusParametersUnionTypeDef definition

PipeTargetEventBridgeEventBusParametersUnionTypeDef = Union[
    PipeTargetEventBridgeEventBusParametersTypeDef,  # (1)
    PipeTargetEventBridgeEventBusParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetEventBridgeEventBusParametersTypeDef
  2. See PipeTargetEventBridgeEventBusParametersOutputTypeDef

PipeTargetHttpParametersUnionTypeDef#

# PipeTargetHttpParametersUnionTypeDef definition

PipeTargetHttpParametersUnionTypeDef = Union[
    PipeTargetHttpParametersTypeDef,  # (1)
    PipeTargetHttpParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetHttpParametersTypeDef
  2. See PipeTargetHttpParametersOutputTypeDef

PipeTargetRedshiftDataParametersUnionTypeDef#

# PipeTargetRedshiftDataParametersUnionTypeDef definition

PipeTargetRedshiftDataParametersUnionTypeDef = Union[
    PipeTargetRedshiftDataParametersTypeDef,  # (1)
    PipeTargetRedshiftDataParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetRedshiftDataParametersTypeDef
  2. See PipeTargetRedshiftDataParametersOutputTypeDef

SelfManagedKafkaAccessConfigurationVpcUnionTypeDef#

# SelfManagedKafkaAccessConfigurationVpcUnionTypeDef definition

SelfManagedKafkaAccessConfigurationVpcUnionTypeDef = Union[
    SelfManagedKafkaAccessConfigurationVpcTypeDef,  # (1)
    SelfManagedKafkaAccessConfigurationVpcOutputTypeDef,  # (2)
]
  1. See SelfManagedKafkaAccessConfigurationVpcTypeDef
  2. See SelfManagedKafkaAccessConfigurationVpcOutputTypeDef

BatchContainerOverridesUnionTypeDef#

# BatchContainerOverridesUnionTypeDef definition

BatchContainerOverridesUnionTypeDef = Union[
    BatchContainerOverridesTypeDef,  # (1)
    BatchContainerOverridesOutputTypeDef,  # (2)
]
  1. See BatchContainerOverridesTypeDef
  2. See BatchContainerOverridesOutputTypeDef

EcsContainerOverrideUnionTypeDef#

# EcsContainerOverrideUnionTypeDef definition

EcsContainerOverrideUnionTypeDef = Union[
    EcsContainerOverrideTypeDef,  # (1)
    EcsContainerOverrideOutputTypeDef,  # (2)
]
  1. See EcsContainerOverrideTypeDef
  2. See EcsContainerOverrideOutputTypeDef

FilterCriteriaUnionTypeDef#

# FilterCriteriaUnionTypeDef definition

FilterCriteriaUnionTypeDef = Union[
    FilterCriteriaTypeDef,  # (1)
    FilterCriteriaOutputTypeDef,  # (2)
]
  1. See FilterCriteriaTypeDef
  2. See FilterCriteriaOutputTypeDef

MultiMeasureMappingUnionTypeDef#

# MultiMeasureMappingUnionTypeDef definition

MultiMeasureMappingUnionTypeDef = Union[
    MultiMeasureMappingTypeDef,  # (1)
    MultiMeasureMappingOutputTypeDef,  # (2)
]
  1. See MultiMeasureMappingTypeDef
  2. See MultiMeasureMappingOutputTypeDef

PipeSourceKinesisStreamParametersUnionTypeDef#

# PipeSourceKinesisStreamParametersUnionTypeDef definition

PipeSourceKinesisStreamParametersUnionTypeDef = Union[
    PipeSourceKinesisStreamParametersTypeDef,  # (1)
    PipeSourceKinesisStreamParametersOutputTypeDef,  # (2)
]
  1. See PipeSourceKinesisStreamParametersTypeDef
  2. See PipeSourceKinesisStreamParametersOutputTypeDef

PipeTargetSageMakerPipelineParametersUnionTypeDef#

# PipeTargetSageMakerPipelineParametersUnionTypeDef definition

PipeTargetSageMakerPipelineParametersUnionTypeDef = Union[
    PipeTargetSageMakerPipelineParametersTypeDef,  # (1)
    PipeTargetSageMakerPipelineParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetSageMakerPipelineParametersTypeDef
  2. See PipeTargetSageMakerPipelineParametersOutputTypeDef

NetworkConfigurationUnionTypeDef#

# NetworkConfigurationUnionTypeDef definition

NetworkConfigurationUnionTypeDef = Union[
    NetworkConfigurationTypeDef,  # (1)
    NetworkConfigurationOutputTypeDef,  # (2)
]
  1. See NetworkConfigurationTypeDef
  2. See NetworkConfigurationOutputTypeDef

PipeSourceSelfManagedKafkaParametersUnionTypeDef#

# PipeSourceSelfManagedKafkaParametersUnionTypeDef definition

PipeSourceSelfManagedKafkaParametersUnionTypeDef = Union[
    PipeSourceSelfManagedKafkaParametersTypeDef,  # (1)
    PipeSourceSelfManagedKafkaParametersOutputTypeDef,  # (2)
]
  1. See PipeSourceSelfManagedKafkaParametersTypeDef
  2. See PipeSourceSelfManagedKafkaParametersOutputTypeDef

PipeTargetBatchJobParametersUnionTypeDef#

# PipeTargetBatchJobParametersUnionTypeDef definition

PipeTargetBatchJobParametersUnionTypeDef = Union[
    PipeTargetBatchJobParametersTypeDef,  # (1)
    PipeTargetBatchJobParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetBatchJobParametersTypeDef
  2. See PipeTargetBatchJobParametersOutputTypeDef

EcsTaskOverrideUnionTypeDef#

# EcsTaskOverrideUnionTypeDef definition

EcsTaskOverrideUnionTypeDef = Union[
    EcsTaskOverrideTypeDef,  # (1)
    EcsTaskOverrideOutputTypeDef,  # (2)
]
  1. See EcsTaskOverrideTypeDef
  2. See EcsTaskOverrideOutputTypeDef

PipeTargetTimestreamParametersUnionTypeDef#

# PipeTargetTimestreamParametersUnionTypeDef definition

PipeTargetTimestreamParametersUnionTypeDef = Union[
    PipeTargetTimestreamParametersTypeDef,  # (1)
    PipeTargetTimestreamParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetTimestreamParametersTypeDef
  2. See PipeTargetTimestreamParametersOutputTypeDef

PipeTargetEcsTaskParametersUnionTypeDef#

# PipeTargetEcsTaskParametersUnionTypeDef definition

PipeTargetEcsTaskParametersUnionTypeDef = Union[
    PipeTargetEcsTaskParametersTypeDef,  # (1)
    PipeTargetEcsTaskParametersOutputTypeDef,  # (2)
]
  1. See PipeTargetEcsTaskParametersTypeDef
  2. See PipeTargetEcsTaskParametersOutputTypeDef

AwsVpcConfigurationOutputTypeDef#

# AwsVpcConfigurationOutputTypeDef definition

class AwsVpcConfigurationOutputTypeDef(TypedDict):
    Subnets: list[str],
    SecurityGroups: NotRequired[list[str]],
    AssignPublicIp: NotRequired[AssignPublicIpType],  # (1)
  1. See AssignPublicIpType

AwsVpcConfigurationTypeDef#

# AwsVpcConfigurationTypeDef definition

class AwsVpcConfigurationTypeDef(TypedDict):
    Subnets: Sequence[str],
    SecurityGroups: NotRequired[Sequence[str]],
    AssignPublicIp: NotRequired[AssignPublicIpType],  # (1)
  1. See AssignPublicIpType

BatchArrayPropertiesTypeDef#

# BatchArrayPropertiesTypeDef definition

class BatchArrayPropertiesTypeDef(TypedDict):
    Size: NotRequired[int],

BatchEnvironmentVariableTypeDef#

# BatchEnvironmentVariableTypeDef definition

class BatchEnvironmentVariableTypeDef(TypedDict):
    Name: NotRequired[str],
    Value: NotRequired[str],

BatchResourceRequirementTypeDef#

# BatchResourceRequirementTypeDef definition

class BatchResourceRequirementTypeDef(TypedDict):
    Type: BatchResourceRequirementTypeType,  # (1)
    Value: str,
  1. See BatchResourceRequirementTypeType

BatchJobDependencyTypeDef#

# BatchJobDependencyTypeDef definition

class BatchJobDependencyTypeDef(TypedDict):
    JobId: NotRequired[str],
    Type: NotRequired[BatchJobDependencyTypeType],  # (1)
  1. See BatchJobDependencyTypeType

BatchRetryStrategyTypeDef#

# BatchRetryStrategyTypeDef definition

class BatchRetryStrategyTypeDef(TypedDict):
    Attempts: NotRequired[int],

CapacityProviderStrategyItemTypeDef#

# CapacityProviderStrategyItemTypeDef definition

class CapacityProviderStrategyItemTypeDef(TypedDict):
    capacityProvider: str,
    weight: NotRequired[int],
    base: NotRequired[int],

CloudwatchLogsLogDestinationParametersTypeDef#

# CloudwatchLogsLogDestinationParametersTypeDef definition

class CloudwatchLogsLogDestinationParametersTypeDef(TypedDict):
    LogGroupArn: str,

CloudwatchLogsLogDestinationTypeDef#

# CloudwatchLogsLogDestinationTypeDef definition

class CloudwatchLogsLogDestinationTypeDef(TypedDict):
    LogGroupArn: NotRequired[str],

ResponseMetadataTypeDef#

# ResponseMetadataTypeDef definition

class ResponseMetadataTypeDef(TypedDict):
    RequestId: str,
    HTTPStatusCode: int,
    HTTPHeaders: dict[str, str],
    RetryAttempts: int,
    HostId: NotRequired[str],

DeadLetterConfigTypeDef#

# DeadLetterConfigTypeDef definition

class DeadLetterConfigTypeDef(TypedDict):
    Arn: NotRequired[str],

DeletePipeRequestRequestTypeDef#

# DeletePipeRequestRequestTypeDef definition

class DeletePipeRequestRequestTypeDef(TypedDict):
    Name: str,

DescribePipeRequestRequestTypeDef#

# DescribePipeRequestRequestTypeDef definition

class DescribePipeRequestRequestTypeDef(TypedDict):
    Name: str,

DimensionMappingTypeDef#

# DimensionMappingTypeDef definition

class DimensionMappingTypeDef(TypedDict):
    DimensionValue: str,
    DimensionValueType: DimensionValueTypeType,  # (1)
    DimensionName: str,
  1. See DimensionValueTypeType

EcsEnvironmentFileTypeDef#

# EcsEnvironmentFileTypeDef definition

class EcsEnvironmentFileTypeDef(TypedDict):
    type: EcsEnvironmentFileTypeType,  # (1)
    value: str,
  1. See EcsEnvironmentFileTypeType

EcsEnvironmentVariableTypeDef#

# EcsEnvironmentVariableTypeDef definition

class EcsEnvironmentVariableTypeDef(TypedDict):
    name: NotRequired[str],
    value: NotRequired[str],

EcsResourceRequirementTypeDef#

# EcsResourceRequirementTypeDef definition

class EcsResourceRequirementTypeDef(TypedDict):
    type: EcsResourceRequirementTypeType,  # (1)
    value: str,
  1. See EcsResourceRequirementTypeType

EcsEphemeralStorageTypeDef#

# EcsEphemeralStorageTypeDef definition

class EcsEphemeralStorageTypeDef(TypedDict):
    sizeInGiB: int,

EcsInferenceAcceleratorOverrideTypeDef#

# EcsInferenceAcceleratorOverrideTypeDef definition

class EcsInferenceAcceleratorOverrideTypeDef(TypedDict):
    deviceName: NotRequired[str],
    deviceType: NotRequired[str],

FilterTypeDef#

# FilterTypeDef definition

class FilterTypeDef(TypedDict):
    Pattern: NotRequired[str],

FirehoseLogDestinationParametersTypeDef#

# FirehoseLogDestinationParametersTypeDef definition

class FirehoseLogDestinationParametersTypeDef(TypedDict):
    DeliveryStreamArn: str,

FirehoseLogDestinationTypeDef#

# FirehoseLogDestinationTypeDef definition

class FirehoseLogDestinationTypeDef(TypedDict):
    DeliveryStreamArn: NotRequired[str],

PaginatorConfigTypeDef#

# PaginatorConfigTypeDef definition

class PaginatorConfigTypeDef(TypedDict):
    MaxItems: NotRequired[int],
    PageSize: NotRequired[int],
    StartingToken: NotRequired[str],

ListPipesRequestRequestTypeDef#

# ListPipesRequestRequestTypeDef definition

class ListPipesRequestRequestTypeDef(TypedDict):
    NamePrefix: NotRequired[str],
    DesiredState: NotRequired[RequestedPipeStateType],  # (1)
    CurrentState: NotRequired[PipeStateType],  # (2)
    SourcePrefix: NotRequired[str],
    TargetPrefix: NotRequired[str],
    NextToken: NotRequired[str],
    Limit: NotRequired[int],
  1. See RequestedPipeStateType
  2. See PipeStateType

PipeTypeDef#

# PipeTypeDef definition

class PipeTypeDef(TypedDict):
    Name: NotRequired[str],
    Arn: NotRequired[str],
    DesiredState: NotRequired[RequestedPipeStateType],  # (1)
    CurrentState: NotRequired[PipeStateType],  # (2)
    StateReason: NotRequired[str],
    CreationTime: NotRequired[datetime],
    LastModifiedTime: NotRequired[datetime],
    Source: NotRequired[str],
    Target: NotRequired[str],
    Enrichment: NotRequired[str],
  1. See RequestedPipeStateType
  2. See PipeStateType

ListTagsForResourceRequestRequestTypeDef#

# ListTagsForResourceRequestRequestTypeDef definition

class ListTagsForResourceRequestRequestTypeDef(TypedDict):
    resourceArn: str,

MQBrokerAccessCredentialsTypeDef#

# MQBrokerAccessCredentialsTypeDef definition

class MQBrokerAccessCredentialsTypeDef(TypedDict):
    BasicAuth: NotRequired[str],

MSKAccessCredentialsTypeDef#

# MSKAccessCredentialsTypeDef definition

class MSKAccessCredentialsTypeDef(TypedDict):
    SaslScram512Auth: NotRequired[str],
    ClientCertificateTlsAuth: NotRequired[str],

MultiMeasureAttributeMappingTypeDef#

# MultiMeasureAttributeMappingTypeDef definition

class MultiMeasureAttributeMappingTypeDef(TypedDict):
    MeasureValue: str,
    MeasureValueType: MeasureValueTypeType,  # (1)
    MultiMeasureAttributeName: str,
  1. See MeasureValueTypeType

PipeEnrichmentHttpParametersOutputTypeDef#

# PipeEnrichmentHttpParametersOutputTypeDef definition

class PipeEnrichmentHttpParametersOutputTypeDef(TypedDict):
    PathParameterValues: NotRequired[list[str]],
    HeaderParameters: NotRequired[dict[str, str]],
    QueryStringParameters: NotRequired[dict[str, str]],

PipeEnrichmentHttpParametersTypeDef#

# PipeEnrichmentHttpParametersTypeDef definition

class PipeEnrichmentHttpParametersTypeDef(TypedDict):
    PathParameterValues: NotRequired[Sequence[str]],
    HeaderParameters: NotRequired[Mapping[str, str]],
    QueryStringParameters: NotRequired[Mapping[str, str]],

S3LogDestinationParametersTypeDef#

# S3LogDestinationParametersTypeDef definition

class S3LogDestinationParametersTypeDef(TypedDict):
    BucketName: str,
    BucketOwner: str,
    OutputFormat: NotRequired[S3OutputFormatType],  # (1)
    Prefix: NotRequired[str],
  1. See S3OutputFormatType

S3LogDestinationTypeDef#

# S3LogDestinationTypeDef definition

class S3LogDestinationTypeDef(TypedDict):
    BucketName: NotRequired[str],
    Prefix: NotRequired[str],
    BucketOwner: NotRequired[str],
    OutputFormat: NotRequired[S3OutputFormatType],  # (1)
  1. See S3OutputFormatType

PipeSourceSqsQueueParametersTypeDef#

# PipeSourceSqsQueueParametersTypeDef definition

class PipeSourceSqsQueueParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],

SelfManagedKafkaAccessConfigurationCredentialsTypeDef#

# SelfManagedKafkaAccessConfigurationCredentialsTypeDef definition

class SelfManagedKafkaAccessConfigurationCredentialsTypeDef(TypedDict):
    BasicAuth: NotRequired[str],
    SaslScram512Auth: NotRequired[str],
    SaslScram256Auth: NotRequired[str],
    ClientCertificateTlsAuth: NotRequired[str],

SelfManagedKafkaAccessConfigurationVpcOutputTypeDef#

# SelfManagedKafkaAccessConfigurationVpcOutputTypeDef definition

class SelfManagedKafkaAccessConfigurationVpcOutputTypeDef(TypedDict):
    Subnets: NotRequired[list[str]],
    SecurityGroup: NotRequired[list[str]],

PipeTargetCloudWatchLogsParametersTypeDef#

# PipeTargetCloudWatchLogsParametersTypeDef definition

class PipeTargetCloudWatchLogsParametersTypeDef(TypedDict):
    LogStreamName: NotRequired[str],
    Timestamp: NotRequired[str],

PlacementConstraintTypeDef#

# PlacementConstraintTypeDef definition

class PlacementConstraintTypeDef(TypedDict):
    type: NotRequired[PlacementConstraintTypeType],  # (1)
    expression: NotRequired[str],
  1. See PlacementConstraintTypeType

PlacementStrategyTypeDef#

# PlacementStrategyTypeDef definition

class PlacementStrategyTypeDef(TypedDict):
    type: NotRequired[PlacementStrategyTypeType],  # (1)
    field: NotRequired[str],
  1. See PlacementStrategyTypeType

TagTypeDef#

# TagTypeDef definition

class TagTypeDef(TypedDict):
    Key: str,
    Value: str,

PipeTargetEventBridgeEventBusParametersOutputTypeDef#

# PipeTargetEventBridgeEventBusParametersOutputTypeDef definition

class PipeTargetEventBridgeEventBusParametersOutputTypeDef(TypedDict):
    EndpointId: NotRequired[str],
    DetailType: NotRequired[str],
    Source: NotRequired[str],
    Resources: NotRequired[list[str]],
    Time: NotRequired[str],

PipeTargetEventBridgeEventBusParametersTypeDef#

# PipeTargetEventBridgeEventBusParametersTypeDef definition

class PipeTargetEventBridgeEventBusParametersTypeDef(TypedDict):
    EndpointId: NotRequired[str],
    DetailType: NotRequired[str],
    Source: NotRequired[str],
    Resources: NotRequired[Sequence[str]],
    Time: NotRequired[str],

PipeTargetHttpParametersOutputTypeDef#

# PipeTargetHttpParametersOutputTypeDef definition

class PipeTargetHttpParametersOutputTypeDef(TypedDict):
    PathParameterValues: NotRequired[list[str]],
    HeaderParameters: NotRequired[dict[str, str]],
    QueryStringParameters: NotRequired[dict[str, str]],

PipeTargetHttpParametersTypeDef#

# PipeTargetHttpParametersTypeDef definition

class PipeTargetHttpParametersTypeDef(TypedDict):
    PathParameterValues: NotRequired[Sequence[str]],
    HeaderParameters: NotRequired[Mapping[str, str]],
    QueryStringParameters: NotRequired[Mapping[str, str]],

PipeTargetKinesisStreamParametersTypeDef#

# PipeTargetKinesisStreamParametersTypeDef definition

class PipeTargetKinesisStreamParametersTypeDef(TypedDict):
    PartitionKey: str,

PipeTargetLambdaFunctionParametersTypeDef#

# PipeTargetLambdaFunctionParametersTypeDef definition

class PipeTargetLambdaFunctionParametersTypeDef(TypedDict):
    InvocationType: NotRequired[PipeTargetInvocationTypeType],  # (1)
  1. See PipeTargetInvocationTypeType

PipeTargetRedshiftDataParametersOutputTypeDef#

# PipeTargetRedshiftDataParametersOutputTypeDef definition

class PipeTargetRedshiftDataParametersOutputTypeDef(TypedDict):
    Database: str,
    Sqls: list[str],
    SecretManagerArn: NotRequired[str],
    DbUser: NotRequired[str],
    StatementName: NotRequired[str],
    WithEvent: NotRequired[bool],

PipeTargetSqsQueueParametersTypeDef#

# PipeTargetSqsQueueParametersTypeDef definition

class PipeTargetSqsQueueParametersTypeDef(TypedDict):
    MessageGroupId: NotRequired[str],
    MessageDeduplicationId: NotRequired[str],

PipeTargetStateMachineParametersTypeDef#

# PipeTargetStateMachineParametersTypeDef definition

class PipeTargetStateMachineParametersTypeDef(TypedDict):
    InvocationType: NotRequired[PipeTargetInvocationTypeType],  # (1)
  1. See PipeTargetInvocationTypeType

PipeTargetRedshiftDataParametersTypeDef#

# PipeTargetRedshiftDataParametersTypeDef definition

class PipeTargetRedshiftDataParametersTypeDef(TypedDict):
    Database: str,
    Sqls: Sequence[str],
    SecretManagerArn: NotRequired[str],
    DbUser: NotRequired[str],
    StatementName: NotRequired[str],
    WithEvent: NotRequired[bool],

SageMakerPipelineParameterTypeDef#

# SageMakerPipelineParameterTypeDef definition

class SageMakerPipelineParameterTypeDef(TypedDict):
    Name: str,
    Value: str,

SingleMeasureMappingTypeDef#

# SingleMeasureMappingTypeDef definition

class SingleMeasureMappingTypeDef(TypedDict):
    MeasureValue: str,
    MeasureValueType: MeasureValueTypeType,  # (1)
    MeasureName: str,
  1. See MeasureValueTypeType

SelfManagedKafkaAccessConfigurationVpcTypeDef#

# SelfManagedKafkaAccessConfigurationVpcTypeDef definition

class SelfManagedKafkaAccessConfigurationVpcTypeDef(TypedDict):
    Subnets: NotRequired[Sequence[str]],
    SecurityGroup: NotRequired[Sequence[str]],

StartPipeRequestRequestTypeDef#

# StartPipeRequestRequestTypeDef definition

class StartPipeRequestRequestTypeDef(TypedDict):
    Name: str,

StopPipeRequestRequestTypeDef#

# StopPipeRequestRequestTypeDef definition

class StopPipeRequestRequestTypeDef(TypedDict):
    Name: str,

TagResourceRequestRequestTypeDef#

# TagResourceRequestRequestTypeDef definition

class TagResourceRequestRequestTypeDef(TypedDict):
    resourceArn: str,
    tags: Mapping[str, str],

UntagResourceRequestRequestTypeDef#

# UntagResourceRequestRequestTypeDef definition

class UntagResourceRequestRequestTypeDef(TypedDict):
    resourceArn: str,
    tagKeys: Sequence[str],

UpdatePipeSourceSqsQueueParametersTypeDef#

# UpdatePipeSourceSqsQueueParametersTypeDef definition

class UpdatePipeSourceSqsQueueParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],

NetworkConfigurationOutputTypeDef#

# NetworkConfigurationOutputTypeDef definition

class NetworkConfigurationOutputTypeDef(TypedDict):
    awsvpcConfiguration: NotRequired[AwsVpcConfigurationOutputTypeDef],  # (1)
  1. See AwsVpcConfigurationOutputTypeDef

BatchContainerOverridesOutputTypeDef#

# BatchContainerOverridesOutputTypeDef definition

class BatchContainerOverridesOutputTypeDef(TypedDict):
    Command: NotRequired[list[str]],
    Environment: NotRequired[list[BatchEnvironmentVariableTypeDef]],  # (1)
    InstanceType: NotRequired[str],
    ResourceRequirements: NotRequired[list[BatchResourceRequirementTypeDef]],  # (2)
  1. See BatchEnvironmentVariableTypeDef
  2. See BatchResourceRequirementTypeDef

BatchContainerOverridesTypeDef#

# BatchContainerOverridesTypeDef definition

class BatchContainerOverridesTypeDef(TypedDict):
    Command: NotRequired[Sequence[str]],
    Environment: NotRequired[Sequence[BatchEnvironmentVariableTypeDef]],  # (1)
    InstanceType: NotRequired[str],
    ResourceRequirements: NotRequired[Sequence[BatchResourceRequirementTypeDef]],  # (2)
  1. See BatchEnvironmentVariableTypeDef
  2. See BatchResourceRequirementTypeDef

CreatePipeResponseTypeDef#

# CreatePipeResponseTypeDef definition

class CreatePipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    DesiredState: RequestedPipeStateType,  # (1)
    CurrentState: PipeStateType,  # (2)
    CreationTime: datetime,
    LastModifiedTime: datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See RequestedPipeStateType
  2. See PipeStateType
  3. See ResponseMetadataTypeDef

DeletePipeResponseTypeDef#

# DeletePipeResponseTypeDef definition

class DeletePipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    DesiredState: RequestedPipeStateDescribeResponseType,  # (1)
    CurrentState: PipeStateType,  # (2)
    CreationTime: datetime,
    LastModifiedTime: datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See RequestedPipeStateDescribeResponseType
  2. See PipeStateType
  3. See ResponseMetadataTypeDef

ListTagsForResourceResponseTypeDef#

# ListTagsForResourceResponseTypeDef definition

class ListTagsForResourceResponseTypeDef(TypedDict):
    tags: dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

StartPipeResponseTypeDef#

# StartPipeResponseTypeDef definition

class StartPipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    DesiredState: RequestedPipeStateType,  # (1)
    CurrentState: PipeStateType,  # (2)
    CreationTime: datetime,
    LastModifiedTime: datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See RequestedPipeStateType
  2. See PipeStateType
  3. See ResponseMetadataTypeDef

StopPipeResponseTypeDef#

# StopPipeResponseTypeDef definition

class StopPipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    DesiredState: RequestedPipeStateType,  # (1)
    CurrentState: PipeStateType,  # (2)
    CreationTime: datetime,
    LastModifiedTime: datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See RequestedPipeStateType
  2. See PipeStateType
  3. See ResponseMetadataTypeDef

UpdatePipeResponseTypeDef#

# UpdatePipeResponseTypeDef definition

class UpdatePipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    DesiredState: RequestedPipeStateType,  # (1)
    CurrentState: PipeStateType,  # (2)
    CreationTime: datetime,
    LastModifiedTime: datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See RequestedPipeStateType
  2. See PipeStateType
  3. See ResponseMetadataTypeDef

PipeSourceDynamoDBStreamParametersTypeDef#

# PipeSourceDynamoDBStreamParametersTypeDef definition

class PipeSourceDynamoDBStreamParametersTypeDef(TypedDict):
    StartingPosition: DynamoDBStreamStartPositionType,  # (3)
    BatchSize: NotRequired[int],
    DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef],  # (1)
    OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType],  # (2)
    MaximumBatchingWindowInSeconds: NotRequired[int],
    MaximumRecordAgeInSeconds: NotRequired[int],
    MaximumRetryAttempts: NotRequired[int],
    ParallelizationFactor: NotRequired[int],
  1. See DeadLetterConfigTypeDef
  2. See OnPartialBatchItemFailureStreamsType
  3. See DynamoDBStreamStartPositionType

PipeSourceKinesisStreamParametersOutputTypeDef#

# PipeSourceKinesisStreamParametersOutputTypeDef definition

class PipeSourceKinesisStreamParametersOutputTypeDef(TypedDict):
    StartingPosition: KinesisStreamStartPositionType,  # (3)
    BatchSize: NotRequired[int],
    DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef],  # (1)
    OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType],  # (2)
    MaximumBatchingWindowInSeconds: NotRequired[int],
    MaximumRecordAgeInSeconds: NotRequired[int],
    MaximumRetryAttempts: NotRequired[int],
    ParallelizationFactor: NotRequired[int],
    StartingPositionTimestamp: NotRequired[datetime],
  1. See DeadLetterConfigTypeDef
  2. See OnPartialBatchItemFailureStreamsType
  3. See KinesisStreamStartPositionType

UpdatePipeSourceDynamoDBStreamParametersTypeDef#

# UpdatePipeSourceDynamoDBStreamParametersTypeDef definition

class UpdatePipeSourceDynamoDBStreamParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef],  # (1)
    OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType],  # (2)
    MaximumBatchingWindowInSeconds: NotRequired[int],
    MaximumRecordAgeInSeconds: NotRequired[int],
    MaximumRetryAttempts: NotRequired[int],
    ParallelizationFactor: NotRequired[int],
  1. See DeadLetterConfigTypeDef
  2. See OnPartialBatchItemFailureStreamsType

UpdatePipeSourceKinesisStreamParametersTypeDef#

# UpdatePipeSourceKinesisStreamParametersTypeDef definition

class UpdatePipeSourceKinesisStreamParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef],  # (1)
    OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType],  # (2)
    MaximumBatchingWindowInSeconds: NotRequired[int],
    MaximumRecordAgeInSeconds: NotRequired[int],
    MaximumRetryAttempts: NotRequired[int],
    ParallelizationFactor: NotRequired[int],
  1. See DeadLetterConfigTypeDef
  2. See OnPartialBatchItemFailureStreamsType

EcsContainerOverrideOutputTypeDef#

# EcsContainerOverrideOutputTypeDef definition

class EcsContainerOverrideOutputTypeDef(TypedDict):
    Command: NotRequired[list[str]],
    Cpu: NotRequired[int],
    Environment: NotRequired[list[EcsEnvironmentVariableTypeDef]],  # (1)
    EnvironmentFiles: NotRequired[list[EcsEnvironmentFileTypeDef]],  # (2)
    Memory: NotRequired[int],
    MemoryReservation: NotRequired[int],
    Name: NotRequired[str],
    ResourceRequirements: NotRequired[list[EcsResourceRequirementTypeDef]],  # (3)
  1. See EcsEnvironmentVariableTypeDef
  2. See EcsEnvironmentFileTypeDef
  3. See EcsResourceRequirementTypeDef

EcsContainerOverrideTypeDef#

# EcsContainerOverrideTypeDef definition

class EcsContainerOverrideTypeDef(TypedDict):
    Command: NotRequired[Sequence[str]],
    Cpu: NotRequired[int],
    Environment: NotRequired[Sequence[EcsEnvironmentVariableTypeDef]],  # (1)
    EnvironmentFiles: NotRequired[Sequence[EcsEnvironmentFileTypeDef]],  # (2)
    Memory: NotRequired[int],
    MemoryReservation: NotRequired[int],
    Name: NotRequired[str],
    ResourceRequirements: NotRequired[Sequence[EcsResourceRequirementTypeDef]],  # (3)
  1. See EcsEnvironmentVariableTypeDef
  2. See EcsEnvironmentFileTypeDef
  3. See EcsResourceRequirementTypeDef

FilterCriteriaOutputTypeDef#

# FilterCriteriaOutputTypeDef definition

class FilterCriteriaOutputTypeDef(TypedDict):
    Filters: NotRequired[list[FilterTypeDef]],  # (1)
  1. See FilterTypeDef

FilterCriteriaTypeDef#

# FilterCriteriaTypeDef definition

class FilterCriteriaTypeDef(TypedDict):
    Filters: NotRequired[Sequence[FilterTypeDef]],  # (1)
  1. See FilterTypeDef

ListPipesRequestPaginateTypeDef#

# ListPipesRequestPaginateTypeDef definition

class ListPipesRequestPaginateTypeDef(TypedDict):
    NamePrefix: NotRequired[str],
    DesiredState: NotRequired[RequestedPipeStateType],  # (1)
    CurrentState: NotRequired[PipeStateType],  # (2)
    SourcePrefix: NotRequired[str],
    TargetPrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (3)
  1. See RequestedPipeStateType
  2. See PipeStateType
  3. See PaginatorConfigTypeDef

ListPipesResponseTypeDef#

# ListPipesResponseTypeDef definition

class ListPipesResponseTypeDef(TypedDict):
    Pipes: list[PipeTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See PipeTypeDef
  2. See ResponseMetadataTypeDef

PipeSourceActiveMQBrokerParametersTypeDef#

# PipeSourceActiveMQBrokerParametersTypeDef definition

class PipeSourceActiveMQBrokerParametersTypeDef(TypedDict):
    Credentials: MQBrokerAccessCredentialsTypeDef,  # (1)
    QueueName: str,
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
  1. See MQBrokerAccessCredentialsTypeDef

PipeSourceRabbitMQBrokerParametersTypeDef#

# PipeSourceRabbitMQBrokerParametersTypeDef definition

class PipeSourceRabbitMQBrokerParametersTypeDef(TypedDict):
    Credentials: MQBrokerAccessCredentialsTypeDef,  # (1)
    QueueName: str,
    VirtualHost: NotRequired[str],
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
  1. See MQBrokerAccessCredentialsTypeDef

UpdatePipeSourceActiveMQBrokerParametersTypeDef#

# UpdatePipeSourceActiveMQBrokerParametersTypeDef definition

class UpdatePipeSourceActiveMQBrokerParametersTypeDef(TypedDict):
    Credentials: MQBrokerAccessCredentialsTypeDef,  # (1)
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
  1. See MQBrokerAccessCredentialsTypeDef

UpdatePipeSourceRabbitMQBrokerParametersTypeDef#

# UpdatePipeSourceRabbitMQBrokerParametersTypeDef definition

class UpdatePipeSourceRabbitMQBrokerParametersTypeDef(TypedDict):
    Credentials: MQBrokerAccessCredentialsTypeDef,  # (1)
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
  1. See MQBrokerAccessCredentialsTypeDef

PipeSourceManagedStreamingKafkaParametersTypeDef#

# PipeSourceManagedStreamingKafkaParametersTypeDef definition

class PipeSourceManagedStreamingKafkaParametersTypeDef(TypedDict):
    TopicName: str,
    StartingPosition: NotRequired[MSKStartPositionType],  # (1)
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
    ConsumerGroupID: NotRequired[str],
    Credentials: NotRequired[MSKAccessCredentialsTypeDef],  # (2)
  1. See MSKStartPositionType
  2. See MSKAccessCredentialsTypeDef

UpdatePipeSourceManagedStreamingKafkaParametersTypeDef#

# UpdatePipeSourceManagedStreamingKafkaParametersTypeDef definition

class UpdatePipeSourceManagedStreamingKafkaParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    Credentials: NotRequired[MSKAccessCredentialsTypeDef],  # (1)
    MaximumBatchingWindowInSeconds: NotRequired[int],
  1. See MSKAccessCredentialsTypeDef

MultiMeasureMappingOutputTypeDef#

# MultiMeasureMappingOutputTypeDef definition

class MultiMeasureMappingOutputTypeDef(TypedDict):
    MultiMeasureName: str,
    MultiMeasureAttributeMappings: list[MultiMeasureAttributeMappingTypeDef],  # (1)
  1. See MultiMeasureAttributeMappingTypeDef

MultiMeasureMappingTypeDef#

# MultiMeasureMappingTypeDef definition

class MultiMeasureMappingTypeDef(TypedDict):
    MultiMeasureName: str,
    MultiMeasureAttributeMappings: Sequence[MultiMeasureAttributeMappingTypeDef],  # (1)
  1. See MultiMeasureAttributeMappingTypeDef

PipeEnrichmentParametersOutputTypeDef#

# PipeEnrichmentParametersOutputTypeDef definition

class PipeEnrichmentParametersOutputTypeDef(TypedDict):
    InputTemplate: NotRequired[str],
    HttpParameters: NotRequired[PipeEnrichmentHttpParametersOutputTypeDef],  # (1)
  1. See PipeEnrichmentHttpParametersOutputTypeDef

PipeLogConfigurationParametersTypeDef#

# PipeLogConfigurationParametersTypeDef definition

class PipeLogConfigurationParametersTypeDef(TypedDict):
    Level: LogLevelType,  # (4)
    S3LogDestination: NotRequired[S3LogDestinationParametersTypeDef],  # (1)
    FirehoseLogDestination: NotRequired[FirehoseLogDestinationParametersTypeDef],  # (2)
    CloudwatchLogsLogDestination: NotRequired[CloudwatchLogsLogDestinationParametersTypeDef],  # (3)
    IncludeExecutionData: NotRequired[Sequence[IncludeExecutionDataOptionType]],  # (5)
  1. See S3LogDestinationParametersTypeDef
  2. See FirehoseLogDestinationParametersTypeDef
  3. See CloudwatchLogsLogDestinationParametersTypeDef
  4. See LogLevelType
  5. See IncludeExecutionDataOptionType

PipeLogConfigurationTypeDef#

# PipeLogConfigurationTypeDef definition

class PipeLogConfigurationTypeDef(TypedDict):
    S3LogDestination: NotRequired[S3LogDestinationTypeDef],  # (1)
    FirehoseLogDestination: NotRequired[FirehoseLogDestinationTypeDef],  # (2)
    CloudwatchLogsLogDestination: NotRequired[CloudwatchLogsLogDestinationTypeDef],  # (3)
    Level: NotRequired[LogLevelType],  # (4)
    IncludeExecutionData: NotRequired[list[IncludeExecutionDataOptionType]],  # (5)
  1. See S3LogDestinationTypeDef
  2. See FirehoseLogDestinationTypeDef
  3. See CloudwatchLogsLogDestinationTypeDef
  4. See LogLevelType
  5. See IncludeExecutionDataOptionType

PipeSourceKinesisStreamParametersTypeDef#

# PipeSourceKinesisStreamParametersTypeDef definition

class PipeSourceKinesisStreamParametersTypeDef(TypedDict):
    StartingPosition: KinesisStreamStartPositionType,  # (3)
    BatchSize: NotRequired[int],
    DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef],  # (1)
    OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType],  # (2)
    MaximumBatchingWindowInSeconds: NotRequired[int],
    MaximumRecordAgeInSeconds: NotRequired[int],
    MaximumRetryAttempts: NotRequired[int],
    ParallelizationFactor: NotRequired[int],
    StartingPositionTimestamp: NotRequired[TimestampTypeDef],
  1. See DeadLetterConfigTypeDef
  2. See OnPartialBatchItemFailureStreamsType
  3. See KinesisStreamStartPositionType

PipeSourceSelfManagedKafkaParametersOutputTypeDef#

# PipeSourceSelfManagedKafkaParametersOutputTypeDef definition

class PipeSourceSelfManagedKafkaParametersOutputTypeDef(TypedDict):
    TopicName: str,
    StartingPosition: NotRequired[SelfManagedKafkaStartPositionType],  # (1)
    AdditionalBootstrapServers: NotRequired[list[str]],
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
    ConsumerGroupID: NotRequired[str],
    Credentials: NotRequired[SelfManagedKafkaAccessConfigurationCredentialsTypeDef],  # (2)
    ServerRootCaCertificate: NotRequired[str],
    Vpc: NotRequired[SelfManagedKafkaAccessConfigurationVpcOutputTypeDef],  # (3)
  1. See SelfManagedKafkaStartPositionType
  2. See SelfManagedKafkaAccessConfigurationCredentialsTypeDef
  3. See SelfManagedKafkaAccessConfigurationVpcOutputTypeDef

PipeTargetSageMakerPipelineParametersOutputTypeDef#

# PipeTargetSageMakerPipelineParametersOutputTypeDef definition

class PipeTargetSageMakerPipelineParametersOutputTypeDef(TypedDict):
    PipelineParameterList: NotRequired[list[SageMakerPipelineParameterTypeDef]],  # (1)
  1. See SageMakerPipelineParameterTypeDef

PipeTargetSageMakerPipelineParametersTypeDef#

# PipeTargetSageMakerPipelineParametersTypeDef definition

class PipeTargetSageMakerPipelineParametersTypeDef(TypedDict):
    PipelineParameterList: NotRequired[Sequence[SageMakerPipelineParameterTypeDef]],  # (1)
  1. See SageMakerPipelineParameterTypeDef

NetworkConfigurationTypeDef#

# NetworkConfigurationTypeDef definition

class NetworkConfigurationTypeDef(TypedDict):
    awsvpcConfiguration: NotRequired[AwsVpcConfigurationUnionTypeDef],  # (1)
  1. See AwsVpcConfigurationTypeDef AwsVpcConfigurationOutputTypeDef

PipeTargetBatchJobParametersOutputTypeDef#

# PipeTargetBatchJobParametersOutputTypeDef definition

class PipeTargetBatchJobParametersOutputTypeDef(TypedDict):
    JobDefinition: str,
    JobName: str,
    ArrayProperties: NotRequired[BatchArrayPropertiesTypeDef],  # (1)
    RetryStrategy: NotRequired[BatchRetryStrategyTypeDef],  # (2)
    ContainerOverrides: NotRequired[BatchContainerOverridesOutputTypeDef],  # (3)
    DependsOn: NotRequired[list[BatchJobDependencyTypeDef]],  # (4)
    Parameters: NotRequired[dict[str, str]],
  1. See BatchArrayPropertiesTypeDef
  2. See BatchRetryStrategyTypeDef
  3. See BatchContainerOverridesOutputTypeDef
  4. See BatchJobDependencyTypeDef

EcsTaskOverrideOutputTypeDef#

# EcsTaskOverrideOutputTypeDef definition

class EcsTaskOverrideOutputTypeDef(TypedDict):
    ContainerOverrides: NotRequired[list[EcsContainerOverrideOutputTypeDef]],  # (1)
    Cpu: NotRequired[str],
    EphemeralStorage: NotRequired[EcsEphemeralStorageTypeDef],  # (2)
    ExecutionRoleArn: NotRequired[str],
    InferenceAcceleratorOverrides: NotRequired[list[EcsInferenceAcceleratorOverrideTypeDef]],  # (3)
    Memory: NotRequired[str],
    TaskRoleArn: NotRequired[str],
  1. See EcsContainerOverrideOutputTypeDef
  2. See EcsEphemeralStorageTypeDef
  3. See EcsInferenceAcceleratorOverrideTypeDef

PipeTargetTimestreamParametersOutputTypeDef#

# PipeTargetTimestreamParametersOutputTypeDef definition

class PipeTargetTimestreamParametersOutputTypeDef(TypedDict):
    TimeValue: str,
    VersionValue: str,
    DimensionMappings: list[DimensionMappingTypeDef],  # (3)
    EpochTimeUnit: NotRequired[EpochTimeUnitType],  # (1)
    TimeFieldType: NotRequired[TimeFieldTypeType],  # (2)
    TimestampFormat: NotRequired[str],
    SingleMeasureMappings: NotRequired[list[SingleMeasureMappingTypeDef]],  # (4)
    MultiMeasureMappings: NotRequired[list[MultiMeasureMappingOutputTypeDef]],  # (5)
  1. See EpochTimeUnitType
  2. See TimeFieldTypeType
  3. See DimensionMappingTypeDef
  4. See SingleMeasureMappingTypeDef
  5. See MultiMeasureMappingOutputTypeDef

PipeEnrichmentParametersTypeDef#

# PipeEnrichmentParametersTypeDef definition

class PipeEnrichmentParametersTypeDef(TypedDict):
    InputTemplate: NotRequired[str],
    HttpParameters: NotRequired[PipeEnrichmentHttpParametersUnionTypeDef],  # (1)
  1. See PipeEnrichmentHttpParametersTypeDef PipeEnrichmentHttpParametersOutputTypeDef

PipeSourceParametersOutputTypeDef#

# PipeSourceParametersOutputTypeDef definition

class PipeSourceParametersOutputTypeDef(TypedDict):
    FilterCriteria: NotRequired[FilterCriteriaOutputTypeDef],  # (1)
    KinesisStreamParameters: NotRequired[PipeSourceKinesisStreamParametersOutputTypeDef],  # (2)
    DynamoDBStreamParameters: NotRequired[PipeSourceDynamoDBStreamParametersTypeDef],  # (3)
    SqsQueueParameters: NotRequired[PipeSourceSqsQueueParametersTypeDef],  # (4)
    ActiveMQBrokerParameters: NotRequired[PipeSourceActiveMQBrokerParametersTypeDef],  # (5)
    RabbitMQBrokerParameters: NotRequired[PipeSourceRabbitMQBrokerParametersTypeDef],  # (6)
    ManagedStreamingKafkaParameters: NotRequired[PipeSourceManagedStreamingKafkaParametersTypeDef],  # (7)
    SelfManagedKafkaParameters: NotRequired[PipeSourceSelfManagedKafkaParametersOutputTypeDef],  # (8)
  1. See FilterCriteriaOutputTypeDef
  2. See PipeSourceKinesisStreamParametersOutputTypeDef
  3. See PipeSourceDynamoDBStreamParametersTypeDef
  4. See PipeSourceSqsQueueParametersTypeDef
  5. See PipeSourceActiveMQBrokerParametersTypeDef
  6. See PipeSourceRabbitMQBrokerParametersTypeDef
  7. See PipeSourceManagedStreamingKafkaParametersTypeDef
  8. See PipeSourceSelfManagedKafkaParametersOutputTypeDef

PipeSourceSelfManagedKafkaParametersTypeDef#

# PipeSourceSelfManagedKafkaParametersTypeDef definition

class PipeSourceSelfManagedKafkaParametersTypeDef(TypedDict):
    TopicName: str,
    StartingPosition: NotRequired[SelfManagedKafkaStartPositionType],  # (1)
    AdditionalBootstrapServers: NotRequired[Sequence[str]],
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
    ConsumerGroupID: NotRequired[str],
    Credentials: NotRequired[SelfManagedKafkaAccessConfigurationCredentialsTypeDef],  # (2)
    ServerRootCaCertificate: NotRequired[str],
    Vpc: NotRequired[SelfManagedKafkaAccessConfigurationVpcUnionTypeDef],  # (3)
  1. See SelfManagedKafkaStartPositionType
  2. See SelfManagedKafkaAccessConfigurationCredentialsTypeDef
  3. See SelfManagedKafkaAccessConfigurationVpcTypeDef SelfManagedKafkaAccessConfigurationVpcOutputTypeDef

UpdatePipeSourceSelfManagedKafkaParametersTypeDef#

# UpdatePipeSourceSelfManagedKafkaParametersTypeDef definition

class UpdatePipeSourceSelfManagedKafkaParametersTypeDef(TypedDict):
    BatchSize: NotRequired[int],
    MaximumBatchingWindowInSeconds: NotRequired[int],
    Credentials: NotRequired[SelfManagedKafkaAccessConfigurationCredentialsTypeDef],  # (1)
    ServerRootCaCertificate: NotRequired[str],
    Vpc: NotRequired[SelfManagedKafkaAccessConfigurationVpcUnionTypeDef],  # (2)
  1. See SelfManagedKafkaAccessConfigurationCredentialsTypeDef
  2. See SelfManagedKafkaAccessConfigurationVpcTypeDef SelfManagedKafkaAccessConfigurationVpcOutputTypeDef

PipeTargetBatchJobParametersTypeDef#

# PipeTargetBatchJobParametersTypeDef definition

class PipeTargetBatchJobParametersTypeDef(TypedDict):
    JobDefinition: str,
    JobName: str,
    ArrayProperties: NotRequired[BatchArrayPropertiesTypeDef],  # (1)
    RetryStrategy: NotRequired[BatchRetryStrategyTypeDef],  # (2)
    ContainerOverrides: NotRequired[BatchContainerOverridesUnionTypeDef],  # (3)
    DependsOn: NotRequired[Sequence[BatchJobDependencyTypeDef]],  # (4)
    Parameters: NotRequired[Mapping[str, str]],
  1. See BatchArrayPropertiesTypeDef
  2. See BatchRetryStrategyTypeDef
  3. See BatchContainerOverridesTypeDef BatchContainerOverridesOutputTypeDef
  4. See BatchJobDependencyTypeDef

PipeTargetEcsTaskParametersOutputTypeDef#

# PipeTargetEcsTaskParametersOutputTypeDef definition

class PipeTargetEcsTaskParametersOutputTypeDef(TypedDict):
    TaskDefinitionArn: str,
    TaskCount: NotRequired[int],
    LaunchType: NotRequired[LaunchTypeType],  # (1)
    NetworkConfiguration: NotRequired[NetworkConfigurationOutputTypeDef],  # (2)
    PlatformVersion: NotRequired[str],
    Group: NotRequired[str],
    CapacityProviderStrategy: NotRequired[list[CapacityProviderStrategyItemTypeDef]],  # (3)
    EnableECSManagedTags: NotRequired[bool],
    EnableExecuteCommand: NotRequired[bool],
    PlacementConstraints: NotRequired[list[PlacementConstraintTypeDef]],  # (4)
    PlacementStrategy: NotRequired[list[PlacementStrategyTypeDef]],  # (5)
    PropagateTags: NotRequired[PropagateTagsType],  # (6)
    ReferenceId: NotRequired[str],
    Overrides: NotRequired[EcsTaskOverrideOutputTypeDef],  # (7)
    Tags: NotRequired[list[TagTypeDef]],  # (8)
  1. See LaunchTypeType
  2. See NetworkConfigurationOutputTypeDef
  3. See CapacityProviderStrategyItemTypeDef
  4. See PlacementConstraintTypeDef
  5. See PlacementStrategyTypeDef
  6. See PropagateTagsType
  7. See EcsTaskOverrideOutputTypeDef
  8. See TagTypeDef

EcsTaskOverrideTypeDef#

# EcsTaskOverrideTypeDef definition

class EcsTaskOverrideTypeDef(TypedDict):
    ContainerOverrides: NotRequired[Sequence[EcsContainerOverrideUnionTypeDef]],  # (1)
    Cpu: NotRequired[str],
    EphemeralStorage: NotRequired[EcsEphemeralStorageTypeDef],  # (2)
    ExecutionRoleArn: NotRequired[str],
    InferenceAcceleratorOverrides: NotRequired[Sequence[EcsInferenceAcceleratorOverrideTypeDef]],  # (3)
    Memory: NotRequired[str],
    TaskRoleArn: NotRequired[str],
  1. See EcsContainerOverrideTypeDef EcsContainerOverrideOutputTypeDef
  2. See EcsEphemeralStorageTypeDef
  3. See EcsInferenceAcceleratorOverrideTypeDef

PipeTargetTimestreamParametersTypeDef#

# PipeTargetTimestreamParametersTypeDef definition

class PipeTargetTimestreamParametersTypeDef(TypedDict):
    TimeValue: str,
    VersionValue: str,
    DimensionMappings: Sequence[DimensionMappingTypeDef],  # (3)
    EpochTimeUnit: NotRequired[EpochTimeUnitType],  # (1)
    TimeFieldType: NotRequired[TimeFieldTypeType],  # (2)
    TimestampFormat: NotRequired[str],
    SingleMeasureMappings: NotRequired[Sequence[SingleMeasureMappingTypeDef]],  # (4)
    MultiMeasureMappings: NotRequired[Sequence[MultiMeasureMappingUnionTypeDef]],  # (5)
  1. See EpochTimeUnitType
  2. See TimeFieldTypeType
  3. See DimensionMappingTypeDef
  4. See SingleMeasureMappingTypeDef
  5. See MultiMeasureMappingTypeDef MultiMeasureMappingOutputTypeDef

UpdatePipeSourceParametersTypeDef#

# UpdatePipeSourceParametersTypeDef definition

class UpdatePipeSourceParametersTypeDef(TypedDict):
    FilterCriteria: NotRequired[FilterCriteriaUnionTypeDef],  # (1)
    KinesisStreamParameters: NotRequired[UpdatePipeSourceKinesisStreamParametersTypeDef],  # (2)
    DynamoDBStreamParameters: NotRequired[UpdatePipeSourceDynamoDBStreamParametersTypeDef],  # (3)
    SqsQueueParameters: NotRequired[UpdatePipeSourceSqsQueueParametersTypeDef],  # (4)
    ActiveMQBrokerParameters: NotRequired[UpdatePipeSourceActiveMQBrokerParametersTypeDef],  # (5)
    RabbitMQBrokerParameters: NotRequired[UpdatePipeSourceRabbitMQBrokerParametersTypeDef],  # (6)
    ManagedStreamingKafkaParameters: NotRequired[UpdatePipeSourceManagedStreamingKafkaParametersTypeDef],  # (7)
    SelfManagedKafkaParameters: NotRequired[UpdatePipeSourceSelfManagedKafkaParametersTypeDef],  # (8)
  1. See FilterCriteriaTypeDef FilterCriteriaOutputTypeDef
  2. See UpdatePipeSourceKinesisStreamParametersTypeDef
  3. See UpdatePipeSourceDynamoDBStreamParametersTypeDef
  4. See UpdatePipeSourceSqsQueueParametersTypeDef
  5. See UpdatePipeSourceActiveMQBrokerParametersTypeDef
  6. See UpdatePipeSourceRabbitMQBrokerParametersTypeDef
  7. See UpdatePipeSourceManagedStreamingKafkaParametersTypeDef
  8. See UpdatePipeSourceSelfManagedKafkaParametersTypeDef

PipeTargetParametersOutputTypeDef#

# PipeTargetParametersOutputTypeDef definition

class PipeTargetParametersOutputTypeDef(TypedDict):
    InputTemplate: NotRequired[str],
    LambdaFunctionParameters: NotRequired[PipeTargetLambdaFunctionParametersTypeDef],  # (1)
    StepFunctionStateMachineParameters: NotRequired[PipeTargetStateMachineParametersTypeDef],  # (2)
    KinesisStreamParameters: NotRequired[PipeTargetKinesisStreamParametersTypeDef],  # (3)
    EcsTaskParameters: NotRequired[PipeTargetEcsTaskParametersOutputTypeDef],  # (4)
    BatchJobParameters: NotRequired[PipeTargetBatchJobParametersOutputTypeDef],  # (5)
    SqsQueueParameters: NotRequired[PipeTargetSqsQueueParametersTypeDef],  # (6)
    HttpParameters: NotRequired[PipeTargetHttpParametersOutputTypeDef],  # (7)
    RedshiftDataParameters: NotRequired[PipeTargetRedshiftDataParametersOutputTypeDef],  # (8)
    SageMakerPipelineParameters: NotRequired[PipeTargetSageMakerPipelineParametersOutputTypeDef],  # (9)
    EventBridgeEventBusParameters: NotRequired[PipeTargetEventBridgeEventBusParametersOutputTypeDef],  # (10)
    CloudWatchLogsParameters: NotRequired[PipeTargetCloudWatchLogsParametersTypeDef],  # (11)
    TimestreamParameters: NotRequired[PipeTargetTimestreamParametersOutputTypeDef],  # (12)
  1. See PipeTargetLambdaFunctionParametersTypeDef
  2. See PipeTargetStateMachineParametersTypeDef
  3. See PipeTargetKinesisStreamParametersTypeDef
  4. See PipeTargetEcsTaskParametersOutputTypeDef
  5. See PipeTargetBatchJobParametersOutputTypeDef
  6. See PipeTargetSqsQueueParametersTypeDef
  7. See PipeTargetHttpParametersOutputTypeDef
  8. See PipeTargetRedshiftDataParametersOutputTypeDef
  9. See PipeTargetSageMakerPipelineParametersOutputTypeDef
  10. See PipeTargetEventBridgeEventBusParametersOutputTypeDef
  11. See PipeTargetCloudWatchLogsParametersTypeDef
  12. See PipeTargetTimestreamParametersOutputTypeDef

PipeSourceParametersTypeDef#

# PipeSourceParametersTypeDef definition

class PipeSourceParametersTypeDef(TypedDict):
    FilterCriteria: NotRequired[FilterCriteriaUnionTypeDef],  # (1)
    KinesisStreamParameters: NotRequired[PipeSourceKinesisStreamParametersUnionTypeDef],  # (2)
    DynamoDBStreamParameters: NotRequired[PipeSourceDynamoDBStreamParametersTypeDef],  # (3)
    SqsQueueParameters: NotRequired[PipeSourceSqsQueueParametersTypeDef],  # (4)
    ActiveMQBrokerParameters: NotRequired[PipeSourceActiveMQBrokerParametersTypeDef],  # (5)
    RabbitMQBrokerParameters: NotRequired[PipeSourceRabbitMQBrokerParametersTypeDef],  # (6)
    ManagedStreamingKafkaParameters: NotRequired[PipeSourceManagedStreamingKafkaParametersTypeDef],  # (7)
    SelfManagedKafkaParameters: NotRequired[PipeSourceSelfManagedKafkaParametersUnionTypeDef],  # (8)
  1. See FilterCriteriaTypeDef FilterCriteriaOutputTypeDef
  2. See PipeSourceKinesisStreamParametersTypeDef PipeSourceKinesisStreamParametersOutputTypeDef
  3. See PipeSourceDynamoDBStreamParametersTypeDef
  4. See PipeSourceSqsQueueParametersTypeDef
  5. See PipeSourceActiveMQBrokerParametersTypeDef
  6. See PipeSourceRabbitMQBrokerParametersTypeDef
  7. See PipeSourceManagedStreamingKafkaParametersTypeDef
  8. See PipeSourceSelfManagedKafkaParametersTypeDef PipeSourceSelfManagedKafkaParametersOutputTypeDef

DescribePipeResponseTypeDef#

# DescribePipeResponseTypeDef definition

class DescribePipeResponseTypeDef(TypedDict):
    Arn: str,
    Name: str,
    Description: str,
    DesiredState: RequestedPipeStateDescribeResponseType,  # (1)
    CurrentState: PipeStateType,  # (2)
    StateReason: str,
    Source: str,
    SourceParameters: PipeSourceParametersOutputTypeDef,  # (3)
    Enrichment: str,
    EnrichmentParameters: PipeEnrichmentParametersOutputTypeDef,  # (4)
    Target: str,
    TargetParameters: PipeTargetParametersOutputTypeDef,  # (5)
    RoleArn: str,
    Tags: dict[str, str],
    CreationTime: datetime,
    LastModifiedTime: datetime,
    LogConfiguration: PipeLogConfigurationTypeDef,  # (6)
    KmsKeyIdentifier: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (7)
  1. See RequestedPipeStateDescribeResponseType
  2. See PipeStateType
  3. See PipeSourceParametersOutputTypeDef
  4. See PipeEnrichmentParametersOutputTypeDef
  5. See PipeTargetParametersOutputTypeDef
  6. See PipeLogConfigurationTypeDef
  7. See ResponseMetadataTypeDef

PipeTargetEcsTaskParametersTypeDef#

# PipeTargetEcsTaskParametersTypeDef definition

class PipeTargetEcsTaskParametersTypeDef(TypedDict):
    TaskDefinitionArn: str,
    TaskCount: NotRequired[int],
    LaunchType: NotRequired[LaunchTypeType],  # (1)
    NetworkConfiguration: NotRequired[NetworkConfigurationUnionTypeDef],  # (2)
    PlatformVersion: NotRequired[str],
    Group: NotRequired[str],
    CapacityProviderStrategy: NotRequired[Sequence[CapacityProviderStrategyItemTypeDef]],  # (3)
    EnableECSManagedTags: NotRequired[bool],
    EnableExecuteCommand: NotRequired[bool],
    PlacementConstraints: NotRequired[Sequence[PlacementConstraintTypeDef]],  # (4)
    PlacementStrategy: NotRequired[Sequence[PlacementStrategyTypeDef]],  # (5)
    PropagateTags: NotRequired[PropagateTagsType],  # (6)
    ReferenceId: NotRequired[str],
    Overrides: NotRequired[EcsTaskOverrideUnionTypeDef],  # (7)
    Tags: NotRequired[Sequence[TagTypeDef]],  # (8)
  1. See LaunchTypeType
  2. See NetworkConfigurationTypeDef NetworkConfigurationOutputTypeDef
  3. See CapacityProviderStrategyItemTypeDef
  4. See PlacementConstraintTypeDef
  5. See PlacementStrategyTypeDef
  6. See PropagateTagsType
  7. See EcsTaskOverrideTypeDef EcsTaskOverrideOutputTypeDef
  8. See TagTypeDef

PipeTargetParametersTypeDef#

# PipeTargetParametersTypeDef definition

class PipeTargetParametersTypeDef(TypedDict):
    InputTemplate: NotRequired[str],
    LambdaFunctionParameters: NotRequired[PipeTargetLambdaFunctionParametersTypeDef],  # (1)
    StepFunctionStateMachineParameters: NotRequired[PipeTargetStateMachineParametersTypeDef],  # (2)
    KinesisStreamParameters: NotRequired[PipeTargetKinesisStreamParametersTypeDef],  # (3)
    EcsTaskParameters: NotRequired[PipeTargetEcsTaskParametersUnionTypeDef],  # (4)
    BatchJobParameters: NotRequired[PipeTargetBatchJobParametersUnionTypeDef],  # (5)
    SqsQueueParameters: NotRequired[PipeTargetSqsQueueParametersTypeDef],  # (6)
    HttpParameters: NotRequired[PipeTargetHttpParametersUnionTypeDef],  # (7)
    RedshiftDataParameters: NotRequired[PipeTargetRedshiftDataParametersUnionTypeDef],  # (8)
    SageMakerPipelineParameters: NotRequired[PipeTargetSageMakerPipelineParametersUnionTypeDef],  # (9)
    EventBridgeEventBusParameters: NotRequired[PipeTargetEventBridgeEventBusParametersUnionTypeDef],  # (10)
    CloudWatchLogsParameters: NotRequired[PipeTargetCloudWatchLogsParametersTypeDef],  # (11)
    TimestreamParameters: NotRequired[PipeTargetTimestreamParametersUnionTypeDef],  # (12)
  1. See PipeTargetLambdaFunctionParametersTypeDef
  2. See PipeTargetStateMachineParametersTypeDef
  3. See PipeTargetKinesisStreamParametersTypeDef
  4. See PipeTargetEcsTaskParametersTypeDef PipeTargetEcsTaskParametersOutputTypeDef
  5. See PipeTargetBatchJobParametersTypeDef PipeTargetBatchJobParametersOutputTypeDef
  6. See PipeTargetSqsQueueParametersTypeDef
  7. See PipeTargetHttpParametersTypeDef PipeTargetHttpParametersOutputTypeDef
  8. See PipeTargetRedshiftDataParametersTypeDef PipeTargetRedshiftDataParametersOutputTypeDef
  9. See PipeTargetSageMakerPipelineParametersTypeDef PipeTargetSageMakerPipelineParametersOutputTypeDef
  10. See PipeTargetEventBridgeEventBusParametersTypeDef PipeTargetEventBridgeEventBusParametersOutputTypeDef
  11. See PipeTargetCloudWatchLogsParametersTypeDef
  12. See PipeTargetTimestreamParametersTypeDef PipeTargetTimestreamParametersOutputTypeDef

CreatePipeRequestRequestTypeDef#

# CreatePipeRequestRequestTypeDef definition

class CreatePipeRequestRequestTypeDef(TypedDict):
    Name: str,
    Source: str,
    Target: str,
    RoleArn: str,
    Description: NotRequired[str],
    DesiredState: NotRequired[RequestedPipeStateType],  # (1)
    SourceParameters: NotRequired[PipeSourceParametersTypeDef],  # (2)
    Enrichment: NotRequired[str],
    EnrichmentParameters: NotRequired[PipeEnrichmentParametersTypeDef],  # (3)
    TargetParameters: NotRequired[PipeTargetParametersTypeDef],  # (4)
    Tags: NotRequired[Mapping[str, str]],
    LogConfiguration: NotRequired[PipeLogConfigurationParametersTypeDef],  # (5)
    KmsKeyIdentifier: NotRequired[str],
  1. See RequestedPipeStateType
  2. See PipeSourceParametersTypeDef
  3. See PipeEnrichmentParametersTypeDef
  4. See PipeTargetParametersTypeDef
  5. See PipeLogConfigurationParametersTypeDef

UpdatePipeRequestRequestTypeDef#

# UpdatePipeRequestRequestTypeDef definition

class UpdatePipeRequestRequestTypeDef(TypedDict):
    Name: str,
    RoleArn: str,
    Description: NotRequired[str],
    DesiredState: NotRequired[RequestedPipeStateType],  # (1)
    SourceParameters: NotRequired[UpdatePipeSourceParametersTypeDef],  # (2)
    Enrichment: NotRequired[str],
    EnrichmentParameters: NotRequired[PipeEnrichmentParametersTypeDef],  # (3)
    Target: NotRequired[str],
    TargetParameters: NotRequired[PipeTargetParametersTypeDef],  # (4)
    LogConfiguration: NotRequired[PipeLogConfigurationParametersTypeDef],  # (5)
    KmsKeyIdentifier: NotRequired[str],
  1. See RequestedPipeStateType
  2. See UpdatePipeSourceParametersTypeDef
  3. See PipeEnrichmentParametersTypeDef
  4. See PipeTargetParametersTypeDef
  5. See PipeLogConfigurationParametersTypeDef