Kinesis module#
Index > Kinesis
Auto-generated documentation for Kinesis type annotations stubs module mypy-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.35.86' mypy_boto3_builder
- Select
boto3-stubs
AWS SDK. - Add
Kinesis
service. - 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 boto3-stubs
for Kinesis
service.
# install with boto3 type annotations
python -m pip install 'boto3-stubs[kinesis]'
# Lite version does not provide session.client/resource overloads
# it is more RAM-friendly, but requires explicit type annotations
python -m pip install 'boto3-stubs-lite[kinesis]'
# standalone installation
python -m pip install mypy-boto3-kinesis
How to uninstall#
python -m pip uninstall -y mypy-boto3-kinesis
Usage#
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 mypy_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 mypy_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 mypy_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 mypy_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.
- AddTagsToStreamInputRequestTypeDef
- BlobTypeDef
- HashKeyRangeTypeDef
- ConsumerDescriptionTypeDef
- ConsumerTypeDef
- StreamModeDetailsTypeDef
- DecreaseStreamRetentionPeriodInputRequestTypeDef
- DeleteResourcePolicyInputRequestTypeDef
- DeleteStreamInputRequestTypeDef
- DeregisterStreamConsumerInputRequestTypeDef
- ResponseMetadataTypeDef
- DescribeStreamConsumerInputRequestTypeDef
- PaginatorConfigTypeDef
- DescribeStreamInputRequestTypeDef
- WaiterConfigTypeDef
- DescribeStreamSummaryInputRequestTypeDef
- DisableEnhancedMonitoringInputRequestTypeDef
- EnableEnhancedMonitoringInputRequestTypeDef
- EnhancedMetricsTypeDef
- GetRecordsInputRequestTypeDef
- RecordTypeDef
- GetResourcePolicyInputRequestTypeDef
- TimestampTypeDef
- IncreaseStreamRetentionPeriodInputRequestTypeDef
- InternalFailureExceptionTypeDef
- KMSAccessDeniedExceptionTypeDef
- KMSDisabledExceptionTypeDef
- KMSInvalidStateExceptionTypeDef
- KMSNotFoundExceptionTypeDef
- KMSOptInRequiredTypeDef
- KMSThrottlingExceptionTypeDef
- ListStreamsInputRequestTypeDef
- ListTagsForStreamInputRequestTypeDef
- TagTypeDef
- MergeShardsInputRequestTypeDef
- PutRecordsResultEntryTypeDef
- PutResourcePolicyInputRequestTypeDef
- RegisterStreamConsumerInputRequestTypeDef
- RemoveTagsFromStreamInputRequestTypeDef
- ResourceInUseExceptionTypeDef
- ResourceNotFoundExceptionTypeDef
- SequenceNumberRangeTypeDef
- SplitShardInputRequestTypeDef
- StartStreamEncryptionInputRequestTypeDef
- StopStreamEncryptionInputRequestTypeDef
- UpdateShardCountInputRequestTypeDef
- PutRecordInputRequestTypeDef
- PutRecordsRequestEntryTypeDef
- ChildShardTypeDef
- CreateStreamInputRequestTypeDef
- StreamSummaryTypeDef
- UpdateStreamModeInputRequestTypeDef
- DescribeLimitsOutputTypeDef
- DescribeStreamConsumerOutputTypeDef
- EmptyResponseMetadataTypeDef
- EnhancedMonitoringOutputTypeDef
- GetResourcePolicyOutputTypeDef
- GetShardIteratorOutputTypeDef
- ListStreamConsumersOutputTypeDef
- PutRecordOutputTypeDef
- RegisterStreamConsumerOutputTypeDef
- UpdateShardCountOutputTypeDef
- DescribeStreamInputPaginateTypeDef
- ListStreamsInputPaginateTypeDef
- DescribeStreamInputWaitTypeDef
- StreamDescriptionSummaryTypeDef
- GetShardIteratorInputRequestTypeDef
- ListStreamConsumersInputPaginateTypeDef
- ListStreamConsumersInputRequestTypeDef
- ShardFilterTypeDef
- StartingPositionTypeDef
- ListTagsForStreamOutputTypeDef
- PutRecordsOutputTypeDef
- ShardTypeDef
- PutRecordsInputRequestTypeDef
- GetRecordsOutputTypeDef
- SubscribeToShardEventTypeDef
- ListStreamsOutputTypeDef
- DescribeStreamSummaryOutputTypeDef
- ListShardsInputPaginateTypeDef
- ListShardsInputRequestTypeDef
- SubscribeToShardInputRequestTypeDef
- ListShardsOutputTypeDef
- StreamDescriptionTypeDef
- SubscribeToShardEventStreamTypeDef
- DescribeStreamOutputTypeDef
- SubscribeToShardOutputTypeDef