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)