Execute mongodb command on pymongo

Question

Hello : i have the following script on mongodb :

db.shipping.find({"dateCreated":{$type:"string"}}).forEach(
function(doc){
doc["dateCreated"]=new Date(doc["dateCreated"]);
db.shipping.save(doc);
})

I need to execute in pymongo

Its a simple function to parse strings to date and i want to add this task to apache airflow

Regards

It seems like you are doing an update here. Am I correct in assuming this? — Manvir
– Manvir, Commented Nov 13, 2020 at 19:59
yes , first i filter only the docs where date_created is string and then save the doc parsed — Matias Ordoñez
– Matias Ordoñez, Commented Nov 13, 2020 at 20:04
You can just do an update like so db.shipping.updateMany({'dateCreated': {'$type':"string"}}, {'$set': {"dateCreated": new Date('$dateCreated')}}) Also what error are you getting when you try to execute what you have using pymongo? — Manvir
– Manvir, Commented Nov 13, 2020 at 20:10

Belly Buster · Accepted Answer · 2020-11-13 20:45:54Z

1

The equivalent of your code in pymongo would be:

from pymongo import MongoClient
from dateutil.parser import parse

db = MongoClient()['mydatabase']

for doc in db.shipping.find({'dateCreated':{'$type':'string'}}):
    db.shipping.update_one({'_id': doc.get('_id')}, {'$set': { 'dateCreated': parse(doc.get('dateCreated'))}})

answered Nov 13, 2020 at 20:45

Belly Buster

8,9142 gold badges12 silver badges25 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Execute mongodb command on pymongo

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related