So übertragen Sie Daten mithilfe von MySQL stapelweise an Mongo

import pymongo 
import mysql.connector

Mit MySQL-Datenbank verbinden

mysql_conn = mysql.connector.connect( host="localhost", user="yourusername", password="yourpassword", database="yourdatabase" )

Mit MongoDB-Datenbank verbinden

mongo_client = pymongo.MongoClient("mongodb://localhost:27017/") mongo_db = mongo_client["mydatabase"] mongo_collection = mongo_db["mycollection"]

#🎜 🎜 #at Erstellen Sie einen Index für eine bestimmte Sammlung in MongoDB. #Erstellen Sie ein Cursorobjekt und rufen Sie Daten aus einer MySQL-Datenbank ab Verarbeiten Sie jede Zeile.

mongo_collection.create_index([("myfield", pymongo.ASCENDING)])

bulk_data = [] bulk_count = 0

Verarbeiten Sie die verbleibenden Zeilen, wenn etwas verarbeitet werden muss.

mysql_cursor = mysql_conn.cursor() mysql_cursor.execute("SELECT * FROM mytable")

Schließen Sie die MySQL-Verbindung.

mysql_conn.close()

for row in mysql_cursor: # 将一条记录转换成你的MongoDB文档，然后将其添加到缓冲列表。 
doc = { "myfield": row[0], "anotherfield": row[1], "yetanotherfield": row[2] } bulk_data.append(doc) bulk_count += 1

Das obige ist der detaillierte Inhalt vonSo übertragen Sie Daten mithilfe von MySQL stapelweise an Mongo. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!