celery在prefork模式下应当如何处理数据库链接（psycopg2）?

20913048

发布于
2018-07-21

问题描述

celery使用prefork模式（4进程），和psycopg2搭配使用，每次启动可以成功完成一个celery任务，在进行第二个任务时就会出现InterfaceError: cursor already closed，请问应该如何处理。

自己尝试过哪些方法

在psycopg2文档中看到，这个库不应在forked process中使用。所以有点疑惑，是因为celery的prefork模式所以导致了问题的出现吗？那么我应当如何处理比较合适？是否需要在每个celery任务中新建一个数据库链接，做完了再关掉？

celery postgresql

阅读 2.6k

撰写回答

你尚未登录，登录后可以

和开发者交流问题的细节
关注并接收问题和回答的更新提醒
参与内容的编辑和改进，让解决方法与时俱进

推荐问题

如何用sql语句计算出变化的share?
数据文件q4.csv: {代码...} 数据文件q3.csv: {代码...} 准备工作: {代码...} 使用full outer join: {代码...} 我希望得到的结果： {代码...} 我可以用vba在excel中完成，也可以用python实现，但是可否用纯粹的postgres语句来实现？
2 回答902 阅读✓ 已解决
为了防止过多索引拖慢数据库，数据库动态创建索引，隔几天就换一套索引，会有什么问题？
我打算用 PostgreSQL。不过我感觉不同数据库可能大同小异，所以问题没限定 PostgreSQL。网上有推荐索引最好不要超过六个的。但是我想给用 jsonb 实现的 EAV 系统加很多索引。所以就想到这么一个方法。问过 DeepSeek 了，我理解它说除非是索引删除重建过于频繁，一般没什么大问题。
2 回答1.7k 阅读
用 PostgreSQL 的 jsonb 的 @> 同时查询多个键值对是否是合法的？
下面这条语句返回的是 true： {代码...} 我没在官方文档里看到类似的用法，不太敢用，我怕是我卡了一个 BUG。我问了 DeepSeek，它说文档一般不会介绍那么细，不太敢信。
1 回答1.4k 阅读
mybatis-plus参数错误？
{代码...} 只设置了两个参数但是显示三个具体如下 {代码...} {代码...} 语句中用到了jsonpath 如何避免 MyBatis 将 JSONPath 中的 ? 误认为占位符
3 回答880 阅读
PostgreSQL 中 template0 和 template1 需要执行 VACUUM FREEZE 吗？
意外发现这两个数据库的 age 很高，用这个看的：SELECT age(datfrozenxid) FROM pg_database;最开始所有数据库的 age 都是一样的。更清晰的：SELECT datname, age(datfrozenxid) FROM pg_database WHERE datname IN ('template0', 'template1');发现所有数据库的 age 都一样并且很高我就全都手动 vacuum 了一遍。其中 te...
1 回答575 阅读
如何将 Postgresql SQL 转义为 Mysql SQL？
Postgresql 转义 Mysql SQL有什么快捷方式？
1 回答429 阅读✓ 已解决

相似问题

PHP pdo链接postgresql数据库，where条件中使用json报错
2 回答4.7k 阅读✓ 已解决
mysql/PG等数据库中库、表、字段数、行数等应当控制在什么范围内，为什么?
2 回答4.4k 阅读
falsk celery task 数据库查询
1 回答3.8k 阅读
Psycopg2 在 postgres 数据库中插入 python 字典
2 回答1.5k 阅读✓ 已解决
celery+rabbitmq ，为什么不是在celery队列里面存
1 回答4.4k 阅读

找不到问题？创建新问题

celery在prefork模式下应当如何处理数据库链接（psycopg2）?

问题描述

自己尝试过哪些方法

你尚未登录，登录后可以

如何用sql语句计算出变化的share?

为了防止过多索引拖慢数据库，数据库动态创建索引，隔几天就换一套索引，会有什么问题？

用 PostgreSQL 的 jsonb 的 @> 同时查询多个键值对是否是合法的？

mybatis-plus参数错误？

PostgreSQL 中 template0 和 template1 需要执行 VACUUM FREEZE 吗？

如何将 Postgresql SQL 转义为 Mysql SQL？