Paginators#
Auto-generated documentation for Kinesis type annotations stubs module types-aiobotocore-kinesis.
DescribeStreamPaginator#
Type annotations and code completion for session.client("kinesis").get_paginator("describe_stream")
.
boto3 documentation
# DescribeStreamPaginator usage example
from aioboto3.session import Session
from types_aiobotocore_kinesis.paginator import DescribeStreamPaginator
session = Session()
session = get_session()
async with session.client("kinesis") as client: # (1)
paginator: DescribeStreamPaginator = client.get_paginator("describe_stream") # (2)
async for item in paginator.paginate(...):
item: DescribeStreamOutputTypeDef
print(item) # (3)
- client: KinesisClient
- paginator: DescribeStreamPaginator
- item: DescribeStreamOutputTypeDef
paginate#
Type annotations and code completion for DescribeStreamPaginator.paginate
method.
# paginate method definition
def paginate(
self,
*,
StreamName: str = ...,
StreamARN: str = ...,
PaginationConfig: PaginatorConfigTypeDef = ..., # (1)
) -> AsyncIterator[DescribeStreamOutputTypeDef]: # (2)
...
# paginate method usage example with argument unpacking
kwargs: DescribeStreamInputDescribeStreamPaginateTypeDef = { # (1)
"StreamName": ...,
}
parent.paginate(**kwargs)
ListShardsPaginator#
Type annotations and code completion for session.client("kinesis").get_paginator("list_shards")
.
boto3 documentation
# ListShardsPaginator usage example
from aioboto3.session import Session
from types_aiobotocore_kinesis.paginator import ListShardsPaginator
session = Session()
session = get_session()
async with session.client("kinesis") as client: # (1)
paginator: ListShardsPaginator = client.get_paginator("list_shards") # (2)
async for item in paginator.paginate(...):
item: ListShardsOutputTypeDef
print(item) # (3)
- client: KinesisClient
- paginator: ListShardsPaginator
- item: ListShardsOutputTypeDef
paginate#
Type annotations and code completion for ListShardsPaginator.paginate
method.
# paginate method definition
def paginate(
self,
*,
StreamName: str = ...,
ExclusiveStartShardId: str = ...,
StreamCreationTimestamp: Union[datetime, str] = ...,
ShardFilter: ShardFilterTypeDef = ..., # (1)
StreamARN: str = ...,
PaginationConfig: PaginatorConfigTypeDef = ..., # (2)
) -> AsyncIterator[ListShardsOutputTypeDef]: # (3)
...
# paginate method usage example with argument unpacking
kwargs: ListShardsInputListShardsPaginateTypeDef = { # (1)
"StreamName": ...,
}
parent.paginate(**kwargs)
ListStreamConsumersPaginator#
Type annotations and code completion for session.client("kinesis").get_paginator("list_stream_consumers")
.
boto3 documentation
# ListStreamConsumersPaginator usage example
from aioboto3.session import Session
from types_aiobotocore_kinesis.paginator import ListStreamConsumersPaginator
session = Session()
session = get_session()
async with session.client("kinesis") as client: # (1)
paginator: ListStreamConsumersPaginator = client.get_paginator("list_stream_consumers") # (2)
async for item in paginator.paginate(...):
item: ListStreamConsumersOutputTypeDef
print(item) # (3)
- client: KinesisClient
- paginator: ListStreamConsumersPaginator
- item: ListStreamConsumersOutputTypeDef
paginate#
Type annotations and code completion for ListStreamConsumersPaginator.paginate
method.
# paginate method definition
def paginate(
self,
*,
StreamARN: str,
StreamCreationTimestamp: Union[datetime, str] = ...,
PaginationConfig: PaginatorConfigTypeDef = ..., # (1)
) -> AsyncIterator[ListStreamConsumersOutputTypeDef]: # (2)
...
# paginate method usage example with argument unpacking
kwargs: ListStreamConsumersInputListStreamConsumersPaginateTypeDef = { # (1)
"StreamARN": ...,
}
parent.paginate(**kwargs)
ListStreamsPaginator#
Type annotations and code completion for session.client("kinesis").get_paginator("list_streams")
.
boto3 documentation
# ListStreamsPaginator usage example
from aioboto3.session import Session
from types_aiobotocore_kinesis.paginator import ListStreamsPaginator
session = Session()
session = get_session()
async with session.client("kinesis") as client: # (1)
paginator: ListStreamsPaginator = client.get_paginator("list_streams") # (2)
async for item in paginator.paginate(...):
item: ListStreamsOutputTypeDef
print(item) # (3)
- client: KinesisClient
- paginator: ListStreamsPaginator
- item: ListStreamsOutputTypeDef
paginate#
Type annotations and code completion for ListStreamsPaginator.paginate
method.
# paginate method definition
def paginate(
self,
*,
ExclusiveStartStreamName: str = ...,
PaginationConfig: PaginatorConfigTypeDef = ..., # (1)
) -> AsyncIterator[ListStreamsOutputTypeDef]: # (2)
...
# paginate method usage example with argument unpacking
kwargs: ListStreamsInputListStreamsPaginateTypeDef = { # (1)
"ExclusiveStartStreamName": ...,
}
parent.paginate(**kwargs)