aioboto3 pagination

aioboto3_test.py

import asyncio
import os

import aioboto3

loop = asyncio.get_event_loop()


async def test():
    async with aioboto3.client('s3', region_name='us-east-1') as s3:
        paginator = s3.get_paginator('list_objects_v2')
        page_iterator = paginator.paginate(
            Bucket=os.environ.get('BUCKET_NAME'),
            Prefix='',
        )
        for page in page_iterator:
            print(len(page.get('Contents')))


def main():
    loop.run_until_complete(test())


if __name__ == '__main__':
    main()

output.log

Traceback (most recent call last):
  File "aioboto3_test.py", line 25, in <module>
    main()
  File "aioboto3_test.py", line 21, in main
    loop.run_until_complete(test())
  File "/usr/lib/python3.6/asyncio/base_events.py", line 473, in run_until_complete
    return future.result()
  File "aioboto3_test.py", line 16, in test
    for page in page_iterator:
  File "/home/user/venv/lib/python3.6/site-packages/aioboto3/aiobotocore/paginate.py", line 13, in __iter__
    raise NotImplementedError
NotImplementedError