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

Question

问题描述

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

自己尝试过哪些方法

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