pymongo
是 Python 的 MongoDB 驱动程序,用于与 MongoDB 数据库进行交互。CSV(Comma-Separated Values)文件是一种常见的数据交换格式,通常用于存储表格数据。
pymongo
提供了丰富的 API,可以方便地进行数据的插入、查询、更新和删除操作。pymongo
可以快速实现数据处理和存储。pymongo
是一个数据库驱动程序,用于连接和操作 MongoDB。以下是一个示例代码,展示如何使用 pymongo
将 CSV 文件插入到 MongoDB 数据库中:
import csv
from pymongo import MongoClient
# 连接到 MongoDB 数据库
client = MongoClient('mongodb://localhost:27017/')
db = client['mydatabase']
collection = db['mycollection']
# 打开 CSV 文件并读取数据
with open('data.csv', newline='') as csvfile:
reader = csv.DictReader(csvfile)
for row in reader:
# 将每一行数据插入到 MongoDB 集合中
collection.insert_one(row)
print("数据插入完成")
# 批量插入数据
data = []
with open('data.csv', newline='') as csvfile:
reader = csv.DictReader(csvfile)
for row in reader:
data.append(row)
if len(data) >= 1000: # 每 1000 条插入一次
collection.insert_many(data)
data = []
# 插入剩余的数据
if data:
collection.insert_many(data)
print("数据插入完成")
通过以上方法,可以有效地将 CSV 文件中的数据插入到 MongoDB 数据库中,并解决可能遇到的问题。
没有搜到相关的沙龙