现在common的view下写了一个MyHandle类,重写emit方法
class MyHandle(logging.Handler):
"""
输出日志到队列
"""
def emit(self, record):
insert_logging.apply_async(args=[self.format(record)], queue=settings.RABBITMQ_QUEUE)
此代码放在celery文件中,想通过celery来实现日志写入队列,之后再做处理
但是我的消费者写在tasks文件中
然后再配置中加上handle,保证在每次访问的时候都会写入到队列
结果在启动的时候就会报错,app没加载,因为tasks里面会加载到一些模型类等等。
最大的问题就是如果自定义了Handle,不知道这个handle该如何配置,才能不会在项目启动时发生冲突
上图是django的配置,里面是自定义了一个handle