mongo-aggregation 1.0.3

Python MongoDB aggregation ORM

mongo_aggregation

Python MongoDB Aggregation ORM class.

Installation

pip install mongo_aggregation

Usage examples

import pymongo
from datetime import datetime
from dateutil.relativedelta import relativedelta
from mongo_aggregation import MongoAggregation

# Usual pymongo connection
client = pymongo.MongoClient('mongodb://localhost:27017/test')
db = client.get_database()
today = datetime.now()
yesterday = today - relativedelta(days=1)

# Compose the pipeline
pipeline = MongoAggregation(collection=db.action)
pipeline.match(
    {'date': {'$gte': yesterday, '$lt': today}},
    completed=True,
    _cls={'$in': [
        'Action.Order', 'Action.StorageIncome', 'Action.StorageCancellation', 'Action.StorageMovementOutcome'
    ]},
).smart_project(
    'transactions.amount,_cls', '_id'
).append([
    {'$project': {
        '_cls': 1,
        'date': 1,
        'transactions.amount': 1,
        'transactions.cashbox': 1,
    }},
]).project(
    {'transactions.amount': 1, 'transactions.cashbox': 1}, _cls=1, date=1
).project(
    transactions=1, _cls=1, date=1
)
# Run it
cursor = pipeline.aggregate()

# Iterate over result
for doc in cursor:
    print(doc)
    break

Methods description

• $replaceRoot

pipeline.replace_root('doctor')
# {'$replaceRoot': {'newRoot': '$doctor'}}

Response as list

By default aggregate returns cursor. If you want it to return a list of documents use as_list argument:

data = pipeline.aggregate(as_list=True)

Patterns module

Provides operators and some other patterns in python functions way.

Imports:

from mongo_aggregation.patterns import regex

• $and

and_({'a': True}, b=True, c=True)
# {'$and': [{'a': True}, {'b': True}, {'c': True}]}

• $or

or_({'a': True}, b=True, c=True)
# {'$or': [{'a': True}, {'b': True}, {'c': True}]}

• $regex

regex('name', i=True)
# {'$regex': 'name', '$options': 'i'}

Aggregation patterns module

Provides aggregation operators and some other patterns in python functions way.

Imports:

from mongo_aggregation.aggr_patterns import merge_objects

• $mergeObjects

merge_objects('$doctor', first_name='John', last_name='Doe')
# {'$mergeObjects': ['$doctor', {'first_name': 'John', 'last_name': 'Doe'}]}

Changelog

1.0.3 (2020-09-01)

• .sort now supports -email sorting format (direction and field name by string).
• Added .replace_root method.
• Added or_ and and_ logical operators. _and is deprecated now.
• Added regex operator pattern.
• Added merge_objects aggregation operator (./aggr_patterns).

1.0.2 (2020-09-01)

• Added $addFields and $set stages.
• Added $filter operator.