求python多进程操作mongodb数据上锁的方法

  • 一个python脚本需查询出两个表各一条数据进行操作,python脚本为a.py;mongodb集合为collection1,collection2。为防止多进程时,两个进程取到重复数据求数据上锁的方案

               collection1数据示例:                                          collection2数据示例:
                                name1      status1                                                 name2      status2
                                  c1_1           0                                                     c2_1          0
                                  c1_2           0                                                     c2_2          0
                                  c1_3           0                                                     c2_3          0
    
  • 流程:a.py从collection1去一条符合条件的数据然后再取一条collection2中符合条件的数据进行后续处理

  • 希望完成目标:多进程为防止两个进程取到重复数据,如何对数据进行上锁,希望能直接在mongo中解决

多进程可以用threading.Lock()对线程加锁处理就行