0
以下上傳方法應該批量上傳到給定的MongoDB集合。它成功運行,但數據不會反映在數據庫中。不確定缺少什麼? @DanielRosemanMongoDB批量上傳代碼
from pymongo import MongoClient
from pymongo.database import Database
from pymongo.collection import Collection
def upload(host, port, db_str, collection_str, src_dir):
# prepare connection to DB
client = MongoClient(host, port)
db = Database(client, db_str)
collection = Collection(db, collection_str)
# prepare bulk object
bulk = collection.initialize_ordered_bulk_op()
# iterate overall all data files and insert
for datafile in datafiles(src_dir):
try:
data = json.load(open(datafile))
bulk.insert(data)
except ValueError:
print "Upload failed for %s" % (datafile)
continue
bulk.execute()
你確認'json.load(open(datafile))'是否返回你期望它返回的對象嗎? – Philipp
bulk.execute()返回的BulkWriteResult()對象是什麼樣的?有沒有非零的條目? – Jaco
@ Philipp是的。對象很好。 – comiventor