Celery任务不会通过记录器重要消息向管理员发送电子邮件 - python

每次调用logger.critical，我的celery任务都不会向应用程序管理员发送电子邮件。

我正在构建Django应用程序。我项目的当前配置允许应用程序的管理员在每次创建logger.critical消息时都收到一封电子邮件。设置起来非常简单，我只是遵循了两个项目（celery和Django）的文档。出于某种原因（我不确定），在celery任务中运行的代码没有相同的行为，它不会在每次创建logger.critical消息时向应用程序管理员发送电子邮件。

芹菜实际上是否允许这样做？
我是否缺少某些配置？
有谁遇到这个问题并能够解决？

使用：

Django 1.11
芹菜4.3

谢谢你的帮助。

python大神给出的解决方案

如文档中所述，Celery会覆盖当前的日志记录配置以应用自己的日志记录，它还说您可以在Django设置中将CELERYD_HIJACK_ROOT_LOGGER设置为False来防止此行为，但没有充分记录的是，这不是真的目前正在工作。

我认为您有2种选择：

1.防止Celery使用setup_logging信号（确实）覆盖您的配置

打开celery.py文件并添加以下内容：

from celery.signals import setup_logging

@setup_logging.connect
def config_loggers(*args, **kwags):
    pass

之后，您的文件应大致如下所示：

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery.signals import setup_logging

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'myproject.settings')

app = Celery('myproject')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

@setup_logging.connect
def config_loggers(*args, **kwags):
    pass

但是，除非您有充分的理由，否则我将避免使用此选项，因为这样一来，您将丢失Celery处理的默认任务日志记录，这非常好。

2.使用特定的记录器

您可以在Django LOGGING配置中定义自定义记录器，并在任务中使用它，例如：

Django设定：

LOGGING = {
    # ... other configs ...
    'handlers': {
        'my_email_handler': {
            # ... handler configuration ...
        },
    },
    'loggers': {
        # ... other loggers ...
        'my_custom_logger': {
            'handlers': ['my_email_handler'],
            'level': 'CRITICAL',
            'propagate': True,
        },
    },
}

任务：

import logging

logger = logging.getLogger('my_custom_logger')

@shared_task
def log():
    logger.critical('Something bad happened!')

我认为这对您来说是最好的方法，因为据我了解，您需要手动记录消息，这使您可以继续使用Celery记录系统。

用大写字母拆分字符串，但忽略AAA Python Regex - python

我的正则表达式：vendor = "MyNameIsJoe. I'mWorkerInAAAinc." ven = re.split(r'(?<=[a-z])[A-Z]|[A-Z](?=[a-z])', vendor) 以大写字母分割字符串，例如：'我的名字是乔。 I'mWorkerInAAAinc”变成…

Python:同时在for循环中添加到列表列表 - python

我想用for循环外的0索引值创建一个新列表，然后使用for循环添加到相同的列表。我的玩具示例是：import random data = ['t1', 't2', 't3'] masterlist = [['col1', 'animal1', 'an…

在Python中迭代OrderedDict - python

我有以下OrderedDict：OrderedDict([('r', 1), ('s', 1), ('a', 1), ('n', 1), ('y', 1)]) 实际上，这表示单词中字母的出现频率。第一步-我将使用最后两个元素来创建一个这样的联合元组； pair…

如何在Matplotlib条形图后面绘制网格线 - python

x = ['01-02', '02-02', '03-02', '04-02', '05-02'] y = [2, 2, 3, 7, 2] fig, ax = plt.subplots(1, 1) ax.bar(range(len(y)), y, width=…

PyCharm中Django的文档字符串中未解决的引用 - python

我在Django的专案中使用Google Style Python Docstrings like in this Example。当我创建一个类并在文档字符串中使用属性符号时，Pycharm总是说-“未解决的引用”。class Post(models.Model): """ Class for posts. Attribute…