如何触发mongodb函数复制到mysql

# 导入所需的库和驱动程序
import pymongo
import mysql.connector

# 连接到 MongoDB
mongo_client = pymongo.MongoClient("mongodb://localhost:27017")
mongo_db = mongo_client["your_mongodb_database"]
mongo_collection = mongo_db["your_mongodb_collection"]

# 连接到 MySQL
mysql_connection = mysql.connector.connect(
    host="localhost",
    user="your_mysql_username",
    password="your_mysql_password",
    database="your_mysql_database"
)
mysql_cursor = mysql_connection.cursor()

# 创建 MongoDB 函数
mongo_function = [
    {"$match": {"field": "value"}},
    {"$project": {"field1": 1, "field2": 1}},
    {"$out": "temp_collection"}
]

# 触发 MongoDB 函数
result = mongo_collection.aggregate(mongo_function)

# 将数据插入到 MySQL
for doc in result:
    sql = "INSERT INTO your_mysql_table (field1, field2) VALUES (%s, %s)"
    values = (doc["field1"], doc["field2"])
    mysql_cursor.execute(sql, values)

# 提交事务并关闭连接
mysql_connection.commit()
mysql_cursor.close()
mysql_connection.close()