You can deal with this by inspecting the errors produced with BulkWriteError. This is actually an “object” which has several properties. The interesting parts are in details: import pymongo from bson.json_util import dumps from pymongo import MongoClient client = MongoClient() db = client.test collection = db.duptest docs = [{ ‘_id’: 1 }, { ‘_id’: 1 … Read more
Well, the best way to solve this is to store the minutes separately as well. But you can get around this with the aggregation framework, although that is not going to be very fast: db.so.aggregate( [ { $project: { loc: 1, vid: 1, datetime_recorded: 1, minutes: { $add: [ { $multiply: [ { $hour: ‘$datetime_recorded’ … Read more
You don’t need to use to retrieve the document first just use the .update method with the $push operator. def update_tags(ref, new_tag): coll.update({‘ref’: ref}, {‘$push’: {‘tags’: new_tag}}) Since update is deprecated you should use the find_one_and_update or the update_one method if you are using pymongo 2.9 or newer
You don’t need to use to retrieve the document first just use the .update method with the $push operator. def update_tags(ref, new_tag): coll.update({‘ref’: ref}, {‘$push’: {‘tags’: new_tag}}) Since update is deprecated you should use the find_one_and_update or the update_one method if you are using pymongo 2.9 or newer
@Joni is correct, you need to use datetime. from datetime import datetime from pymongo import Connection # i have updated and included the complete code client = Connection(‘localhost’, 27017) db = client[‘database’] # your database name inoshare = db[‘inoshare’] # convert your date string to datetime object start = datetime(2014, 9, 24, 7, 51, 04) … Read more
Modern releases of pymongo ( greater than 3.x ) wrap bulk operations in a consistent interface that downgrades where the server release does not support bulk operations. This is now consistent in MongoDB officially supported drivers. So the preferred method for coding is to use bulk_write() instead, where you use an UpdateOne other other appropriate … Read more
You seem to be missing some concepts here so I’ll basically answer as a “guide” to what you should be doing instead. So “authentication’ is not really something you do “after” connection, but rather you need to be “looking in the right place” when you actually attempt to authenticate. We can start this by essentially … Read more
You just need to store an instance of datetime.datetime. Inserting from the python shell: >>> c.test.test.insert({‘date’: datetime.datetime.utcnow()}) ObjectId(‘4e8b388367d5bd2de0000000′) >>> c.test.test.find_one() {u’date’: datetime.datetime(2011, 10, 4, 16, 46, 59, 786000), u’_id’: ObjectId(‘4e8b388367d5bd2de0000000’)} Querying in the mongo shell: > db.test.findOne() { “_id” : ObjectId(“4e8b388367d5bd2de0000000”), “date” : ISODate(“2011-10-04T16:46:59.786Z”) }
.sort(), in pymongo, takes key and direction as parameters. So if you want to sort by, let’s say, id then you should .sort(“_id”, 1) For multiple fields: .sort([(“field1”, pymongo.ASCENDING), (“field2”, pymongo.DESCENDING)])
Here you have the very quickest way. Using the insert_many method from pymongo 3 and ‘records’ parameter of to_dict method. db.collection.insert_many(df.to_dict(‘records’))