個人博客地址：Python3連接MongoDB并寫入數據 | 一張假鈔的真實世界

安裝PyMongo

$ pip3 install pymongo
Successfully installed pymongo-3.7.2

連接MongoDB并且批量插入操作

#!/usr/bin/python3import mysql.connector
import gzip
import json
from pymongo import MongoClient
from datetime import datetimeopsDateTime = datetime.now().isoformat(timespec='seconds')config = {'user': 'roHive','password': 'hive@bigdata!23','host': '172.16.72.22','database': 'azkaban3','raise_on_warnings': True,'charset': 'latin1'
}cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()
query = ("SELECT trigger_id, data FROM azkaban3.triggers")
cursor.execute(query)scheduledList = []
for (triggerId, triggerData) in cursor:triggerJson = json.loads(gzip.decompress(bytes(triggerData, encoding='latin1')))actionJson = triggerJson['actions'][0]['actionJson']projectName = actionJson['projectName']flowName = actionJson['flowName']scheduledFlow = {'opsDateTime': opsDateTime, 'projectName': projectName, 'flowName': flowName}scheduledList.append(scheduledFlow)cursor.close()
cnx.close()mongoClient = MongoClient('mongodb://172.16.72.213:27017/')
opsDb = mongoClient.ops
azScheduled = opsDb.azScheduledFlow
azScheduled.insert_many(scheduledList)