能否实现Excel与MongoDB的双向同步？含实时/一键同步需求

代码无反应的核心原因 #

你用的MotorClient是异步MongoDB驱动，但代码里直接调用collection.drop()、insert_many()、find()这些异步方法却没有用await关键字，也没启动异步事件循环，导致这些操作根本没实际执行，所以运行后没任何反应。

另外你的代码逻辑也存在问题：先删除Mongo里的数据，把Excel内容插进去，再把Mongo数据写回Excel，等于做了无意义的循环，完全达不到双向同步的效果。

一键同步方案（修正版代码） #

Excel→MongoDB 一键同步 #

改用同步的pymongo驱动（更适合新手），代码如下：

import pandas as pd
from pymongo import MongoClient

# 连接MongoDB
client = MongoClient('localhost', 27017)
db = client['Exceldb']
collection = db['excel']

# 读取CSV文件
excel_file = "Employee.csv"
df = pd.read_csv(excel_file)

# 清空集合并插入新数据
collection.delete_many({})  # 替代drop()，避免误删整个集合
collection.insert_many(df.to_dict('records'))

print("数据同步完成！")
client.close()

MongoDB→Excel 一键同步 #

如果需要把Mongo数据导出到Excel，用这段代码：

import pandas as pd
from pymongo import MongoClient

client = MongoClient('localhost', 27017)
db = client['Exceldb']
collection = db['excel']

# 从Mongo读取数据，排除自动生成的_id字段
data = list(collection.find({}, {'_id': False}))
df = pd.DataFrame(data)
df.to_csv("Employee.csv", index=False)

print("数据导出完成！")
client.close()

实时同步实现思路 #

实时同步需要监听文件或数据库的变化，自动触发同步：

• 监听Excel文件变化：用watchdog库检测CSV文件修改事件，触发同步到MongoDB
• 监听MongoDB变化：用MongoDB的Change Streams功能，当集合数据更新时写回Excel

文件监听同步示例（Excel→Mongo实时同步） #

import pandas as pd
from pymongo import MongoClient
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler

# 初始化Mongo连接
client = MongoClient('localhost', 27017)
db = client['Exceldb']
collection = db['excel']
excel_file = "Employee.csv"

class ExcelSyncHandler(FileSystemEventHandler):
    def on_modified(self, event):
        if event.src_path.endswith(excel_file):
            print("检测到文件修改，开始同步...")
            df = pd.read_csv(excel_file)
            collection.delete_many({})
            collection.insert_many(df.to_dict('records'))
            print("同步完成！")

if __name__ == "__main__":
    event_handler = ExcelSyncHandler()
    observer = Observer()
    observer.schedule(event_handler, path='.', recursive=False)
    observer.start()
    print("正在监听文件变化...按Ctrl+C退出")
    try:
        while True:
            pass
    except KeyboardInterrupt:
        observer.stop()
    observer.join()
    client.close()

先安装依赖：

pip install pandas pymongo watchdog

内容的提问来源于stack exchange，提问作者Lurker