将50K记录从JSON或CSV加载到DynamoDB

import boto3
import json
import csv

# 创建DynamoDB客户端
dynamodb = boto3.resource('dynamodb')

# 打开JSON文件并加载数据到DynamoDB表
def load_json_to_dynamodb(table_name, json_file):
    table = dynamodb.Table(table_name)
    with open(json_file) as file:
        data = json.load(file)
        with table.batch_writer() as batch:
            for item in data:
                batch.put_item(Item=item)

# 打开CSV文件并加载数据到DynamoDB表
def load_csv_to_dynamodb(table_name, csv_file):
    table = dynamodb.Table(table_name)
    with open(csv_file, 'r') as file:
        reader = csv.DictReader(file)
        with table.batch_writer() as batch:
            for row in reader:
                batch.put_item(Item=row)

# 调用函数加载数据到DynamoDB表
load_json_to_dynamodb('your_table_name', 'your_json_file.json')
load_csv_to_dynamodb('your_table_name', 'your_csv_file.csv')