一个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中符合条件的数据进行后续处理
多进程可以用threading.Lock()对线程加锁处理就行