MongoDB批量上传代码

Question

以下上传方法应该批量上传到给定的 MongoDB 集合。它无一例外地成功运行，但数据未反映在数据库中。不确定缺少什么？ @丹尼尔罗斯曼

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()

Answer 1

返回的BulkWriteResult 结果表明数据已正确上传到Mongo Db。数据是否上传到正确的数据库和集合？

MongoDB批量上传代码

MongoDB bulk upload code

mongodb

python-2.7

pymongo

bulkinsert