Untitled

import json
import boto3
import threading


def batch_write_items(items, table_name):
    dynamodb = boto3.resource('dynamodb')
    table = dynamodb.Table(table_name)

    try:
        table.batch_write_item(RequestItems={table_name: items})
    except Exception as e:
        print(f'Error writing items to DynamoDB: {e}')


def read_file(file_path):
    with open(file_path, 'r') as f:
        items = []
        for line in f:
            items.append(json.loads(line))

    return items


def main():
    file_path = 'items.json'
    table_name = 'my_table'
    items = read_file(file_path)

    threads = []
    for i in range(10):
        thread = threading.Thread(target=batch_write_items, args=(items[i::10], table_name))
        threads.append(thread)

    for thread in threads:
        thread.start()

    for thread in threads:
        thread.join()


if __name__ == '__main__':
    main()