Python中如何使用pymongo将查询结果转换成CSV？

import csv
from pymongo import MongoClient

# 连接MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client['your_database']
collection = db['your_collection']

# 执行查询
cursor = collection.find({})  # 这里可以添加查询条件，比如{"status": "active"}

# 指定CSV文件名
csv_file = 'output.csv'

# 获取所有文档，提取字段名（使用第一个文档的键）
all_docs = list(cursor)
if all_docs:
    # 获取所有可能的字段名（合并所有文档的键）
    fieldnames = set()
    for doc in all_docs:
        fieldnames.update(doc.keys())
    
    # 写入CSV
    with open(csv_file, 'w', newline='', encoding='utf-8') as file:
        writer = csv.DictWriter(file, fieldnames=sorted(fieldnames))
        writer.writeheader()
        
        for doc in all_docs:
            # 处理嵌套文档（这里简单转换为字符串，复杂情况需要递归处理）
            row = {}
            for key in fieldnames:
                value = doc.get(key)
                if isinstance(value, (dict, list)):
                    row[key] = str(value)  # 复杂类型转为字符串
                else:
                    row[key] = value
            writer.writerow(row)
    
    print(f"数据已导出到 {csv_file}")
else:
    print("没有找到数据")

这个代码做了几件事：先连接MongoDB并执行查询，然后自动提取所有文档中的字段名作为CSV表头。处理数据时会把字典或列表这类嵌套结构转成字符串，避免CSV格式问题。如果你需要处理更复杂的嵌套数据，可能得写个递归函数来展平结构。

简单说就是查数据、定表头、处理嵌套、写文件。