def dynamo_db_batch_write(items): """ Write in db by batch """ dynamo_db = boto3.resource( 'dynamodb', endpoint_url=get_aws_endpoint_url('dynamodb'), region_name=EOC_DYNAMO_DB_REGION, ) table = dynamo_db.Table(EOC_DYNAMO_DB_NAME) with table.batch_writer() as batch: for item in items: batch.put_item(Item=item) logging.info('Batch insert done for {} records'.format(len(items)))