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

Question

我有一个芹菜任务，大约需要6个小时。在它的末尾，Django (或者可能是Celery)引发了一个异常"MySQL服务器已经消失了“。

在做了一些阅读之后，这似乎是一个长任务的已知问题。我不(认为我有)控制pinging或其他中途任务；但异常是在耗时的调用结束后引发的(但仍在任务函数内)。

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

(我已经用相同的RDS“本地”运行了这个任务，没有问题，但我在MySQL实例上运行时得到了它。)

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将无法工作。

伊恩