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

refector: 正式环境500才发邮件

This commit is contained in:
caoqianming 2023-03-23 13:48:13 +08:00
parent 8628d0a74b
commit 3c91e23cec
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/utils/tasks.py
View File

@ -10,11 +10,12 @@ myLogger = logging.getLogger('log')
@shared_task
def send_mail_task(**args):
from django.core.mail import send_mail
args['subject'] = args.get('subject', '{}:{}_{}_500'.format(settings.SYS_NAME, settings.SYS_VERSION, settings.PROJECT_NAME))
args['from_email'] = args.get('from_email', settings.EMAIL_HOST_USER)
args['recipient_list'] = args.get('recipient_list', [settings.EMAIL_HOST_USER])
send_mail(**args)
if settings.DEBUG is False:
from django.core.mail import send_mail
args['subject'] = args.get('subject', '{}:{}_{}_500'.format(settings.SYS_NAME, settings.SYS_VERSION, settings.PROJECT_NAME))
args['from_email'] = args.get('from_email', settings.EMAIL_HOST_USER)
args['recipient_list'] = args.get('recipient_list', [settings.EMAIL_HOST_USER])
send_mail(**args)
class CustomTask(Task):
@ -23,7 +24,8 @@ class CustomTask(Task):
"""
def on_failure(self, exc, task_id, args, kwargs, einfo):
detail = '{0!r} failed: {1!r}'.format(task_id, exc)
myLogger.error(detail)
send_mail_task.delay(subject='{}:{}_{}_task_error'.format(settings.SYS_NAME, settings.SYS_VERSION, settings.PROJECT_NAME), message=detail)
return super().on_failure(exc, task_id, args, kwargs, einfo)
if settings.DEBUG is False:
detail = '{0!r} failed: {1!r}'.format(task_id, exc)
myLogger.error(detail)
send_mail_task.delay(subject='{}:{}_{}_task_error'.format(settings.SYS_NAME, settings.SYS_VERSION, settings.PROJECT_NAME), message=detail)
return super().on_failure(exc, task_id, args, kwargs, einfo)