问题描述
我将Django与Celery结合使用。我的芹菜工作者使用Django及其模型执行数据库事务。我的工作人员中有几个任务,每个任务多次对数据库进行读/写调用。我正在运行6个工人,每个工人并发10个线程。
我面临的问题是它可以正确完成数据库中的所有read
个事务,但是却错过了对数据库进行某些write
个事务的机会。并且它遗漏的write
个事务是一致的。尽管永远不会引发任何异常,但它总是无法在同一时间写入数据库。
我尝试将time.sleep(5)
放在事务之间来给它时间,但没有帮助。我开始认为这是某种连接池问题。
其他人对此有任何想法或经历过同一问题吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)