import asyncio
import aioboto3
from boto3.dynamodb.conditions import Key

import config


async def main(items):
    async with aioboto3.resource('dynamodb') as dynamo_resource:
        table = dynamo_resource.Table(config.TABLE_NAME)

        async with table.batch_writer() as batch:
            for item in items:
                await batch.put_item(item)



def insert_items(items):
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main(items))