如何解决Celery Workers并没有全部用Django将事务写入数据库
我将Django与Celery结合使用。我的芹菜工作者使用Django及其模型执行数据库事务。我的工作人员中有几个任务,每个任务多次对数据库进行读/写调用。我正在运行6个工人,每个工人并发10个线程。
我面临的问题是它可以正确完成数据库中的所有read
个事务,但是却错过了对数据库进行某些write
个事务的机会。并且它遗漏的write
个事务是一致的。尽管永远不会引发任何异常,但它总是无法在同一时间写入数据库。
我尝试将time.sleep(5)
放在事务之间来给它时间,但没有帮助。我开始认为这是某种连接池问题。
其他人对此有任何想法或经历过同一问题吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。