python - 如何使用 pandas 执行 mongodB $lookup 和 $unwind？

Question

我有一个数据框 df1 如下，

ID     email        status         ID2
10   [e-mail]   completed       12
11   [e-mail]   not_completed   10
12   [e-mail]   completed       11
13   [e-mail]   completed       12

如何使用 Pandas 执行以下 MongoDB 管道，

{ $lookup: { 'from': 'df1', 'localField': 'ID', 'foreignField': 'ID2', 'as': 'member' } }

然后，下一步就是放松，

{ $unwind: { path: '$member' } },

所需的输出看起来像这样。

ID2     email        status        member
10   [e-mail]   completed      [{ID: 11, email: '[e-mail]', status: 'not_completed'}]  
11   [e-mail]   not_completed  [{ID: 12, email: '[e-mail]', status: 'completed'}]
12   [e-mail]   completed      [{ID: 10, email: '[e-mail]', status: 'completed'}]
12   [e-mail]   completed      [{ID: 13, email: '[e-mail]', status: 'completed'}]       

标签： pythonpandasmongodbmongodb-querypymongo