python

import pymssql
from pymongo import MongoClient
conn = pymssql.connect(‘IP‘, ‘用戶名‘, ‘密碼‘, ‘數據庫‘)
cursor = conn.cursor(as_dict = True)
cursor.execute(" select top 1000 V_ALERTS.SOURCE,V_ALERTS.FILEPATH,V_ALERTS.ALERTDATETIME,V_ALERTS.ALERTENDDATETIME,ALERTMSG.ALERT ,SEM_COMPUTER.COMPUTER_NAME,SEM_COMPUTER.CURRENT_LOGIN_USER from (V_ALERTS left join ALERTMSG on V_ALERTS.ALERT_IDX= ALERTMSG.ALERT_IDX) left join SEM_COMPUTER on V_ALERTS.COMPUTER_IDX = SEM_COMPUTER.COMPUTER_ID")
client = MongoClient(‘localhost‘, 27017)
db = client.SEPM
collection = db.sepm
for row in cursor:
print(row)
collection.insert_one(row)
for item in collection.find():
print(item)

Python將SQL server 數據庫導入到mongoDB數據庫中