python mongodb / mongo / mython mongo
pyMongo 사용
설치
pip install pyMongo
사용예제
from pymongo import MongoClient
from bson.son import SON
import datetime
uri = "mongodb://user:password@example.com:27017/default_db?authSource=admin"
client = MongoClient(uri)
db = client.mydatabase
pipeline = [
{ "$match": { "time": {
"$gte": datetime.datetime(2022, 8, 6),
"$lt": datetime.datetime(2022, 8, 7)
}}
},
{"$unwind": "$tags"},
{"$group": {"_id": "$tags", "count": {"$sum": 1}}},
{"$sort": SON([("count", -1), ("_id", -1)])}
]
# 출력 - list 이용하는 방법
import pprint
pprint.pprint(list(db.testcoll.aggregate(pipeline)))
# 출력 - cursor 를 이용하는 방법
cursor = db.testcoll.aggregate(pipeline)
for c in cursor:
print(c)
기타
Frequently Asked Questions — PyMongo 4.2.0 documentation
MongoClient()
는 thread-safe 하다.MongoClient()
는 connection pool 을 가지고 있다. 기본 값은 100 이다. parameter 로 조정가능
댓글 없음:
댓글 쓰기