Typed dictionaries

Index > Kinesis > Typed dictionaries

Auto-generated documentation for Kinesis type annotations stubs module types-aiobotocore-kinesis.

AddTagsToStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import AddTagsToStreamInputRequestTypeDef

def get_value() -> AddTagsToStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
        "Tags": ...,
    }

Definition

class AddTagsToStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    Tags: Mapping[str, str],

HashKeyRangeTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import HashKeyRangeTypeDef

def get_value() -> HashKeyRangeTypeDef:
    return {
        "StartingHashKey": ...,
        "EndingHashKey": ...,
    }

Definition

class HashKeyRangeTypeDef(TypedDict):
    StartingHashKey: str,
    EndingHashKey: str,

ConsumerDescriptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ConsumerDescriptionTypeDef

def get_value() -> ConsumerDescriptionTypeDef:
    return {
        "ConsumerName": ...,
        "ConsumerARN": ...,
        "ConsumerStatus": ...,
        "ConsumerCreationTimestamp": ...,
        "StreamARN": ...,
    }

Definition

class ConsumerDescriptionTypeDef(TypedDict):
    ConsumerName: str,
    ConsumerARN: str,
    ConsumerStatus: ConsumerStatusType,  # (1)
    ConsumerCreationTimestamp: datetime,
    StreamARN: str,

1. See ConsumerStatusType

ConsumerTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ConsumerTypeDef

def get_value() -> ConsumerTypeDef:
    return {
        "ConsumerName": ...,
        "ConsumerARN": ...,
        "ConsumerStatus": ...,
        "ConsumerCreationTimestamp": ...,
    }

Definition

class ConsumerTypeDef(TypedDict):
    ConsumerName: str,
    ConsumerARN: str,
    ConsumerStatus: ConsumerStatusType,  # (1)
    ConsumerCreationTimestamp: datetime,

1. See ConsumerStatusType

StreamModeDetailsTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StreamModeDetailsTypeDef

def get_value() -> StreamModeDetailsTypeDef:
    return {
        "StreamMode": ...,
    }

Definition

class StreamModeDetailsTypeDef(TypedDict):
    StreamMode: StreamModeType,  # (1)

1. See StreamModeType

DecreaseStreamRetentionPeriodInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DecreaseStreamRetentionPeriodInputRequestTypeDef

def get_value() -> DecreaseStreamRetentionPeriodInputRequestTypeDef:
    return {
        "StreamName": ...,
        "RetentionPeriodHours": ...,
    }

Definition

class DecreaseStreamRetentionPeriodInputRequestTypeDef(TypedDict):
    StreamName: str,
    RetentionPeriodHours: int,

DeleteStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DeleteStreamInputRequestTypeDef

def get_value() -> DeleteStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DeleteStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    EnforceConsumerDeletion: NotRequired[bool],

DeregisterStreamConsumerInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DeregisterStreamConsumerInputRequestTypeDef

def get_value() -> DeregisterStreamConsumerInputRequestTypeDef:
    return {
        "StreamARN": ...,
    }

Definition

class DeregisterStreamConsumerInputRequestTypeDef(TypedDict):
    StreamARN: NotRequired[str],
    ConsumerName: NotRequired[str],
    ConsumerARN: NotRequired[str],

ResponseMetadataTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ResponseMetadataTypeDef

def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
        "HostId": ...,
        "HTTPStatusCode": ...,
        "HTTPHeaders": ...,
        "RetryAttempts": ...,
    }

Definition

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

DescribeStreamConsumerInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamConsumerInputRequestTypeDef

def get_value() -> DescribeStreamConsumerInputRequestTypeDef:
    return {
        "StreamARN": ...,
    }

Definition

class DescribeStreamConsumerInputRequestTypeDef(TypedDict):
    StreamARN: NotRequired[str],
    ConsumerName: NotRequired[str],
    ConsumerARN: NotRequired[str],

PaginatorConfigTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PaginatorConfigTypeDef

def get_value() -> PaginatorConfigTypeDef:
    return {
        "MaxItems": ...,
    }

Definition

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

DescribeStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamInputRequestTypeDef

def get_value() -> DescribeStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DescribeStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    Limit: NotRequired[int],
    ExclusiveStartShardId: NotRequired[str],

WaiterConfigTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import WaiterConfigTypeDef

def get_value() -> WaiterConfigTypeDef:
    return {
        "Delay": ...,
    }

Definition

class WaiterConfigTypeDef(TypedDict):
    Delay: NotRequired[int],
    MaxAttempts: NotRequired[int],

DescribeStreamSummaryInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamSummaryInputRequestTypeDef

def get_value() -> DescribeStreamSummaryInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DescribeStreamSummaryInputRequestTypeDef(TypedDict):
    StreamName: str,

DisableEnhancedMonitoringInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DisableEnhancedMonitoringInputRequestTypeDef

def get_value() -> DisableEnhancedMonitoringInputRequestTypeDef:
    return {
        "StreamName": ...,
        "ShardLevelMetrics": ...,
    }

Definition

class DisableEnhancedMonitoringInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardLevelMetrics: Sequence[MetricsNameType],  # (1)

1. See MetricsNameType

EnableEnhancedMonitoringInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import EnableEnhancedMonitoringInputRequestTypeDef

def get_value() -> EnableEnhancedMonitoringInputRequestTypeDef:
    return {
        "StreamName": ...,
        "ShardLevelMetrics": ...,
    }

Definition

class EnableEnhancedMonitoringInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardLevelMetrics: Sequence[MetricsNameType],  # (1)

1. See MetricsNameType

EnhancedMetricsTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import EnhancedMetricsTypeDef

def get_value() -> EnhancedMetricsTypeDef:
    return {
        "ShardLevelMetrics": ...,
    }

Definition

class EnhancedMetricsTypeDef(TypedDict):
    ShardLevelMetrics: NotRequired[List[MetricsNameType]],  # (1)

1. See MetricsNameType

GetRecordsInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import GetRecordsInputRequestTypeDef

def get_value() -> GetRecordsInputRequestTypeDef:
    return {
        "ShardIterator": ...,
    }

Definition

class GetRecordsInputRequestTypeDef(TypedDict):
    ShardIterator: str,
    Limit: NotRequired[int],

RecordTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import RecordTypeDef

def get_value() -> RecordTypeDef:
    return {
        "SequenceNumber": ...,
        "Data": ...,
        "PartitionKey": ...,
    }

Definition

class RecordTypeDef(TypedDict):
    SequenceNumber: str,
    Data: bytes,
    PartitionKey: str,
    ApproximateArrivalTimestamp: NotRequired[datetime],
    EncryptionType: NotRequired[EncryptionTypeType],  # (1)

1. See EncryptionTypeType

GetShardIteratorInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import GetShardIteratorInputRequestTypeDef

def get_value() -> GetShardIteratorInputRequestTypeDef:
    return {
        "StreamName": ...,
        "ShardId": ...,
        "ShardIteratorType": ...,
    }

Definition

class GetShardIteratorInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardId: str,
    ShardIteratorType: ShardIteratorTypeType,  # (1)
    StartingSequenceNumber: NotRequired[str],
    Timestamp: NotRequired[Union[datetime, str]],

1. See ShardIteratorTypeType

IncreaseStreamRetentionPeriodInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import IncreaseStreamRetentionPeriodInputRequestTypeDef

def get_value() -> IncreaseStreamRetentionPeriodInputRequestTypeDef:
    return {
        "StreamName": ...,
        "RetentionPeriodHours": ...,
    }

Definition

class IncreaseStreamRetentionPeriodInputRequestTypeDef(TypedDict):
    StreamName: str,
    RetentionPeriodHours: int,

InternalFailureExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import InternalFailureExceptionTypeDef

def get_value() -> InternalFailureExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class InternalFailureExceptionTypeDef(TypedDict):
    message: NotRequired[str],

KMSAccessDeniedExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSAccessDeniedExceptionTypeDef

def get_value() -> KMSAccessDeniedExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSAccessDeniedExceptionTypeDef(TypedDict):
    message: NotRequired[str],

KMSDisabledExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSDisabledExceptionTypeDef

def get_value() -> KMSDisabledExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSDisabledExceptionTypeDef(TypedDict):
    message: NotRequired[str],

KMSInvalidStateExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSInvalidStateExceptionTypeDef

def get_value() -> KMSInvalidStateExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSInvalidStateExceptionTypeDef(TypedDict):
    message: NotRequired[str],

KMSNotFoundExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSNotFoundExceptionTypeDef

def get_value() -> KMSNotFoundExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSNotFoundExceptionTypeDef(TypedDict):
    message: NotRequired[str],

KMSOptInRequiredTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSOptInRequiredTypeDef

def get_value() -> KMSOptInRequiredTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSOptInRequiredTypeDef(TypedDict):
    message: NotRequired[str],

KMSThrottlingExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import KMSThrottlingExceptionTypeDef

def get_value() -> KMSThrottlingExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class KMSThrottlingExceptionTypeDef(TypedDict):
    message: NotRequired[str],

ShardFilterTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ShardFilterTypeDef

def get_value() -> ShardFilterTypeDef:
    return {
        "Type": ...,
    }

Definition

class ShardFilterTypeDef(TypedDict):
    Type: ShardFilterTypeType,  # (1)
    ShardId: NotRequired[str],
    Timestamp: NotRequired[Union[datetime, str]],

1. See ShardFilterTypeType

ListStreamConsumersInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamConsumersInputRequestTypeDef

def get_value() -> ListStreamConsumersInputRequestTypeDef:
    return {
        "StreamARN": ...,
    }

Definition

class ListStreamConsumersInputRequestTypeDef(TypedDict):
    StreamARN: str,
    NextToken: NotRequired[str],
    MaxResults: NotRequired[int],
    StreamCreationTimestamp: NotRequired[Union[datetime, str]],

ListStreamsInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamsInputRequestTypeDef

def get_value() -> ListStreamsInputRequestTypeDef:
    return {
        "Limit": ...,
    }

Definition

class ListStreamsInputRequestTypeDef(TypedDict):
    Limit: NotRequired[int],
    ExclusiveStartStreamName: NotRequired[str],

ListTagsForStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListTagsForStreamInputRequestTypeDef

def get_value() -> ListTagsForStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class ListTagsForStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    ExclusiveStartTagKey: NotRequired[str],
    Limit: NotRequired[int],

TagTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import TagTypeDef

def get_value() -> TagTypeDef:
    return {
        "Key": ...,
    }

Definition

class TagTypeDef(TypedDict):
    Key: str,
    Value: NotRequired[str],

MergeShardsInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import MergeShardsInputRequestTypeDef

def get_value() -> MergeShardsInputRequestTypeDef:
    return {
        "StreamName": ...,
        "ShardToMerge": ...,
        "AdjacentShardToMerge": ...,
    }

Definition

class MergeShardsInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardToMerge: str,
    AdjacentShardToMerge: str,

PutRecordInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordInputRequestTypeDef

def get_value() -> PutRecordInputRequestTypeDef:
    return {
        "StreamName": ...,
        "Data": ...,
        "PartitionKey": ...,
    }

Definition

class PutRecordInputRequestTypeDef(TypedDict):
    StreamName: str,
    Data: Union[str, bytes, IO[Any], StreamingBody],
    PartitionKey: str,
    ExplicitHashKey: NotRequired[str],
    SequenceNumberForOrdering: NotRequired[str],

PutRecordsRequestEntryTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordsRequestEntryTypeDef

def get_value() -> PutRecordsRequestEntryTypeDef:
    return {
        "Data": ...,
        "PartitionKey": ...,
    }

Definition

class PutRecordsRequestEntryTypeDef(TypedDict):
    Data: Union[str, bytes, IO[Any], StreamingBody],
    PartitionKey: str,
    ExplicitHashKey: NotRequired[str],

PutRecordsResultEntryTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordsResultEntryTypeDef

def get_value() -> PutRecordsResultEntryTypeDef:
    return {
        "SequenceNumber": ...,
    }

Definition

class PutRecordsResultEntryTypeDef(TypedDict):
    SequenceNumber: NotRequired[str],
    ShardId: NotRequired[str],
    ErrorCode: NotRequired[str],
    ErrorMessage: NotRequired[str],

RegisterStreamConsumerInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import RegisterStreamConsumerInputRequestTypeDef

def get_value() -> RegisterStreamConsumerInputRequestTypeDef:
    return {
        "StreamARN": ...,
        "ConsumerName": ...,
    }

Definition

class RegisterStreamConsumerInputRequestTypeDef(TypedDict):
    StreamARN: str,
    ConsumerName: str,

RemoveTagsFromStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import RemoveTagsFromStreamInputRequestTypeDef

def get_value() -> RemoveTagsFromStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
        "TagKeys": ...,
    }

Definition

class RemoveTagsFromStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    TagKeys: Sequence[str],

ResourceInUseExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ResourceInUseExceptionTypeDef

def get_value() -> ResourceInUseExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class ResourceInUseExceptionTypeDef(TypedDict):
    message: NotRequired[str],

ResourceNotFoundExceptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ResourceNotFoundExceptionTypeDef

def get_value() -> ResourceNotFoundExceptionTypeDef:
    return {
        "message": ...,
    }

Definition

class ResourceNotFoundExceptionTypeDef(TypedDict):
    message: NotRequired[str],

SequenceNumberRangeTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SequenceNumberRangeTypeDef

def get_value() -> SequenceNumberRangeTypeDef:
    return {
        "StartingSequenceNumber": ...,
    }

Definition

class SequenceNumberRangeTypeDef(TypedDict):
    StartingSequenceNumber: str,
    EndingSequenceNumber: NotRequired[str],

SplitShardInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SplitShardInputRequestTypeDef

def get_value() -> SplitShardInputRequestTypeDef:
    return {
        "StreamName": ...,
        "ShardToSplit": ...,
        "NewStartingHashKey": ...,
    }

Definition

class SplitShardInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardToSplit: str,
    NewStartingHashKey: str,

StartStreamEncryptionInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StartStreamEncryptionInputRequestTypeDef

def get_value() -> StartStreamEncryptionInputRequestTypeDef:
    return {
        "StreamName": ...,
        "EncryptionType": ...,
        "KeyId": ...,
    }

Definition

class StartStreamEncryptionInputRequestTypeDef(TypedDict):
    StreamName: str,
    EncryptionType: EncryptionTypeType,  # (1)
    KeyId: str,

1. See EncryptionTypeType

StartingPositionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StartingPositionTypeDef

def get_value() -> StartingPositionTypeDef:
    return {
        "Type": ...,
    }

Definition

class StartingPositionTypeDef(TypedDict):
    Type: ShardIteratorTypeType,  # (1)
    SequenceNumber: NotRequired[str],
    Timestamp: NotRequired[Union[datetime, str]],

1. See ShardIteratorTypeType

StopStreamEncryptionInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StopStreamEncryptionInputRequestTypeDef

def get_value() -> StopStreamEncryptionInputRequestTypeDef:
    return {
        "StreamName": ...,
        "EncryptionType": ...,
        "KeyId": ...,
    }

Definition

class StopStreamEncryptionInputRequestTypeDef(TypedDict):
    StreamName: str,
    EncryptionType: EncryptionTypeType,  # (1)
    KeyId: str,

1. See EncryptionTypeType

UpdateShardCountInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import UpdateShardCountInputRequestTypeDef

def get_value() -> UpdateShardCountInputRequestTypeDef:
    return {
        "StreamName": ...,
        "TargetShardCount": ...,
        "ScalingType": ...,
    }

Definition

class UpdateShardCountInputRequestTypeDef(TypedDict):
    StreamName: str,
    TargetShardCount: int,
    ScalingType: ScalingTypeType,  # (1)

1. See ScalingTypeType

ChildShardTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ChildShardTypeDef

def get_value() -> ChildShardTypeDef:
    return {
        "ShardId": ...,
        "ParentShards": ...,
        "HashKeyRange": ...,
    }

Definition

class ChildShardTypeDef(TypedDict):
    ShardId: str,
    ParentShards: List[str],
    HashKeyRange: HashKeyRangeTypeDef,  # (1)

1. See HashKeyRangeTypeDef

CreateStreamInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import CreateStreamInputRequestTypeDef

def get_value() -> CreateStreamInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class CreateStreamInputRequestTypeDef(TypedDict):
    StreamName: str,
    ShardCount: NotRequired[int],
    StreamModeDetails: NotRequired[StreamModeDetailsTypeDef],  # (1)

1. See StreamModeDetailsTypeDef

UpdateStreamModeInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import UpdateStreamModeInputRequestTypeDef

def get_value() -> UpdateStreamModeInputRequestTypeDef:
    return {
        "StreamARN": ...,
        "StreamModeDetails": ...,
    }

Definition

class UpdateStreamModeInputRequestTypeDef(TypedDict):
    StreamARN: str,
    StreamModeDetails: StreamModeDetailsTypeDef,  # (1)

1. See StreamModeDetailsTypeDef

DescribeLimitsOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeLimitsOutputTypeDef

def get_value() -> DescribeLimitsOutputTypeDef:
    return {
        "ShardLimit": ...,
        "OpenShardCount": ...,
        "OnDemandStreamCount": ...,
        "OnDemandStreamCountLimit": ...,
        "ResponseMetadata": ...,
    }

Definition

class DescribeLimitsOutputTypeDef(TypedDict):
    ShardLimit: int,
    OpenShardCount: int,
    OnDemandStreamCount: int,
    OnDemandStreamCountLimit: int,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

DescribeStreamConsumerOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamConsumerOutputTypeDef

def get_value() -> DescribeStreamConsumerOutputTypeDef:
    return {
        "ConsumerDescription": ...,
        "ResponseMetadata": ...,
    }

Definition

class DescribeStreamConsumerOutputTypeDef(TypedDict):
    ConsumerDescription: ConsumerDescriptionTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See ConsumerDescriptionTypeDef
2. See ResponseMetadataTypeDef

EmptyResponseMetadataTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import EmptyResponseMetadataTypeDef

def get_value() -> EmptyResponseMetadataTypeDef:
    return {
        "ResponseMetadata": ...,
    }

Definition

class EmptyResponseMetadataTypeDef(TypedDict):
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

EnhancedMonitoringOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import EnhancedMonitoringOutputTypeDef

def get_value() -> EnhancedMonitoringOutputTypeDef:
    return {
        "StreamName": ...,
        "CurrentShardLevelMetrics": ...,
        "DesiredShardLevelMetrics": ...,
        "ResponseMetadata": ...,
    }

Definition

class EnhancedMonitoringOutputTypeDef(TypedDict):
    StreamName: str,
    CurrentShardLevelMetrics: List[MetricsNameType],  # (1)
    DesiredShardLevelMetrics: List[MetricsNameType],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)

1. See MetricsNameType
2. See MetricsNameType
3. See ResponseMetadataTypeDef

GetShardIteratorOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import GetShardIteratorOutputTypeDef

def get_value() -> GetShardIteratorOutputTypeDef:
    return {
        "ShardIterator": ...,
        "ResponseMetadata": ...,
    }

Definition

class GetShardIteratorOutputTypeDef(TypedDict):
    ShardIterator: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

ListStreamConsumersOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamConsumersOutputTypeDef

def get_value() -> ListStreamConsumersOutputTypeDef:
    return {
        "Consumers": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }

Definition

class ListStreamConsumersOutputTypeDef(TypedDict):
    Consumers: List[ConsumerTypeDef],  # (1)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See ConsumerTypeDef
2. See ResponseMetadataTypeDef

ListStreamsOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamsOutputTypeDef

def get_value() -> ListStreamsOutputTypeDef:
    return {
        "StreamNames": ...,
        "HasMoreStreams": ...,
        "ResponseMetadata": ...,
    }

Definition

class ListStreamsOutputTypeDef(TypedDict):
    StreamNames: List[str],
    HasMoreStreams: bool,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

PutRecordOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordOutputTypeDef

def get_value() -> PutRecordOutputTypeDef:
    return {
        "ShardId": ...,
        "SequenceNumber": ...,
        "EncryptionType": ...,
        "ResponseMetadata": ...,
    }

Definition

class PutRecordOutputTypeDef(TypedDict):
    ShardId: str,
    SequenceNumber: str,
    EncryptionType: EncryptionTypeType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See EncryptionTypeType
2. See ResponseMetadataTypeDef

RegisterStreamConsumerOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import RegisterStreamConsumerOutputTypeDef

def get_value() -> RegisterStreamConsumerOutputTypeDef:
    return {
        "Consumer": ...,
        "ResponseMetadata": ...,
    }

Definition

class RegisterStreamConsumerOutputTypeDef(TypedDict):
    Consumer: ConsumerTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See ConsumerTypeDef
2. See ResponseMetadataTypeDef

UpdateShardCountOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import UpdateShardCountOutputTypeDef

def get_value() -> UpdateShardCountOutputTypeDef:
    return {
        "StreamName": ...,
        "CurrentShardCount": ...,
        "TargetShardCount": ...,
        "ResponseMetadata": ...,
    }

Definition

class UpdateShardCountOutputTypeDef(TypedDict):
    StreamName: str,
    CurrentShardCount: int,
    TargetShardCount: int,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

DescribeStreamInputDescribeStreamPaginateTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamInputDescribeStreamPaginateTypeDef

def get_value() -> DescribeStreamInputDescribeStreamPaginateTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DescribeStreamInputDescribeStreamPaginateTypeDef(TypedDict):
    StreamName: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

ListStreamConsumersInputListStreamConsumersPaginateTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamConsumersInputListStreamConsumersPaginateTypeDef

def get_value() -> ListStreamConsumersInputListStreamConsumersPaginateTypeDef:
    return {
        "StreamARN": ...,
    }

Definition

class ListStreamConsumersInputListStreamConsumersPaginateTypeDef(TypedDict):
    StreamARN: str,
    StreamCreationTimestamp: NotRequired[Union[datetime, str]],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

ListStreamsInputListStreamsPaginateTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListStreamsInputListStreamsPaginateTypeDef

def get_value() -> ListStreamsInputListStreamsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }

Definition

class ListStreamsInputListStreamsPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

DescribeStreamInputStreamExistsWaitTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamInputStreamExistsWaitTypeDef

def get_value() -> DescribeStreamInputStreamExistsWaitTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DescribeStreamInputStreamExistsWaitTypeDef(TypedDict):
    StreamName: str,
    Limit: NotRequired[int],
    ExclusiveStartShardId: NotRequired[str],
    WaiterConfig: NotRequired[WaiterConfigTypeDef],  # (1)

1. See WaiterConfigTypeDef

DescribeStreamInputStreamNotExistsWaitTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamInputStreamNotExistsWaitTypeDef

def get_value() -> DescribeStreamInputStreamNotExistsWaitTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class DescribeStreamInputStreamNotExistsWaitTypeDef(TypedDict):
    StreamName: str,
    Limit: NotRequired[int],
    ExclusiveStartShardId: NotRequired[str],
    WaiterConfig: NotRequired[WaiterConfigTypeDef],  # (1)

1. See WaiterConfigTypeDef

StreamDescriptionSummaryTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StreamDescriptionSummaryTypeDef

def get_value() -> StreamDescriptionSummaryTypeDef:
    return {
        "StreamName": ...,
        "StreamARN": ...,
        "StreamStatus": ...,
        "RetentionPeriodHours": ...,
        "StreamCreationTimestamp": ...,
        "EnhancedMonitoring": ...,
        "OpenShardCount": ...,
    }

Definition

class StreamDescriptionSummaryTypeDef(TypedDict):
    StreamName: str,
    StreamARN: str,
    StreamStatus: StreamStatusType,  # (1)
    RetentionPeriodHours: int,
    StreamCreationTimestamp: datetime,
    EnhancedMonitoring: List[EnhancedMetricsTypeDef],  # (3)
    OpenShardCount: int,
    StreamModeDetails: NotRequired[StreamModeDetailsTypeDef],  # (2)
    EncryptionType: NotRequired[EncryptionTypeType],  # (4)
    KeyId: NotRequired[str],
    ConsumerCount: NotRequired[int],

1. See StreamStatusType
2. See StreamModeDetailsTypeDef
3. See EnhancedMetricsTypeDef
4. See EncryptionTypeType

ListShardsInputListShardsPaginateTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListShardsInputListShardsPaginateTypeDef

def get_value() -> ListShardsInputListShardsPaginateTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class ListShardsInputListShardsPaginateTypeDef(TypedDict):
    StreamName: NotRequired[str],
    ExclusiveStartShardId: NotRequired[str],
    StreamCreationTimestamp: NotRequired[Union[datetime, str]],
    ShardFilter: NotRequired[ShardFilterTypeDef],  # (1)
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (2)

1. See ShardFilterTypeDef
2. See PaginatorConfigTypeDef

ListShardsInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListShardsInputRequestTypeDef

def get_value() -> ListShardsInputRequestTypeDef:
    return {
        "StreamName": ...,
    }

Definition

class ListShardsInputRequestTypeDef(TypedDict):
    StreamName: NotRequired[str],
    NextToken: NotRequired[str],
    ExclusiveStartShardId: NotRequired[str],
    MaxResults: NotRequired[int],
    StreamCreationTimestamp: NotRequired[Union[datetime, str]],
    ShardFilter: NotRequired[ShardFilterTypeDef],  # (1)

1. See ShardFilterTypeDef

ListTagsForStreamOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListTagsForStreamOutputTypeDef

def get_value() -> ListTagsForStreamOutputTypeDef:
    return {
        "Tags": ...,
        "HasMoreTags": ...,
        "ResponseMetadata": ...,
    }

Definition

class ListTagsForStreamOutputTypeDef(TypedDict):
    Tags: List[TagTypeDef],  # (1)
    HasMoreTags: bool,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See TagTypeDef
2. See ResponseMetadataTypeDef

PutRecordsInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordsInputRequestTypeDef

def get_value() -> PutRecordsInputRequestTypeDef:
    return {
        "Records": ...,
        "StreamName": ...,
    }

Definition

class PutRecordsInputRequestTypeDef(TypedDict):
    Records: Sequence[PutRecordsRequestEntryTypeDef],  # (1)
    StreamName: str,

1. See PutRecordsRequestEntryTypeDef

PutRecordsOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import PutRecordsOutputTypeDef

def get_value() -> PutRecordsOutputTypeDef:
    return {
        "FailedRecordCount": ...,
        "Records": ...,
        "EncryptionType": ...,
        "ResponseMetadata": ...,
    }

Definition

class PutRecordsOutputTypeDef(TypedDict):
    FailedRecordCount: int,
    Records: List[PutRecordsResultEntryTypeDef],  # (1)
    EncryptionType: EncryptionTypeType,  # (2)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)

1. See PutRecordsResultEntryTypeDef
2. See EncryptionTypeType
3. See ResponseMetadataTypeDef

ShardTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ShardTypeDef

def get_value() -> ShardTypeDef:
    return {
        "ShardId": ...,
        "HashKeyRange": ...,
        "SequenceNumberRange": ...,
    }

Definition

class ShardTypeDef(TypedDict):
    ShardId: str,
    HashKeyRange: HashKeyRangeTypeDef,  # (1)
    SequenceNumberRange: SequenceNumberRangeTypeDef,  # (2)
    ParentShardId: NotRequired[str],
    AdjacentParentShardId: NotRequired[str],

1. See HashKeyRangeTypeDef
2. See SequenceNumberRangeTypeDef

SubscribeToShardInputRequestTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SubscribeToShardInputRequestTypeDef

def get_value() -> SubscribeToShardInputRequestTypeDef:
    return {
        "ConsumerARN": ...,
        "ShardId": ...,
        "StartingPosition": ...,
    }

Definition

class SubscribeToShardInputRequestTypeDef(TypedDict):
    ConsumerARN: str,
    ShardId: str,
    StartingPosition: StartingPositionTypeDef,  # (1)

1. See StartingPositionTypeDef

GetRecordsOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import GetRecordsOutputTypeDef

def get_value() -> GetRecordsOutputTypeDef:
    return {
        "Records": ...,
        "NextShardIterator": ...,
        "MillisBehindLatest": ...,
        "ChildShards": ...,
        "ResponseMetadata": ...,
    }

Definition

class GetRecordsOutputTypeDef(TypedDict):
    Records: List[RecordTypeDef],  # (1)
    NextShardIterator: str,
    MillisBehindLatest: int,
    ChildShards: List[ChildShardTypeDef],  # (2)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)

1. See RecordTypeDef
2. See ChildShardTypeDef
3. See ResponseMetadataTypeDef

SubscribeToShardEventTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SubscribeToShardEventTypeDef

def get_value() -> SubscribeToShardEventTypeDef:
    return {
        "Records": ...,
        "ContinuationSequenceNumber": ...,
        "MillisBehindLatest": ...,
    }

Definition

class SubscribeToShardEventTypeDef(TypedDict):
    Records: List[RecordTypeDef],  # (1)
    ContinuationSequenceNumber: str,
    MillisBehindLatest: int,
    ChildShards: NotRequired[List[ChildShardTypeDef]],  # (2)

1. See RecordTypeDef
2. See ChildShardTypeDef

DescribeStreamSummaryOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamSummaryOutputTypeDef

def get_value() -> DescribeStreamSummaryOutputTypeDef:
    return {
        "StreamDescriptionSummary": ...,
        "ResponseMetadata": ...,
    }

Definition

class DescribeStreamSummaryOutputTypeDef(TypedDict):
    StreamDescriptionSummary: StreamDescriptionSummaryTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See StreamDescriptionSummaryTypeDef
2. See ResponseMetadataTypeDef

ListShardsOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import ListShardsOutputTypeDef

def get_value() -> ListShardsOutputTypeDef:
    return {
        "Shards": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }

Definition

class ListShardsOutputTypeDef(TypedDict):
    Shards: List[ShardTypeDef],  # (1)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See ShardTypeDef
2. See ResponseMetadataTypeDef

StreamDescriptionTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import StreamDescriptionTypeDef

def get_value() -> StreamDescriptionTypeDef:
    return {
        "StreamName": ...,
        "StreamARN": ...,
        "StreamStatus": ...,
        "Shards": ...,
        "HasMoreShards": ...,
        "RetentionPeriodHours": ...,
        "StreamCreationTimestamp": ...,
        "EnhancedMonitoring": ...,
    }

Definition

class StreamDescriptionTypeDef(TypedDict):
    StreamName: str,
    StreamARN: str,
    StreamStatus: StreamStatusType,  # (1)
    Shards: List[ShardTypeDef],  # (3)
    HasMoreShards: bool,
    RetentionPeriodHours: int,
    StreamCreationTimestamp: datetime,
    EnhancedMonitoring: List[EnhancedMetricsTypeDef],  # (4)
    StreamModeDetails: NotRequired[StreamModeDetailsTypeDef],  # (2)
    EncryptionType: NotRequired[EncryptionTypeType],  # (5)
    KeyId: NotRequired[str],

1. See StreamStatusType
2. See StreamModeDetailsTypeDef
3. See ShardTypeDef
4. See EnhancedMetricsTypeDef
5. See EncryptionTypeType

SubscribeToShardEventStreamTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SubscribeToShardEventStreamTypeDef

def get_value() -> SubscribeToShardEventStreamTypeDef:
    return {
        "SubscribeToShardEvent": ...,
    }

Definition

class SubscribeToShardEventStreamTypeDef(TypedDict):
    SubscribeToShardEvent: SubscribeToShardEventTypeDef,  # (1)
    ResourceNotFoundException: NotRequired[ResourceNotFoundExceptionTypeDef],  # (2)
    ResourceInUseException: NotRequired[ResourceInUseExceptionTypeDef],  # (3)
    KMSDisabledException: NotRequired[KMSDisabledExceptionTypeDef],  # (4)
    KMSInvalidStateException: NotRequired[KMSInvalidStateExceptionTypeDef],  # (5)
    KMSAccessDeniedException: NotRequired[KMSAccessDeniedExceptionTypeDef],  # (6)
    KMSNotFoundException: NotRequired[KMSNotFoundExceptionTypeDef],  # (7)
    KMSOptInRequired: NotRequired[KMSOptInRequiredTypeDef],  # (8)
    KMSThrottlingException: NotRequired[KMSThrottlingExceptionTypeDef],  # (9)
    InternalFailureException: NotRequired[InternalFailureExceptionTypeDef],  # (10)

1. See SubscribeToShardEventTypeDef
2. See ResourceNotFoundExceptionTypeDef
3. See ResourceInUseExceptionTypeDef
4. See KMSDisabledExceptionTypeDef
5. See KMSInvalidStateExceptionTypeDef
6. See KMSAccessDeniedExceptionTypeDef
7. See KMSNotFoundExceptionTypeDef
8. See KMSOptInRequiredTypeDef
9. See KMSThrottlingExceptionTypeDef
10. See InternalFailureExceptionTypeDef

DescribeStreamOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import DescribeStreamOutputTypeDef

def get_value() -> DescribeStreamOutputTypeDef:
    return {
        "StreamDescription": ...,
        "ResponseMetadata": ...,
    }

Definition

class DescribeStreamOutputTypeDef(TypedDict):
    StreamDescription: StreamDescriptionTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See StreamDescriptionTypeDef
2. See ResponseMetadataTypeDef

SubscribeToShardOutputTypeDef

Usage Example

from types_aiobotocore_kinesis.type_defs import SubscribeToShardOutputTypeDef

def get_value() -> SubscribeToShardOutputTypeDef:
    return {
        "EventStream": ...,
        "ResponseMetadata": ...,
    }

Definition

class SubscribeToShardOutputTypeDef(TypedDict):
    EventStream: SubscribeToShardEventStreamTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See SubscribeToShardEventStreamTypeDef
2. See ResponseMetadataTypeDef