Channel Worker 崩溃:如何在崩溃前完成一些任务?
Channel Worker crash: how to do some task before crash?
出于调试目的,我需要在某些 Channel Worker 因错误而停止时执行任务(发送电子邮件)。
我找不到可以编辑以在 SyncConsumer 或 AsyncConsumer 中添加 mi 任务的闭包方法。
频道==2.2.0
频道-redis==2.4.0
对于完全通用的方法:
您可以尝试覆盖 Consumers __call__
方法
async def __call__(self, receive, send):
try:
await super().__call__(receive, send):
except:
.... do your stuff
raise
出于调试目的,我需要在某些 Channel Worker 因错误而停止时执行任务(发送电子邮件)。
我找不到可以编辑以在 SyncConsumer 或 AsyncConsumer 中添加 mi 任务的闭包方法。
频道==2.2.0 频道-redis==2.4.0
对于完全通用的方法:
您可以尝试覆盖 Consumers __call__
方法
async def __call__(self, receive, send):
try:
await super().__call__(receive, send):
except:
.... do your stuff
raise