Celery + SQLAlchemy：DatabaseError：（DatabaseError）SSL错误：解密失败或记录MAC有误

Question

3

当在启用SSL的postgresql数据库上使用多个celery工作进程时，标题中的错误有时会触发。我使用的是flask + SQLAlchemy配置。

- Ben G

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Ben G · Accepted Answer

如此提到：https://github.com/celery/celery/issues/634 。django-celery插件的解决方案是在任务开始时简单地处理所有db连接。

在flask + SQLAlchemy配置中，我采取了这种方式，它对我有用：

from celery.signals import task_prerun

@task_prerun.connect
def on_task_init(*args, **kwargs):
    engine.dispose()

如果您不知道什么是“引擎”以及如何获取它，请参见此处：http://flask.pocoo.org/docs/patterns/sqlalchemy/