import asyncio
import aiobotocore

from .settings import AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY


async def get_stream(loop):
    bucket = 'dataintake'
    filename = 'dummy.bin'
    folder = 'aiobotocore'
    key = '{}/{}'.format(folder, filename)

    session = aiobotocore.get_session(loop=loop)
    async with session.create_client('s3', region_name='us-west-2',
                                     aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
                                     aws_access_key_id=AWS_ACCESS_KEY_ID) as client:

        response = await client.get_object(Bucket=bucket, Key=key)
        async with response['Body'] as stream:
            try:
                chunk = await stream.read(10)
                while len(chunk) > 0:
                    chunk = await stream.read(10)
            finally:
                stream.close()


loop = asyncio.get_event_loop()
loop.run_until_complete(get_stream(loop))