好的，我找到了一个解决方案。我设置了一个不同的日志，它记录了celery ，还检查了任何类似于连接丢失的警告或错误消息。代码如下：

# Project/celery.py
from __future__ import absolute_import
import os
from celery import Celery
import logging
import celery
import logstash
from django.conf import settings
from utils.email_alert import send_shutting_down_email
import os

os.environ.setdefault('DJANGO_SETTINGS_MODULE','Project.settings')
app = Celery('Project')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

class LogstashEmailHandler(logging.handlers.SocketHandler):
    def __init__(self, host, port, sender):
        super().__init__(host, port)
        self.sender = sender
    def emit(self, record):
        try:
            # Send the log message to Logstash
            logging.handlers.SocketHandler.emit(self, record)
        except Exception:
            self.handleError(record)
        if 'consumer: Connection to broker lost.' in record.message:
            send_shutting_down_email(record.message, 'Connection to broker lost.')
            os.system("ps auxww | grep celery | grep -v 'grep' | awk '{print $2}' | xargs kill -HUP && celery -A project worker -l info")
        elif 'Trying again in 2.00 seconds... (1/100)' in record.message:
            send_shutting_down_email(record.message, 'Trying to connect to broker url.')


from celery.signals import after_setup_task_logger
from celery.signals import after_setup_logger

@after_setup_task_logger.connect
@after_setup_logger.connect
def initialize_logstash(logger=None,loglevel=logging.INFO, **kwargs):
    handler = logstash.TCPLogstashHandler(settings.LOGSTASH_HOST, 5960,tags=['celery-' + settings.ENV_NAME],message_type='celery',version=1)
    handler.setLevel(loglevel)
    logger.addHandler(handler)
    customhandler = LogstashEmailHandler(host= settings.LOGSTASH_HOST, port= 5960, sender = kwargs.get('sender'))
    logger.addHandler(customhandler)
    return logger

这里send_shutting_down_email是一个函数，它将消息和主题作为参数并发送它。

# send_shutting_down_email
from django.core.mail import EmailMultiAlternatives
from django.template.loader import render_to_string
from django.utils.html import strip_tags
from project.settings import ENV_NAME

def send_shutting_down_email(msg, sub):
    subject = f'Project Celery {ENV_NAME} message: {sub}'
    html_content = render_to_string('mails/celery.html', {'msg':msg,'env':ENV_NAME})
    text_content = strip_tags(html_content)
    mail_to_send = EmailMultiAlternatives(
        subject,
        text_content,
        "alert@dummyemail.com",
        ['email@dummyemail.com']
    )
    mail_to_send.attach_alternative(html_content, "text/html")
    mail_to_send.send()

我相信有更好的方法可以做到这一点。如果有，请让我知道！