Допустим, у нас есть две коллекции (таблицы):
- buy_orders
- sell_orders
Эти таблицы имеют одно и то же поле 'id_transaction',и мы хотим объединить эти таблицы в этом поле:
import pymongo
my_client = pymongo.MongoClient('mongodb://localhost:27017/')
my_db = my_client['Orders']
my_collection = my_db['buy_orders']
result = my_collection..aggregate([ {'$lookup' : {'from': sell_orders','localField': 'id_transaction','foreignField': 'id_transaction','as': 'results' }}])
Для печати результатов:
for item in result:
print(item)
Для получения дополнительных ссылок: Документы MongoDB и PyMongoDocs