0
sqlCur.execute('SELECT TOP 10 '+fld+cc.joins+cc.where,custo)
tub=sqlCur.fetchall()
從上面的查詢中,我從SQL Server獲取數據到Python元組。我將這些數據轉換爲OrderedDict()
列表,然後使用pymongo
中的insert_many
將數據推送到mongodb。
要使用mongo列映射SQL列,我有一個OrderedDict(cols)
,它的用法如下。python:從字符串中刪除引號以執行命令或映射字符串值到密鑰
sqlCol=list(cols.keys())
mongoCol=list(cols.values())
insArray=[]
for b in tub:
doc=OrderedDict()
lst=['b.'+x for x in sqlCol]
for v in range(len(mongoCol)):
ii=lst[v]
doc[ll[v]]=lst[v]
insArray.append(doc)
但是,結果我看到了列名的代替值因爲列表lst
是具有列名爲字符串,但它需要與mongoColumns映射不報價 。
我該如何做到這一點或有沒有更好的方法來處理這個問題?
順便說一句,我使用的的Python 3.6
你能分享其中的一個sqlCur返回 – GThamizh
@GThamizh樣本數據:我知道了有一個像[( 'GoDad',73399, 'C'),('GoDad元組的列表',73483,'我')] –