长芹菜任务导致 MySQL Django 超时 - 选项？

Question

我有一个 celery 任务，大约需要 6 个小时。最后，Django（或可能是 Celery）引发异常 "MySQL server has gone away"。

经过一些阅读，这似乎是长任务的一个已知问题。我不（认为我有）控制 ping 或其他中间任务；但是在需要时间的调用完成后引发异常（但仍在任务函数内）。

我可以在函数内进行调用以重新建立连接吗？

（我有运行这个任务 "locally" 使用相同的 RDS MySQL DB 并且没有问题，但是当运行在AWS 实例。）

Answer 1

最终发现似乎有效的方法：

from django.db import close_old_connections
import time

def check_and_retry_django_db_connection():
    close_old_connections()

    db_conn = False
    while not db_conn:
        try:
            connection.ensure_connection()
            db_conn = True
        except OperationalError:
            print('Database unavailable, waiting 1 second...')
            time.sleep(1)

    print('Database available')

关键是 close_old_connections 调用 - ensure_connection 否则将不起作用。

伊恩

长芹菜任务导致 MySQL Django 超时 - 选项？

Long celery task causes MySQL timeout in Django - options?

python

django

celery