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