1

我将Django与Celery一起使用以执行定期任务，并将Raven用作哨兵客户端。

到目前为止，我已经设法用 celery beat 运行了几个应用程序，并且一切正常。

出于某种原因，在我正在开发的一个最近的应用程序中，当我将根记录器设置为使用“哨兵”处理程序时，周期性任务没有运行。

当将根记录器设置为仅使用“控制台”处理程序时，它确实有效。

我无法理解导致此问题的原因。

这是我的日志记录：

LOGGING = {
'version': 1,
'disable_existing_loggers': False,
'root': {
    'level': os.environ.get('LOG_LEVEL','INFO'),
    'handlers': ['console'],
},
'filters': {
    'require_debug_false': {
        '()': 'django.utils.log.RequireDebugFalse'
    }
},
'handlers': {
    'mail_admins': {
        'level': 'ERROR',
        'filters': ['require_debug_false'],
        'class': 'django.utils.log.AdminEmailHandler'
    },
    'sentry': {
        'level': 'WARNING',
        'class': 'raven.contrib.django.raven_compat.handlers.SentryHandler',
    },
    'console': {
        'level': 'DEBUG',
        'class': 'logging.StreamHandler',
    },
},
'loggers': {
    'django.request': {
        'handlers': ['mail_admins'],
        'level': 'ERROR',
        'propagate': True,
    },
    'raven': {
        'level': 'WARNING',
        'handlers': ['console','sentry'],
        'propagate': True,
    },
    'celery': {
        'handlers': ['console'],
        'level': 'DEBUG',
    },
}

}

以及控制根记录器处理程序的 env var：

    ENABLE_SENTRY = os.environ.get('ENABLE_SENTRY', 'FALSE') == 'TRUE'
    if (ENABLE_SENTRY):
        LOGGING['root']['handlers'] = ['console','sentry']

注意：似乎根记录器在更改后不会登录到控制台

这就是我运行 celery beat 和 worker 的方式：

python manage.py celery worker -E -B --maxtasksperchild=1000 --concurrency=10 --loglevel=DEBUG -Ofair

这是我正在使用的软件包的一部分：

celery==3.1.17 django-celery==3.1.16 raven==5.0.0 Django==1.8.7

这是我的 celery.py 文件：

"""
This module will hold celery configuration
"""
from __future__ import absolute_import
from django.conf import settings
import os
from celery import Celery

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE',     'ltg_backend_app.settings')

# init the celery app
app = Celery('ltg_backend_app')

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

任何帮助将不胜感激！

4

1 回答 1

1

您是否配置 raven 来捕获与 Celery 合作所需的必要信号？这是我配置 Celery 应用程序的方式：

import celery
from django.conf import settings

import raven
from raven.contrib.celery import register_signal, register_logger_signal


class Celery(celery.Celery):
    def on_configure(self):
        #
        # https://docs.sentry.io/clients/python/integrations/celery/
        #
        if 'dsn' in settings.RAVEN_CONFIG and settings.RAVEN_CONFIG['dsn']:
            client = raven.Client(settings.RAVEN_CONFIG['dsn'])
        else:
            client = raven.Client()  # should do nothing

        # register a custom filter to filter out duplicate logs
        register_logger_signal(client)

        # hook into the Celery error handler
        register_signal(client)

app = Celery('foobar')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

有关更多配置选项和详细信息，请参见此处：https ://docs.sentry.io/clients/python/integrations/celery/

于 2016-11-12T14:31:21.453 回答