Python将SQL server 数据库导入到mongoDB数据库中
import pymssqlfrom 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 joinSEM_COMPUTER onV_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)
页:
[1]