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

feat: base 优化邮件报错频率过高自动屏蔽

This commit is contained in:
caoqianming 2024-05-21 15:00:13 +08:00
parent e8ced88547
commit a7d7a312f8
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
apps/utils/tasks.py
View File

@ -5,26 +5,21 @@ 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 hashlib
from django.core.cache import cache from django.core.cache import cache
# 实例化myLogger # 实例化myLogger
myLogger = logging.getLogger('log') myLogger = logging.getLogger('log')
def generate_cache_key(subject):
# 使用邮件主题生成一个唯一的缓存键
hash_subject = hashlib.md5(subject.encode()).hexdigest()
return f"error_email_{hash_subject}"
@shared_task @shared_task
def send_mail_task(**args): def send_mail_task(**args):
config = get_sysconfig() config = get_sysconfig()
subject = args.get('subject', '500')
args['subject'] = '{}:{}_{}_{}'.format( args['subject'] = '{}:{}_{}_{}'.format(
settings.SYS_NAME, settings.SYS_VERSION, config['base']['base_name_short'], args.get('subject', '500')) settings.SYS_NAME, settings.SYS_VERSION, config['base']['base_name_short'], subject)
args['from_email'] = args.get('from_email', settings.EMAIL_HOST_USER) args['from_email'] = args.get('from_email', settings.EMAIL_HOST_USER)
args['recipient_list'] = args.get( args['recipient_list'] = args.get(
'recipient_list', [settings.EMAIL_HOST_USER]) 'recipient_list', [settings.EMAIL_HOST_USER])
cache_key = generate_cache_key(args['subject']) cache_key = f'error_mail_{subject}'
email_tuple = cache.get(cache_key) email_tuple = cache.get(cache_key)
if email_tuple is None: if email_tuple is None:
email_tuple = (0, True) email_tuple = (0, True)