zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: base 完整的task on_failure日志记录和邮件推送

This commit is contained in:
caoqianming 2024-04-29 21:45:35 +08:00
parent 3a0d229ec0
commit 513d37e9ac
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/utils/tasks.py
View File

@ -5,6 +5,7 @@ import logging
from django.conf import settings from django.conf import settings
from server.settings import get_sysconfig from server.settings import get_sysconfig
import importlib import importlib
import traceback
# 实例化myLogger # 实例化myLogger
myLogger = logging.getLogger('log') myLogger = logging.getLogger('log')
@ -27,7 +28,8 @@ class CustomTask(Task):
""" """
def on_failure(self, exc, task_id, args, kwargs, einfo): def on_failure(self, exc, task_id, args, kwargs, einfo):
detail = '{0!r} failed: {1!r}'.format(task_id, exc) detail ='Task {0} raised exception: {1!r}\n{2!r}'.format(
task_id, exc, einfo.traceback)
myLogger.error(detail) myLogger.error(detail)
send_mail_task.delay(subject='task_error', message=detail) send_mail_task.delay(subject='task_error', message=detail)
return super().on_failure(exc, task_id, args, kwargs, einfo) return super().on_failure(exc, task_id, args, kwargs, einfo)