Typed dictionaries
Index > EventBridgePipes > Typed dictionaries
Auto-generated documentation for EventBridgePipes type annotations stubs module mypy-boto3-pipes.
AwsVpcConfigurationTypeDef
# AwsVpcConfigurationTypeDef usage example
from mypy_boto3_pipes.type_defs import AwsVpcConfigurationTypeDef
def get_value() -> AwsVpcConfigurationTypeDef:
return {
"Subnets": ...,
}
# AwsVpcConfigurationTypeDef definition
class AwsVpcConfigurationTypeDef(TypedDict):
Subnets: Sequence[str],
AssignPublicIp: NotRequired[AssignPublicIpType], # (1)
SecurityGroups: NotRequired[Sequence[str]],
BatchArrayPropertiesTypeDef
# BatchArrayPropertiesTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchArrayPropertiesTypeDef
def get_value() -> BatchArrayPropertiesTypeDef:
return {
"Size": ...,
}
# BatchArrayPropertiesTypeDef definition
class BatchArrayPropertiesTypeDef(TypedDict):
Size: NotRequired[int],
BatchEnvironmentVariableTypeDef
# BatchEnvironmentVariableTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchEnvironmentVariableTypeDef
def get_value() -> BatchEnvironmentVariableTypeDef:
return {
"Name": ...,
}
# BatchEnvironmentVariableTypeDef definition
class BatchEnvironmentVariableTypeDef(TypedDict):
Name: NotRequired[str],
Value: NotRequired[str],
BatchResourceRequirementTypeDef
# BatchResourceRequirementTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchResourceRequirementTypeDef
def get_value() -> BatchResourceRequirementTypeDef:
return {
"Type": ...,
"Value": ...,
}
# BatchResourceRequirementTypeDef definition
class BatchResourceRequirementTypeDef(TypedDict):
Type: BatchResourceRequirementTypeType, # (1)
Value: str,
BatchJobDependencyTypeDef
# BatchJobDependencyTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchJobDependencyTypeDef
def get_value() -> BatchJobDependencyTypeDef:
return {
"JobId": ...,
}
# BatchJobDependencyTypeDef definition
class BatchJobDependencyTypeDef(TypedDict):
JobId: NotRequired[str],
Type: NotRequired[BatchJobDependencyTypeType], # (1)
BatchRetryStrategyTypeDef
# BatchRetryStrategyTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchRetryStrategyTypeDef
def get_value() -> BatchRetryStrategyTypeDef:
return {
"Attempts": ...,
}
# BatchRetryStrategyTypeDef definition
class BatchRetryStrategyTypeDef(TypedDict):
Attempts: NotRequired[int],
CapacityProviderStrategyItemTypeDef
# CapacityProviderStrategyItemTypeDef usage example
from mypy_boto3_pipes.type_defs import CapacityProviderStrategyItemTypeDef
def get_value() -> CapacityProviderStrategyItemTypeDef:
return {
"capacityProvider": ...,
}
# CapacityProviderStrategyItemTypeDef definition
class CapacityProviderStrategyItemTypeDef(TypedDict):
capacityProvider: str,
base: NotRequired[int],
weight: NotRequired[int],
ResponseMetadataTypeDef
# ResponseMetadataTypeDef usage example
from mypy_boto3_pipes.type_defs import ResponseMetadataTypeDef
def get_value() -> ResponseMetadataTypeDef:
return {
"RequestId": ...,
"HostId": ...,
"HTTPStatusCode": ...,
"HTTPHeaders": ...,
"RetryAttempts": ...,
}
# ResponseMetadataTypeDef definition
class ResponseMetadataTypeDef(TypedDict):
RequestId: str,
HostId: str,
HTTPStatusCode: int,
HTTPHeaders: Dict[str, str],
RetryAttempts: int,
DeadLetterConfigTypeDef
# DeadLetterConfigTypeDef usage example
from mypy_boto3_pipes.type_defs import DeadLetterConfigTypeDef
def get_value() -> DeadLetterConfigTypeDef:
return {
"Arn": ...,
}
# DeadLetterConfigTypeDef definition
class DeadLetterConfigTypeDef(TypedDict):
Arn: NotRequired[str],
DeletePipeRequestRequestTypeDef
# DeletePipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import DeletePipeRequestRequestTypeDef
def get_value() -> DeletePipeRequestRequestTypeDef:
return {
"Name": ...,
}
# DeletePipeRequestRequestTypeDef definition
class DeletePipeRequestRequestTypeDef(TypedDict):
Name: str,
DescribePipeRequestRequestTypeDef
# DescribePipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import DescribePipeRequestRequestTypeDef
def get_value() -> DescribePipeRequestRequestTypeDef:
return {
"Name": ...,
}
# DescribePipeRequestRequestTypeDef definition
class DescribePipeRequestRequestTypeDef(TypedDict):
Name: str,
EcsEnvironmentFileTypeDef
# EcsEnvironmentFileTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsEnvironmentFileTypeDef
def get_value() -> EcsEnvironmentFileTypeDef:
return {
"type": ...,
"value": ...,
}
# EcsEnvironmentFileTypeDef definition
class EcsEnvironmentFileTypeDef(TypedDict):
type: EcsEnvironmentFileTypeType, # (1)
value: str,
EcsEnvironmentVariableTypeDef
# EcsEnvironmentVariableTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsEnvironmentVariableTypeDef
def get_value() -> EcsEnvironmentVariableTypeDef:
return {
"name": ...,
}
# EcsEnvironmentVariableTypeDef definition
class EcsEnvironmentVariableTypeDef(TypedDict):
name: NotRequired[str],
value: NotRequired[str],
EcsResourceRequirementTypeDef
# EcsResourceRequirementTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsResourceRequirementTypeDef
def get_value() -> EcsResourceRequirementTypeDef:
return {
"type": ...,
"value": ...,
}
# EcsResourceRequirementTypeDef definition
class EcsResourceRequirementTypeDef(TypedDict):
type: EcsResourceRequirementTypeType, # (1)
value: str,
EcsEphemeralStorageTypeDef
# EcsEphemeralStorageTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsEphemeralStorageTypeDef
def get_value() -> EcsEphemeralStorageTypeDef:
return {
"sizeInGiB": ...,
}
# EcsEphemeralStorageTypeDef definition
class EcsEphemeralStorageTypeDef(TypedDict):
sizeInGiB: int,
EcsInferenceAcceleratorOverrideTypeDef
# EcsInferenceAcceleratorOverrideTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsInferenceAcceleratorOverrideTypeDef
def get_value() -> EcsInferenceAcceleratorOverrideTypeDef:
return {
"deviceName": ...,
}
# EcsInferenceAcceleratorOverrideTypeDef definition
class EcsInferenceAcceleratorOverrideTypeDef(TypedDict):
deviceName: NotRequired[str],
deviceType: NotRequired[str],
FilterTypeDef
# FilterTypeDef usage example
from mypy_boto3_pipes.type_defs import FilterTypeDef
def get_value() -> FilterTypeDef:
return {
"Pattern": ...,
}
# FilterTypeDef definition
class FilterTypeDef(TypedDict):
Pattern: NotRequired[str],
PaginatorConfigTypeDef
# PaginatorConfigTypeDef usage example
from mypy_boto3_pipes.type_defs import PaginatorConfigTypeDef
def get_value() -> PaginatorConfigTypeDef:
return {
"MaxItems": ...,
}
# PaginatorConfigTypeDef definition
class PaginatorConfigTypeDef(TypedDict):
MaxItems: NotRequired[int],
PageSize: NotRequired[int],
StartingToken: NotRequired[str],
ListPipesRequestRequestTypeDef
# ListPipesRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import ListPipesRequestRequestTypeDef
def get_value() -> ListPipesRequestRequestTypeDef:
return {
"CurrentState": ...,
}
# ListPipesRequestRequestTypeDef definition
class ListPipesRequestRequestTypeDef(TypedDict):
CurrentState: NotRequired[PipeStateType], # (1)
DesiredState: NotRequired[RequestedPipeStateType], # (2)
Limit: NotRequired[int],
NamePrefix: NotRequired[str],
NextToken: NotRequired[str],
SourcePrefix: NotRequired[str],
TargetPrefix: NotRequired[str],
- See PipeStateType
- See RequestedPipeStateType
PipeTypeDef
# PipeTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTypeDef
def get_value() -> PipeTypeDef:
return {
"Arn": ...,
}
# PipeTypeDef definition
class PipeTypeDef(TypedDict):
Arn: NotRequired[str],
CreationTime: NotRequired[datetime],
CurrentState: NotRequired[PipeStateType], # (1)
DesiredState: NotRequired[RequestedPipeStateType], # (2)
Enrichment: NotRequired[str],
LastModifiedTime: NotRequired[datetime],
Name: NotRequired[str],
Source: NotRequired[str],
StateReason: NotRequired[str],
Target: NotRequired[str],
- See PipeStateType
- See RequestedPipeStateType
ListTagsForResourceRequestRequestTypeDef
# ListTagsForResourceRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import ListTagsForResourceRequestRequestTypeDef
def get_value() -> ListTagsForResourceRequestRequestTypeDef:
return {
"resourceArn": ...,
}
# ListTagsForResourceRequestRequestTypeDef definition
class ListTagsForResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
MQBrokerAccessCredentialsTypeDef
# MQBrokerAccessCredentialsTypeDef usage example
from mypy_boto3_pipes.type_defs import MQBrokerAccessCredentialsTypeDef
def get_value() -> MQBrokerAccessCredentialsTypeDef:
return {
"BasicAuth": ...,
}
# MQBrokerAccessCredentialsTypeDef definition
class MQBrokerAccessCredentialsTypeDef(TypedDict):
BasicAuth: NotRequired[str],
MSKAccessCredentialsTypeDef
# MSKAccessCredentialsTypeDef usage example
from mypy_boto3_pipes.type_defs import MSKAccessCredentialsTypeDef
def get_value() -> MSKAccessCredentialsTypeDef:
return {
"ClientCertificateTlsAuth": ...,
}
# MSKAccessCredentialsTypeDef definition
class MSKAccessCredentialsTypeDef(TypedDict):
ClientCertificateTlsAuth: NotRequired[str],
SaslScram512Auth: NotRequired[str],
PipeEnrichmentHttpParametersTypeDef
# PipeEnrichmentHttpParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeEnrichmentHttpParametersTypeDef
def get_value() -> PipeEnrichmentHttpParametersTypeDef:
return {
"HeaderParameters": ...,
}
# PipeEnrichmentHttpParametersTypeDef definition
class PipeEnrichmentHttpParametersTypeDef(TypedDict):
HeaderParameters: NotRequired[Mapping[str, str]],
PathParameterValues: NotRequired[Sequence[str]],
QueryStringParameters: NotRequired[Mapping[str, str]],
PipeSourceSqsQueueParametersTypeDef
# PipeSourceSqsQueueParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceSqsQueueParametersTypeDef
def get_value() -> PipeSourceSqsQueueParametersTypeDef:
return {
"BatchSize": ...,
}
# PipeSourceSqsQueueParametersTypeDef definition
class PipeSourceSqsQueueParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
SelfManagedKafkaAccessConfigurationCredentialsTypeDef
# SelfManagedKafkaAccessConfigurationCredentialsTypeDef usage example
from mypy_boto3_pipes.type_defs import SelfManagedKafkaAccessConfigurationCredentialsTypeDef
def get_value() -> SelfManagedKafkaAccessConfigurationCredentialsTypeDef:
return {
"BasicAuth": ...,
}
# SelfManagedKafkaAccessConfigurationCredentialsTypeDef definition
class SelfManagedKafkaAccessConfigurationCredentialsTypeDef(TypedDict):
BasicAuth: NotRequired[str],
ClientCertificateTlsAuth: NotRequired[str],
SaslScram256Auth: NotRequired[str],
SaslScram512Auth: NotRequired[str],
SelfManagedKafkaAccessConfigurationVpcTypeDef
# SelfManagedKafkaAccessConfigurationVpcTypeDef usage example
from mypy_boto3_pipes.type_defs import SelfManagedKafkaAccessConfigurationVpcTypeDef
def get_value() -> SelfManagedKafkaAccessConfigurationVpcTypeDef:
return {
"SecurityGroup": ...,
}
# SelfManagedKafkaAccessConfigurationVpcTypeDef definition
class SelfManagedKafkaAccessConfigurationVpcTypeDef(TypedDict):
SecurityGroup: NotRequired[Sequence[str]],
Subnets: NotRequired[Sequence[str]],
PipeTargetCloudWatchLogsParametersTypeDef
# PipeTargetCloudWatchLogsParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetCloudWatchLogsParametersTypeDef
def get_value() -> PipeTargetCloudWatchLogsParametersTypeDef:
return {
"LogStreamName": ...,
}
# PipeTargetCloudWatchLogsParametersTypeDef definition
class PipeTargetCloudWatchLogsParametersTypeDef(TypedDict):
LogStreamName: NotRequired[str],
Timestamp: NotRequired[str],
PlacementConstraintTypeDef
# PlacementConstraintTypeDef usage example
from mypy_boto3_pipes.type_defs import PlacementConstraintTypeDef
def get_value() -> PlacementConstraintTypeDef:
return {
"expression": ...,
}
# PlacementConstraintTypeDef definition
class PlacementConstraintTypeDef(TypedDict):
expression: NotRequired[str],
type: NotRequired[PlacementConstraintTypeType], # (1)
PlacementStrategyTypeDef
# PlacementStrategyTypeDef usage example
from mypy_boto3_pipes.type_defs import PlacementStrategyTypeDef
def get_value() -> PlacementStrategyTypeDef:
return {
"field": ...,
}
# PlacementStrategyTypeDef definition
class PlacementStrategyTypeDef(TypedDict):
field: NotRequired[str],
type: NotRequired[PlacementStrategyTypeType], # (1)
TagTypeDef
# TagTypeDef usage example
from mypy_boto3_pipes.type_defs import TagTypeDef
def get_value() -> TagTypeDef:
return {
"Key": ...,
"Value": ...,
}
# TagTypeDef definition
class TagTypeDef(TypedDict):
Key: str,
Value: str,
PipeTargetEventBridgeEventBusParametersTypeDef
# PipeTargetEventBridgeEventBusParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetEventBridgeEventBusParametersTypeDef
def get_value() -> PipeTargetEventBridgeEventBusParametersTypeDef:
return {
"DetailType": ...,
}
# PipeTargetEventBridgeEventBusParametersTypeDef definition
class PipeTargetEventBridgeEventBusParametersTypeDef(TypedDict):
DetailType: NotRequired[str],
EndpointId: NotRequired[str],
Resources: NotRequired[Sequence[str]],
Source: NotRequired[str],
Time: NotRequired[str],
PipeTargetHttpParametersTypeDef
# PipeTargetHttpParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetHttpParametersTypeDef
def get_value() -> PipeTargetHttpParametersTypeDef:
return {
"HeaderParameters": ...,
}
# PipeTargetHttpParametersTypeDef definition
class PipeTargetHttpParametersTypeDef(TypedDict):
HeaderParameters: NotRequired[Mapping[str, str]],
PathParameterValues: NotRequired[Sequence[str]],
QueryStringParameters: NotRequired[Mapping[str, str]],
PipeTargetKinesisStreamParametersTypeDef
# PipeTargetKinesisStreamParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetKinesisStreamParametersTypeDef
def get_value() -> PipeTargetKinesisStreamParametersTypeDef:
return {
"PartitionKey": ...,
}
# PipeTargetKinesisStreamParametersTypeDef definition
class PipeTargetKinesisStreamParametersTypeDef(TypedDict):
PartitionKey: str,
PipeTargetLambdaFunctionParametersTypeDef
# PipeTargetLambdaFunctionParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetLambdaFunctionParametersTypeDef
def get_value() -> PipeTargetLambdaFunctionParametersTypeDef:
return {
"InvocationType": ...,
}
# PipeTargetLambdaFunctionParametersTypeDef definition
class PipeTargetLambdaFunctionParametersTypeDef(TypedDict):
InvocationType: NotRequired[PipeTargetInvocationTypeType], # (1)
PipeTargetRedshiftDataParametersTypeDef
# PipeTargetRedshiftDataParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetRedshiftDataParametersTypeDef
def get_value() -> PipeTargetRedshiftDataParametersTypeDef:
return {
"Database": ...,
"Sqls": ...,
}
# PipeTargetRedshiftDataParametersTypeDef definition
class PipeTargetRedshiftDataParametersTypeDef(TypedDict):
Database: str,
Sqls: Sequence[str],
DbUser: NotRequired[str],
SecretManagerArn: NotRequired[str],
StatementName: NotRequired[str],
WithEvent: NotRequired[bool],
PipeTargetSqsQueueParametersTypeDef
# PipeTargetSqsQueueParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetSqsQueueParametersTypeDef
def get_value() -> PipeTargetSqsQueueParametersTypeDef:
return {
"MessageDeduplicationId": ...,
}
# PipeTargetSqsQueueParametersTypeDef definition
class PipeTargetSqsQueueParametersTypeDef(TypedDict):
MessageDeduplicationId: NotRequired[str],
MessageGroupId: NotRequired[str],
PipeTargetStateMachineParametersTypeDef
# PipeTargetStateMachineParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetStateMachineParametersTypeDef
def get_value() -> PipeTargetStateMachineParametersTypeDef:
return {
"InvocationType": ...,
}
# PipeTargetStateMachineParametersTypeDef definition
class PipeTargetStateMachineParametersTypeDef(TypedDict):
InvocationType: NotRequired[PipeTargetInvocationTypeType], # (1)
SageMakerPipelineParameterTypeDef
# SageMakerPipelineParameterTypeDef usage example
from mypy_boto3_pipes.type_defs import SageMakerPipelineParameterTypeDef
def get_value() -> SageMakerPipelineParameterTypeDef:
return {
"Name": ...,
"Value": ...,
}
# SageMakerPipelineParameterTypeDef definition
class SageMakerPipelineParameterTypeDef(TypedDict):
Name: str,
Value: str,
StartPipeRequestRequestTypeDef
# StartPipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import StartPipeRequestRequestTypeDef
def get_value() -> StartPipeRequestRequestTypeDef:
return {
"Name": ...,
}
# StartPipeRequestRequestTypeDef definition
class StartPipeRequestRequestTypeDef(TypedDict):
Name: str,
StopPipeRequestRequestTypeDef
# StopPipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import StopPipeRequestRequestTypeDef
def get_value() -> StopPipeRequestRequestTypeDef:
return {
"Name": ...,
}
# StopPipeRequestRequestTypeDef definition
class StopPipeRequestRequestTypeDef(TypedDict):
Name: str,
TagResourceRequestRequestTypeDef
# TagResourceRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import TagResourceRequestRequestTypeDef
def get_value() -> TagResourceRequestRequestTypeDef:
return {
"resourceArn": ...,
"tags": ...,
}
# TagResourceRequestRequestTypeDef definition
class TagResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
tags: Mapping[str, str],
UntagResourceRequestRequestTypeDef
# UntagResourceRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import UntagResourceRequestRequestTypeDef
def get_value() -> UntagResourceRequestRequestTypeDef:
return {
"resourceArn": ...,
"tagKeys": ...,
}
# UntagResourceRequestRequestTypeDef definition
class UntagResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
tagKeys: Sequence[str],
UpdatePipeSourceSqsQueueParametersTypeDef
# UpdatePipeSourceSqsQueueParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceSqsQueueParametersTypeDef
def get_value() -> UpdatePipeSourceSqsQueueParametersTypeDef:
return {
"BatchSize": ...,
}
# UpdatePipeSourceSqsQueueParametersTypeDef definition
class UpdatePipeSourceSqsQueueParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
NetworkConfigurationTypeDef
# NetworkConfigurationTypeDef usage example
from mypy_boto3_pipes.type_defs import NetworkConfigurationTypeDef
def get_value() -> NetworkConfigurationTypeDef:
return {
"awsvpcConfiguration": ...,
}
# NetworkConfigurationTypeDef definition
class NetworkConfigurationTypeDef(TypedDict):
awsvpcConfiguration: NotRequired[AwsVpcConfigurationTypeDef], # (1)
BatchContainerOverridesTypeDef
# BatchContainerOverridesTypeDef usage example
from mypy_boto3_pipes.type_defs import BatchContainerOverridesTypeDef
def get_value() -> BatchContainerOverridesTypeDef:
return {
"Command": ...,
}
# BatchContainerOverridesTypeDef definition
class BatchContainerOverridesTypeDef(TypedDict):
Command: NotRequired[Sequence[str]],
Environment: NotRequired[Sequence[BatchEnvironmentVariableTypeDef]], # (1)
InstanceType: NotRequired[str],
ResourceRequirements: NotRequired[Sequence[BatchResourceRequirementTypeDef]], # (2)
CreatePipeResponseTypeDef
# CreatePipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import CreatePipeResponseTypeDef
def get_value() -> CreatePipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"DesiredState": ...,
"LastModifiedTime": ...,
"Name": ...,
"ResponseMetadata": ...,
}
# CreatePipeResponseTypeDef definition
class CreatePipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
DesiredState: RequestedPipeStateType, # (2)
LastModifiedTime: datetime,
Name: str,
ResponseMetadata: ResponseMetadataTypeDef, # (3)
DeletePipeResponseTypeDef
# DeletePipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import DeletePipeResponseTypeDef
def get_value() -> DeletePipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"DesiredState": ...,
"LastModifiedTime": ...,
"Name": ...,
"ResponseMetadata": ...,
}
# DeletePipeResponseTypeDef definition
class DeletePipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
DesiredState: RequestedPipeStateDescribeResponseType, # (2)
LastModifiedTime: datetime,
Name: str,
ResponseMetadata: ResponseMetadataTypeDef, # (3)
ListTagsForResourceResponseTypeDef
# ListTagsForResourceResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import ListTagsForResourceResponseTypeDef
def get_value() -> ListTagsForResourceResponseTypeDef:
return {
"tags": ...,
"ResponseMetadata": ...,
}
# ListTagsForResourceResponseTypeDef definition
class ListTagsForResourceResponseTypeDef(TypedDict):
tags: Dict[str, str],
ResponseMetadata: ResponseMetadataTypeDef, # (1)
StartPipeResponseTypeDef
# StartPipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import StartPipeResponseTypeDef
def get_value() -> StartPipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"DesiredState": ...,
"LastModifiedTime": ...,
"Name": ...,
"ResponseMetadata": ...,
}
# StartPipeResponseTypeDef definition
class StartPipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
DesiredState: RequestedPipeStateType, # (2)
LastModifiedTime: datetime,
Name: str,
ResponseMetadata: ResponseMetadataTypeDef, # (3)
StopPipeResponseTypeDef
# StopPipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import StopPipeResponseTypeDef
def get_value() -> StopPipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"DesiredState": ...,
"LastModifiedTime": ...,
"Name": ...,
"ResponseMetadata": ...,
}
# StopPipeResponseTypeDef definition
class StopPipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
DesiredState: RequestedPipeStateType, # (2)
LastModifiedTime: datetime,
Name: str,
ResponseMetadata: ResponseMetadataTypeDef, # (3)
UpdatePipeResponseTypeDef
# UpdatePipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeResponseTypeDef
def get_value() -> UpdatePipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"DesiredState": ...,
"LastModifiedTime": ...,
"Name": ...,
"ResponseMetadata": ...,
}
# UpdatePipeResponseTypeDef definition
class UpdatePipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
DesiredState: RequestedPipeStateType, # (2)
LastModifiedTime: datetime,
Name: str,
ResponseMetadata: ResponseMetadataTypeDef, # (3)
PipeSourceDynamoDBStreamParametersTypeDef
# PipeSourceDynamoDBStreamParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceDynamoDBStreamParametersTypeDef
def get_value() -> PipeSourceDynamoDBStreamParametersTypeDef:
return {
"StartingPosition": ...,
}
# PipeSourceDynamoDBStreamParametersTypeDef definition
class PipeSourceDynamoDBStreamParametersTypeDef(TypedDict):
StartingPosition: DynamoDBStreamStartPositionType, # (3)
BatchSize: NotRequired[int],
DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
MaximumRecordAgeInSeconds: NotRequired[int],
MaximumRetryAttempts: NotRequired[int],
OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType], # (2)
ParallelizationFactor: NotRequired[int],
- See DeadLetterConfigTypeDef
- See OnPartialBatchItemFailureStreamsType
- See DynamoDBStreamStartPositionType
PipeSourceKinesisStreamParametersTypeDef
# PipeSourceKinesisStreamParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceKinesisStreamParametersTypeDef
def get_value() -> PipeSourceKinesisStreamParametersTypeDef:
return {
"StartingPosition": ...,
}
# PipeSourceKinesisStreamParametersTypeDef definition
class PipeSourceKinesisStreamParametersTypeDef(TypedDict):
StartingPosition: KinesisStreamStartPositionType, # (3)
BatchSize: NotRequired[int],
DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
MaximumRecordAgeInSeconds: NotRequired[int],
MaximumRetryAttempts: NotRequired[int],
OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType], # (2)
ParallelizationFactor: NotRequired[int],
StartingPositionTimestamp: NotRequired[Union[datetime, str]],
- See DeadLetterConfigTypeDef
- See OnPartialBatchItemFailureStreamsType
- See KinesisStreamStartPositionType
UpdatePipeSourceDynamoDBStreamParametersTypeDef
# UpdatePipeSourceDynamoDBStreamParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceDynamoDBStreamParametersTypeDef
def get_value() -> UpdatePipeSourceDynamoDBStreamParametersTypeDef:
return {
"BatchSize": ...,
}
# UpdatePipeSourceDynamoDBStreamParametersTypeDef definition
class UpdatePipeSourceDynamoDBStreamParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
MaximumRecordAgeInSeconds: NotRequired[int],
MaximumRetryAttempts: NotRequired[int],
OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType], # (2)
ParallelizationFactor: NotRequired[int],
UpdatePipeSourceKinesisStreamParametersTypeDef
# UpdatePipeSourceKinesisStreamParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceKinesisStreamParametersTypeDef
def get_value() -> UpdatePipeSourceKinesisStreamParametersTypeDef:
return {
"BatchSize": ...,
}
# UpdatePipeSourceKinesisStreamParametersTypeDef definition
class UpdatePipeSourceKinesisStreamParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
DeadLetterConfig: NotRequired[DeadLetterConfigTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
MaximumRecordAgeInSeconds: NotRequired[int],
MaximumRetryAttempts: NotRequired[int],
OnPartialBatchItemFailure: NotRequired[OnPartialBatchItemFailureStreamsType], # (2)
ParallelizationFactor: NotRequired[int],
EcsContainerOverrideTypeDef
# EcsContainerOverrideTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsContainerOverrideTypeDef
def get_value() -> EcsContainerOverrideTypeDef:
return {
"Command": ...,
}
# 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)
FilterCriteriaTypeDef
# FilterCriteriaTypeDef usage example
from mypy_boto3_pipes.type_defs import FilterCriteriaTypeDef
def get_value() -> FilterCriteriaTypeDef:
return {
"Filters": ...,
}
# FilterCriteriaTypeDef definition
class FilterCriteriaTypeDef(TypedDict):
Filters: NotRequired[Sequence[FilterTypeDef]], # (1)
- See FilterTypeDef
ListPipesRequestListPipesPaginateTypeDef
# ListPipesRequestListPipesPaginateTypeDef usage example
from mypy_boto3_pipes.type_defs import ListPipesRequestListPipesPaginateTypeDef
def get_value() -> ListPipesRequestListPipesPaginateTypeDef:
return {
"CurrentState": ...,
}
# ListPipesRequestListPipesPaginateTypeDef definition
class ListPipesRequestListPipesPaginateTypeDef(TypedDict):
CurrentState: NotRequired[PipeStateType], # (1)
DesiredState: NotRequired[RequestedPipeStateType], # (2)
NamePrefix: NotRequired[str],
SourcePrefix: NotRequired[str],
TargetPrefix: NotRequired[str],
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (3)
ListPipesResponseTypeDef
# ListPipesResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import ListPipesResponseTypeDef
def get_value() -> ListPipesResponseTypeDef:
return {
"NextToken": ...,
"Pipes": ...,
"ResponseMetadata": ...,
}
# ListPipesResponseTypeDef definition
class ListPipesResponseTypeDef(TypedDict):
NextToken: str,
Pipes: List[PipeTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
- See PipeTypeDef
- See ResponseMetadataTypeDef
PipeSourceActiveMQBrokerParametersTypeDef
# PipeSourceActiveMQBrokerParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceActiveMQBrokerParametersTypeDef
def get_value() -> PipeSourceActiveMQBrokerParametersTypeDef:
return {
"Credentials": ...,
"QueueName": ...,
}
# PipeSourceActiveMQBrokerParametersTypeDef definition
class PipeSourceActiveMQBrokerParametersTypeDef(TypedDict):
Credentials: MQBrokerAccessCredentialsTypeDef, # (1)
QueueName: str,
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
PipeSourceRabbitMQBrokerParametersTypeDef
# PipeSourceRabbitMQBrokerParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceRabbitMQBrokerParametersTypeDef
def get_value() -> PipeSourceRabbitMQBrokerParametersTypeDef:
return {
"Credentials": ...,
"QueueName": ...,
}
# PipeSourceRabbitMQBrokerParametersTypeDef definition
class PipeSourceRabbitMQBrokerParametersTypeDef(TypedDict):
Credentials: MQBrokerAccessCredentialsTypeDef, # (1)
QueueName: str,
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
VirtualHost: NotRequired[str],
UpdatePipeSourceActiveMQBrokerParametersTypeDef
# UpdatePipeSourceActiveMQBrokerParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceActiveMQBrokerParametersTypeDef
def get_value() -> UpdatePipeSourceActiveMQBrokerParametersTypeDef:
return {
"Credentials": ...,
}
# UpdatePipeSourceActiveMQBrokerParametersTypeDef definition
class UpdatePipeSourceActiveMQBrokerParametersTypeDef(TypedDict):
Credentials: MQBrokerAccessCredentialsTypeDef, # (1)
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
UpdatePipeSourceRabbitMQBrokerParametersTypeDef
# UpdatePipeSourceRabbitMQBrokerParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceRabbitMQBrokerParametersTypeDef
def get_value() -> UpdatePipeSourceRabbitMQBrokerParametersTypeDef:
return {
"Credentials": ...,
}
# UpdatePipeSourceRabbitMQBrokerParametersTypeDef definition
class UpdatePipeSourceRabbitMQBrokerParametersTypeDef(TypedDict):
Credentials: MQBrokerAccessCredentialsTypeDef, # (1)
BatchSize: NotRequired[int],
MaximumBatchingWindowInSeconds: NotRequired[int],
PipeSourceManagedStreamingKafkaParametersTypeDef
# PipeSourceManagedStreamingKafkaParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceManagedStreamingKafkaParametersTypeDef
def get_value() -> PipeSourceManagedStreamingKafkaParametersTypeDef:
return {
"TopicName": ...,
}
# PipeSourceManagedStreamingKafkaParametersTypeDef definition
class PipeSourceManagedStreamingKafkaParametersTypeDef(TypedDict):
TopicName: str,
BatchSize: NotRequired[int],
ConsumerGroupID: NotRequired[str],
Credentials: NotRequired[MSKAccessCredentialsTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
StartingPosition: NotRequired[MSKStartPositionType], # (2)
UpdatePipeSourceManagedStreamingKafkaParametersTypeDef
# UpdatePipeSourceManagedStreamingKafkaParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceManagedStreamingKafkaParametersTypeDef
def get_value() -> UpdatePipeSourceManagedStreamingKafkaParametersTypeDef:
return {
"BatchSize": ...,
}
# UpdatePipeSourceManagedStreamingKafkaParametersTypeDef definition
class UpdatePipeSourceManagedStreamingKafkaParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
Credentials: NotRequired[MSKAccessCredentialsTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
PipeEnrichmentParametersTypeDef
# PipeEnrichmentParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeEnrichmentParametersTypeDef
def get_value() -> PipeEnrichmentParametersTypeDef:
return {
"HttpParameters": ...,
}
# PipeEnrichmentParametersTypeDef definition
class PipeEnrichmentParametersTypeDef(TypedDict):
HttpParameters: NotRequired[PipeEnrichmentHttpParametersTypeDef], # (1)
InputTemplate: NotRequired[str],
PipeSourceSelfManagedKafkaParametersTypeDef
# PipeSourceSelfManagedKafkaParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceSelfManagedKafkaParametersTypeDef
def get_value() -> PipeSourceSelfManagedKafkaParametersTypeDef:
return {
"TopicName": ...,
}
# PipeSourceSelfManagedKafkaParametersTypeDef definition
class PipeSourceSelfManagedKafkaParametersTypeDef(TypedDict):
TopicName: str,
AdditionalBootstrapServers: NotRequired[Sequence[str]],
BatchSize: NotRequired[int],
ConsumerGroupID: NotRequired[str],
Credentials: NotRequired[SelfManagedKafkaAccessConfigurationCredentialsTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
ServerRootCaCertificate: NotRequired[str],
StartingPosition: NotRequired[SelfManagedKafkaStartPositionType], # (2)
Vpc: NotRequired[SelfManagedKafkaAccessConfigurationVpcTypeDef], # (3)
- See SelfManagedKafkaAccessConfigurationCredentialsTypeDef
- See SelfManagedKafkaStartPositionType
- See SelfManagedKafkaAccessConfigurationVpcTypeDef
UpdatePipeSourceSelfManagedKafkaParametersTypeDef
# UpdatePipeSourceSelfManagedKafkaParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceSelfManagedKafkaParametersTypeDef
def get_value() -> UpdatePipeSourceSelfManagedKafkaParametersTypeDef:
return {
"BatchSize": ...,
}
# UpdatePipeSourceSelfManagedKafkaParametersTypeDef definition
class UpdatePipeSourceSelfManagedKafkaParametersTypeDef(TypedDict):
BatchSize: NotRequired[int],
Credentials: NotRequired[SelfManagedKafkaAccessConfigurationCredentialsTypeDef], # (1)
MaximumBatchingWindowInSeconds: NotRequired[int],
ServerRootCaCertificate: NotRequired[str],
Vpc: NotRequired[SelfManagedKafkaAccessConfigurationVpcTypeDef], # (2)
- See SelfManagedKafkaAccessConfigurationCredentialsTypeDef
- See SelfManagedKafkaAccessConfigurationVpcTypeDef
PipeTargetSageMakerPipelineParametersTypeDef
# PipeTargetSageMakerPipelineParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetSageMakerPipelineParametersTypeDef
def get_value() -> PipeTargetSageMakerPipelineParametersTypeDef:
return {
"PipelineParameterList": ...,
}
# PipeTargetSageMakerPipelineParametersTypeDef definition
class PipeTargetSageMakerPipelineParametersTypeDef(TypedDict):
PipelineParameterList: NotRequired[Sequence[SageMakerPipelineParameterTypeDef]], # (1)
PipeTargetBatchJobParametersTypeDef
# PipeTargetBatchJobParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetBatchJobParametersTypeDef
def get_value() -> PipeTargetBatchJobParametersTypeDef:
return {
"JobDefinition": ...,
"JobName": ...,
}
# PipeTargetBatchJobParametersTypeDef definition
class PipeTargetBatchJobParametersTypeDef(TypedDict):
JobDefinition: str,
JobName: str,
ArrayProperties: NotRequired[BatchArrayPropertiesTypeDef], # (1)
ContainerOverrides: NotRequired[BatchContainerOverridesTypeDef], # (2)
DependsOn: NotRequired[Sequence[BatchJobDependencyTypeDef]], # (3)
Parameters: NotRequired[Mapping[str, str]],
RetryStrategy: NotRequired[BatchRetryStrategyTypeDef], # (4)
- See BatchArrayPropertiesTypeDef
- See BatchContainerOverridesTypeDef
- See BatchJobDependencyTypeDef
- See BatchRetryStrategyTypeDef
EcsTaskOverrideTypeDef
# EcsTaskOverrideTypeDef usage example
from mypy_boto3_pipes.type_defs import EcsTaskOverrideTypeDef
def get_value() -> EcsTaskOverrideTypeDef:
return {
"ContainerOverrides": ...,
}
# EcsTaskOverrideTypeDef definition
class EcsTaskOverrideTypeDef(TypedDict):
ContainerOverrides: NotRequired[Sequence[EcsContainerOverrideTypeDef]], # (1)
Cpu: NotRequired[str],
EphemeralStorage: NotRequired[EcsEphemeralStorageTypeDef], # (2)
ExecutionRoleArn: NotRequired[str],
InferenceAcceleratorOverrides: NotRequired[Sequence[EcsInferenceAcceleratorOverrideTypeDef]], # (3)
Memory: NotRequired[str],
TaskRoleArn: NotRequired[str],
- See EcsContainerOverrideTypeDef
- See EcsEphemeralStorageTypeDef
- See EcsInferenceAcceleratorOverrideTypeDef
PipeSourceParametersTypeDef
# PipeSourceParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeSourceParametersTypeDef
def get_value() -> PipeSourceParametersTypeDef:
return {
"ActiveMQBrokerParameters": ...,
}
# PipeSourceParametersTypeDef definition
class PipeSourceParametersTypeDef(TypedDict):
ActiveMQBrokerParameters: NotRequired[PipeSourceActiveMQBrokerParametersTypeDef], # (1)
DynamoDBStreamParameters: NotRequired[PipeSourceDynamoDBStreamParametersTypeDef], # (2)
FilterCriteria: NotRequired[FilterCriteriaTypeDef], # (3)
KinesisStreamParameters: NotRequired[PipeSourceKinesisStreamParametersTypeDef], # (4)
ManagedStreamingKafkaParameters: NotRequired[PipeSourceManagedStreamingKafkaParametersTypeDef], # (5)
RabbitMQBrokerParameters: NotRequired[PipeSourceRabbitMQBrokerParametersTypeDef], # (6)
SelfManagedKafkaParameters: NotRequired[PipeSourceSelfManagedKafkaParametersTypeDef], # (7)
SqsQueueParameters: NotRequired[PipeSourceSqsQueueParametersTypeDef], # (8)
- See PipeSourceActiveMQBrokerParametersTypeDef
- See PipeSourceDynamoDBStreamParametersTypeDef
- See FilterCriteriaTypeDef
- See PipeSourceKinesisStreamParametersTypeDef
- See PipeSourceManagedStreamingKafkaParametersTypeDef
- See PipeSourceRabbitMQBrokerParametersTypeDef
- See PipeSourceSelfManagedKafkaParametersTypeDef
- See PipeSourceSqsQueueParametersTypeDef
UpdatePipeSourceParametersTypeDef
# UpdatePipeSourceParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeSourceParametersTypeDef
def get_value() -> UpdatePipeSourceParametersTypeDef:
return {
"ActiveMQBrokerParameters": ...,
}
# UpdatePipeSourceParametersTypeDef definition
class UpdatePipeSourceParametersTypeDef(TypedDict):
ActiveMQBrokerParameters: NotRequired[UpdatePipeSourceActiveMQBrokerParametersTypeDef], # (1)
DynamoDBStreamParameters: NotRequired[UpdatePipeSourceDynamoDBStreamParametersTypeDef], # (2)
FilterCriteria: NotRequired[FilterCriteriaTypeDef], # (3)
KinesisStreamParameters: NotRequired[UpdatePipeSourceKinesisStreamParametersTypeDef], # (4)
ManagedStreamingKafkaParameters: NotRequired[UpdatePipeSourceManagedStreamingKafkaParametersTypeDef], # (5)
RabbitMQBrokerParameters: NotRequired[UpdatePipeSourceRabbitMQBrokerParametersTypeDef], # (6)
SelfManagedKafkaParameters: NotRequired[UpdatePipeSourceSelfManagedKafkaParametersTypeDef], # (7)
SqsQueueParameters: NotRequired[UpdatePipeSourceSqsQueueParametersTypeDef], # (8)
- See UpdatePipeSourceActiveMQBrokerParametersTypeDef
- See UpdatePipeSourceDynamoDBStreamParametersTypeDef
- See FilterCriteriaTypeDef
- See UpdatePipeSourceKinesisStreamParametersTypeDef
- See UpdatePipeSourceManagedStreamingKafkaParametersTypeDef
- See UpdatePipeSourceRabbitMQBrokerParametersTypeDef
- See UpdatePipeSourceSelfManagedKafkaParametersTypeDef
- See UpdatePipeSourceSqsQueueParametersTypeDef
PipeTargetEcsTaskParametersTypeDef
# PipeTargetEcsTaskParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetEcsTaskParametersTypeDef
def get_value() -> PipeTargetEcsTaskParametersTypeDef:
return {
"TaskDefinitionArn": ...,
}
# PipeTargetEcsTaskParametersTypeDef definition
class PipeTargetEcsTaskParametersTypeDef(TypedDict):
TaskDefinitionArn: str,
CapacityProviderStrategy: NotRequired[Sequence[CapacityProviderStrategyItemTypeDef]], # (1)
EnableECSManagedTags: NotRequired[bool],
EnableExecuteCommand: NotRequired[bool],
Group: NotRequired[str],
LaunchType: NotRequired[LaunchTypeType], # (2)
NetworkConfiguration: NotRequired[NetworkConfigurationTypeDef], # (3)
Overrides: NotRequired[EcsTaskOverrideTypeDef], # (4)
PlacementConstraints: NotRequired[Sequence[PlacementConstraintTypeDef]], # (5)
PlacementStrategy: NotRequired[Sequence[PlacementStrategyTypeDef]], # (6)
PlatformVersion: NotRequired[str],
PropagateTags: NotRequired[PropagateTagsType], # (7)
ReferenceId: NotRequired[str],
Tags: NotRequired[Sequence[TagTypeDef]], # (8)
TaskCount: NotRequired[int],
- See CapacityProviderStrategyItemTypeDef
- See LaunchTypeType
- See NetworkConfigurationTypeDef
- See EcsTaskOverrideTypeDef
- See PlacementConstraintTypeDef
- See PlacementStrategyTypeDef
- See PropagateTagsType
- See TagTypeDef
PipeTargetParametersTypeDef
# PipeTargetParametersTypeDef usage example
from mypy_boto3_pipes.type_defs import PipeTargetParametersTypeDef
def get_value() -> PipeTargetParametersTypeDef:
return {
"BatchJobParameters": ...,
}
# PipeTargetParametersTypeDef definition
class PipeTargetParametersTypeDef(TypedDict):
BatchJobParameters: NotRequired[PipeTargetBatchJobParametersTypeDef], # (1)
CloudWatchLogsParameters: NotRequired[PipeTargetCloudWatchLogsParametersTypeDef], # (2)
EcsTaskParameters: NotRequired[PipeTargetEcsTaskParametersTypeDef], # (3)
EventBridgeEventBusParameters: NotRequired[PipeTargetEventBridgeEventBusParametersTypeDef], # (4)
HttpParameters: NotRequired[PipeTargetHttpParametersTypeDef], # (5)
InputTemplate: NotRequired[str],
KinesisStreamParameters: NotRequired[PipeTargetKinesisStreamParametersTypeDef], # (6)
LambdaFunctionParameters: NotRequired[PipeTargetLambdaFunctionParametersTypeDef], # (7)
RedshiftDataParameters: NotRequired[PipeTargetRedshiftDataParametersTypeDef], # (8)
SageMakerPipelineParameters: NotRequired[PipeTargetSageMakerPipelineParametersTypeDef], # (9)
SqsQueueParameters: NotRequired[PipeTargetSqsQueueParametersTypeDef], # (10)
StepFunctionStateMachineParameters: NotRequired[PipeTargetStateMachineParametersTypeDef], # (11)
- See PipeTargetBatchJobParametersTypeDef
- See PipeTargetCloudWatchLogsParametersTypeDef
- See PipeTargetEcsTaskParametersTypeDef
- See PipeTargetEventBridgeEventBusParametersTypeDef
- See PipeTargetHttpParametersTypeDef
- See PipeTargetKinesisStreamParametersTypeDef
- See PipeTargetLambdaFunctionParametersTypeDef
- See PipeTargetRedshiftDataParametersTypeDef
- See PipeTargetSageMakerPipelineParametersTypeDef
- See PipeTargetSqsQueueParametersTypeDef
- See PipeTargetStateMachineParametersTypeDef
CreatePipeRequestRequestTypeDef
# CreatePipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import CreatePipeRequestRequestTypeDef
def get_value() -> CreatePipeRequestRequestTypeDef:
return {
"Name": ...,
"RoleArn": ...,
"Source": ...,
"Target": ...,
}
# CreatePipeRequestRequestTypeDef definition
class CreatePipeRequestRequestTypeDef(TypedDict):
Name: str,
RoleArn: str,
Source: str,
Target: str,
Description: NotRequired[str],
DesiredState: NotRequired[RequestedPipeStateType], # (1)
Enrichment: NotRequired[str],
EnrichmentParameters: NotRequired[PipeEnrichmentParametersTypeDef], # (2)
SourceParameters: NotRequired[PipeSourceParametersTypeDef], # (3)
Tags: NotRequired[Mapping[str, str]],
TargetParameters: NotRequired[PipeTargetParametersTypeDef], # (4)
- See RequestedPipeStateType
- See PipeEnrichmentParametersTypeDef
- See PipeSourceParametersTypeDef
- See PipeTargetParametersTypeDef
DescribePipeResponseTypeDef
# DescribePipeResponseTypeDef usage example
from mypy_boto3_pipes.type_defs import DescribePipeResponseTypeDef
def get_value() -> DescribePipeResponseTypeDef:
return {
"Arn": ...,
"CreationTime": ...,
"CurrentState": ...,
"Description": ...,
"DesiredState": ...,
"Enrichment": ...,
"EnrichmentParameters": ...,
"LastModifiedTime": ...,
"Name": ...,
"RoleArn": ...,
"Source": ...,
"SourceParameters": ...,
"StateReason": ...,
"Tags": ...,
"Target": ...,
"TargetParameters": ...,
"ResponseMetadata": ...,
}
# DescribePipeResponseTypeDef definition
class DescribePipeResponseTypeDef(TypedDict):
Arn: str,
CreationTime: datetime,
CurrentState: PipeStateType, # (1)
Description: str,
DesiredState: RequestedPipeStateDescribeResponseType, # (2)
Enrichment: str,
EnrichmentParameters: PipeEnrichmentParametersTypeDef, # (3)
LastModifiedTime: datetime,
Name: str,
RoleArn: str,
Source: str,
SourceParameters: PipeSourceParametersTypeDef, # (4)
StateReason: str,
Tags: Dict[str, str],
Target: str,
TargetParameters: PipeTargetParametersTypeDef, # (5)
ResponseMetadata: ResponseMetadataTypeDef, # (6)
- See PipeStateType
- See RequestedPipeStateDescribeResponseType
- See PipeEnrichmentParametersTypeDef
- See PipeSourceParametersTypeDef
- See PipeTargetParametersTypeDef
- See ResponseMetadataTypeDef
UpdatePipeRequestRequestTypeDef
# UpdatePipeRequestRequestTypeDef usage example
from mypy_boto3_pipes.type_defs import UpdatePipeRequestRequestTypeDef
def get_value() -> UpdatePipeRequestRequestTypeDef:
return {
"Name": ...,
"RoleArn": ...,
}
# UpdatePipeRequestRequestTypeDef definition
class UpdatePipeRequestRequestTypeDef(TypedDict):
Name: str,
RoleArn: str,
Description: NotRequired[str],
DesiredState: NotRequired[RequestedPipeStateType], # (1)
Enrichment: NotRequired[str],
EnrichmentParameters: NotRequired[PipeEnrichmentParametersTypeDef], # (2)
SourceParameters: NotRequired[UpdatePipeSourceParametersTypeDef], # (3)
Target: NotRequired[str],
TargetParameters: NotRequired[PipeTargetParametersTypeDef], # (4)