可以通过以下步骤完成:
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')
对于这个问题,腾讯云提供了一个适用于云原生应用的数据库产品TencentDB for TDSQL,它是一种高性能、高可用、弹性扩展的云原生数据库,适用于各种规模的应用场景。你可以使用TencentDB for TDSQL来存储和管理大量数据,并通过TDSQL的数据导入功能将JSON或CSV文件加载到数据库中。详情请参考TencentDB for TDSQL产品介绍。
领取专属 10元无门槛券
手把手带您无忧上云