Kinesis module#
Index > Kinesis
Auto-generated documentation for Kinesis type annotations stubs module types-boto3-kinesis.
How to install#
Generate locally (recommended)#
You can generate type annotations for boto3 package locally with mypy-boto3-builder.
Use uv for build isolation.
- Run mypy-boto3-builder in your package root directory: uvx --with 'boto3==1.40.63' mypy-boto3-builder
- Select boto3AWS SDK.
- Add Kinesisservice.
- Use provided commands to install generated packages.
VSCode extension#
Add AWS Boto3
extension to your VSCode and run AWS boto3: Quick Start command.
Click Modify and select boto3 common and Kinesis.
From PyPI with pip#
Install types-boto3 for Kinesis service.
# install with boto3 type annotations
python -m pip install 'types-boto3[kinesis]'
# Lite version does not provide session.client/resource overloads
# it is more RAM-friendly, but requires explicit type annotations
python -m pip install 'types-boto3-lite[kinesis]'
# standalone installation
python -m pip install types-boto3-kinesisHow to uninstall#
python -m pip uninstall -y types-boto3-kinesisUsage#
Code samples can be found in Examples.
KinesisClient#
Type annotations and code completion for  boto3.client("kinesis") as KinesisClient
 boto3 documentation
# KinesisClient usage example
from boto3.session import Session
from types_boto3_kinesis.client import KinesisClient
def get_client() -> KinesisClient:
    return Session().client("kinesis")Paginators#
Type annotations and code completion for paginators
from boto3.client("kinesis").get_paginator("...").
# DescribeStreamPaginator usage example
from boto3.session import Session
from types_boto3_kinesis.paginator import DescribeStreamPaginator
def get_describe_stream_paginator() -> DescribeStreamPaginator:
    return Session().client("kinesis").get_paginator("describe_stream"))Waiters#
Type annotations and code completion for waiters
from boto3.client("kinesis").get_waiter("...").
# StreamExistsWaiter usage example
from boto3.session import Session
from types_boto3_kinesis.waiter import StreamExistsWaiter
def get_stream_exists_waiter() -> StreamExistsWaiter:
    return Session().client("kinesis").get_waiter("stream_exists")Literals#
Type annotations for literals used in methods and schema.
# ConsumerStatusType usage example
from types_boto3_kinesis.literals import ConsumerStatusType
def get_value() -> ConsumerStatusType:
    return "ACTIVE"- ConsumerStatusType
- DescribeStreamPaginatorName
- EncryptionTypeType
- ListShardsPaginatorName
- ListStreamConsumersPaginatorName
- ListStreamsPaginatorName
- MetricsNameType
- ScalingTypeType
- ShardFilterTypeType
- ShardIteratorTypeType
- StreamExistsWaiterName
- StreamModeType
- StreamNotExistsWaiterName
- StreamStatusType
- KinesisServiceName
- ServiceName
- ResourceServiceName
- PaginatorName
- WaiterName
- RegionName
Type definitions#
Type annotations for type definitions used in methods and schema.
- AddTagsToStreamInputTypeDef
- BlobTypeDef
- HashKeyRangeTypeDef
- ConsumerDescriptionTypeDef
- ConsumerTypeDef
- StreamModeDetailsTypeDef
- DecreaseStreamRetentionPeriodInputTypeDef
- DeleteResourcePolicyInputTypeDef
- DeleteStreamInputTypeDef
- DeregisterStreamConsumerInputTypeDef
- ResponseMetadataTypeDef
- DescribeStreamConsumerInputTypeDef
- PaginatorConfigTypeDef
- DescribeStreamInputTypeDef
- WaiterConfigTypeDef
- DescribeStreamSummaryInputTypeDef
- DisableEnhancedMonitoringInputTypeDef
- EnableEnhancedMonitoringInputTypeDef
- EnhancedMetricsTypeDef
- GetRecordsInputTypeDef
- RecordTypeDef
- GetResourcePolicyInputTypeDef
- TimestampTypeDef
- IncreaseStreamRetentionPeriodInputTypeDef
- InternalFailureExceptionTypeDef
- KMSAccessDeniedExceptionTypeDef
- KMSDisabledExceptionTypeDef
- KMSInvalidStateExceptionTypeDef
- KMSNotFoundExceptionTypeDef
- KMSOptInRequiredTypeDef
- KMSThrottlingExceptionTypeDef
- ListStreamsInputTypeDef
- ListTagsForResourceInputTypeDef
- TagTypeDef
- ListTagsForStreamInputTypeDef
- MergeShardsInputTypeDef
- PutRecordsResultEntryTypeDef
- PutResourcePolicyInputTypeDef
- RegisterStreamConsumerInputTypeDef
- RemoveTagsFromStreamInputTypeDef
- ResourceInUseExceptionTypeDef
- ResourceNotFoundExceptionTypeDef
- SequenceNumberRangeTypeDef
- SplitShardInputTypeDef
- StartStreamEncryptionInputTypeDef
- StopStreamEncryptionInputTypeDef
- TagResourceInputTypeDef
- UntagResourceInputTypeDef
- UpdateMaxRecordSizeInputTypeDef
- UpdateShardCountInputTypeDef
- PutRecordInputTypeDef
- PutRecordsRequestEntryTypeDef
- ChildShardTypeDef
- CreateStreamInputTypeDef
- StreamSummaryTypeDef
- UpdateStreamModeInputTypeDef
- DescribeLimitsOutputTypeDef
- DescribeStreamConsumerOutputTypeDef
- EmptyResponseMetadataTypeDef
- EnhancedMonitoringOutputTypeDef
- GetResourcePolicyOutputTypeDef
- GetShardIteratorOutputTypeDef
- ListStreamConsumersOutputTypeDef
- PutRecordOutputTypeDef
- RegisterStreamConsumerOutputTypeDef
- UpdateShardCountOutputTypeDef
- DescribeStreamInputPaginateTypeDef
- ListStreamsInputPaginateTypeDef
- DescribeStreamInputWaitExtraTypeDef
- DescribeStreamInputWaitTypeDef
- StreamDescriptionSummaryTypeDef
- GetShardIteratorInputTypeDef
- ListStreamConsumersInputPaginateTypeDef
- ListStreamConsumersInputTypeDef
- ShardFilterTypeDef
- StartingPositionTypeDef
- ListTagsForResourceOutputTypeDef
- ListTagsForStreamOutputTypeDef
- PutRecordsOutputTypeDef
- ShardTypeDef
- PutRecordsInputTypeDef
- GetRecordsOutputTypeDef
- SubscribeToShardEventTypeDef
- ListStreamsOutputTypeDef
- DescribeStreamSummaryOutputTypeDef
- ListShardsInputPaginateTypeDef
- ListShardsInputTypeDef
- SubscribeToShardInputTypeDef
- ListShardsOutputTypeDef
- StreamDescriptionTypeDef
- SubscribeToShardEventStreamTypeDef
- DescribeStreamOutputTypeDef
- SubscribeToShardOutputTypeDef