我使用Django和Celery来执行定期任务,并将Raven用作哨兵客户端。
到目前为止,我已经成功地用芹菜节拍运行了几个应用程序,并且都运行得很好。
出于某种原因,在我正在开发的最近的一个应用程序中,当我将根记录器设置为使用'sentry'hander时,周期性任务不会运行。
当将根记录器设置为仅使用"控制台"处理程序时,它确实有效。
我无法理解是什么导致了这个问题。
这是我的日志记录格言:
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']
注意:在更改之后,根记录器似乎不会登录到控制台
这就是我如何运行芹菜节拍和工人:
python manage.py芹菜工人-E-B--maxtasksperchild=1000--并发=10-loglevel=DEBUG-Ofair
这是我正在使用的软件包的一部分:
芹菜==3.1.17姜戈芹菜==3.1.16乌鸦==5.0.0姜戈==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)
如有任何帮助,我们将不胜感激!
您是否配置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/