如何将mongo对象推送到Neo4j中

from pymongo import MongoClient
from neo4j import GraphDatabase

# 连接到MongoDB
mongo_client = MongoClient('mongodb://localhost:27017/')
mongo_db = mongo_client['your_mongo_db']
mongo_collection = mongo_db['your_mongo_collection']

# 查询Mongo对象数据
mongo_objects = mongo_collection.find({})

# 连接到Neo4j
neo4j_driver = GraphDatabase.driver('bolt://localhost:7687', auth=('neo4j', 'your_password'))

# 创建Neo4j事务
with neo4j_driver.session() as session:
    for mongo_object in mongo_objects:
        # 创建Neo4j节点
        session.run(
            'CREATE (node:MongoObject {id: $id, name: $name})',
            id=mongo_object['_id'],
            name=mongo_object['name']
        )

        # 创建关系（如果有关联）
        if 'related_objects' in mongo_object:
            for related_object_id in mongo_object['related_objects']:
                session.run(
                    'MATCH (source:MongoObject {id: $source_id}), (target:MongoObject {id: $target_id}) '
                    'CREATE (source)-[:RELATED_TO]->(target)',
                    source_id=mongo_object['_id'],
                    target_id=related_object_id
                )

# 关闭连接
neo4j_driver.close()
mongo_client.close()