Minimal POC of a Python-MongoDB Aggregation transpiler.
Now you can write your aggregation pipelines using native Python syntax, and PyMongoAgg will handle conversion by parsing the AST of your function.
Example:
def basic_func():
y = a
a = (a + b) / 2
b = sqrt(b * y)
t = t - (x * (y - a) ** 2)
x = x * 2
...
output_dict = transpile_function(basic_func)
print(output_dict)[{'$set': {'y': '$a'}},
{'$set': {'a': {'$divide': [{'$add': ['$a', '$b']}, 2]}}},
{'$set': {'b': {'$sqrt': [{'$multiply': ['$b', '$y']}]}}},
{'$set': {'t': {'$subtract': ['$t', {'$multiply': ['$x', {'$pow': [{'$subtract': ['$y', '$a']}, 2]}]}]}}},
{'$set': {'x': {'$multiply': ['$x', 2]}}}]It also supports boolean operations!
def bool_func(y, a, b, c):
y = 1
a = (y and 0) and 1
b = y or 0
c = not y
...[{'$set': {'y': 1}},
{'$set': {'a': {'$and': [{'$and': ['$y', 0]}, 1]}}},
{'$set': {'b': {'$or': ['$y', 0]}}},
{'$set': {'c': {'$not': ['$y']}}}]Changes since original Skunkworks presentation:
- Added support for builtins like
sqrt - Added support for boolean operations
- Added tests that run the transpiled functions and checks the result of running the functions against the result of executing the transpiled MongoDB aggregation.
To-do:
- Control flow
- Vector operations
- More aggregation operators