공식 문서

Tutorial — PyMongo 4.3.3 documentation

pymongo

db_query = 'mongodb://{USER}:{PASSWORD}@{URL}:{PORT}'
myclient = MongoClient(db_query)
mydb = myclient[DATABASES["SIAResearch"]["CLIENT"]]
mycol = mydb[table]

find

find() 메서드의 두 번째 매개변수는 컬럼 출력 여부 결정 객체임.

※ 값이 0인 컬럼 경우 : 출력 X

※ 값이 1인 컬럼 경우 : 출력 O

mycol.find({where절}, {select절})

mycol.find({"status": "running"}, {"status": 1, "task_id": 1})

json_util

mongoDB 에서는 json util 기능 제공

from bson.json_util import loads, dumps

data = [{'_id': ObjectId('64181f20d907e6b81f0cac91'), 'task_id': '235a2754b1b2', 'status': 'running'}, {'_id': ObjectId('64181f22d907e6b81f0cac92'), 'task_id': '56998f812d4d', 'status': 'running'}, {'_id': ObjectId('64193a8743952be30de677ab'), 'task_id': 'c047c8f2073c', 'status': 'running'}]

>>> jsonStr = dumps(data)
[{"_id": {"$oid": "64181f20d907e6b81f0cac91"}, "task_id": "235a2754b1b2", "status": "running"}, {"_id": {"$oid": "64181f22d907e6b81f0cac92"}, "task_id": "56998f812d4d", "status": "running"}, {"_id": {"$oid": "64193a8743952be30de677ab"}, "task_id": "c047c8f2073c", "status": "running"}]