, mongo_ip, mongo_db):
self.mysqlUtil = MySQLUtil(mysql_ip, mysql_user, mysql_passwd, mysql_db...)
self.mongoUtil = MongoDBUtil(mongo_ip, mongo_db)
def mysqlToMongo(self, mysql_database...in zip(table_field, row):
dict[key[0]] = value
documents.append(dict)...mysql_db = "127.0.0.1", "test"
mongo_ip, mongo_db = "127.0.0.1", "xl01"
## 数据库同步对象
syncsql...= SyncMysqlMongo(mysql_ip, mysql_user, mysql_passwd, mysql_db, mongo_ip, mongo_db)
## 将一张MySQL表数据全量插入到