django - Channel Worker 崩溃:崩溃前如何做一些任务?
问题描述
出于调试目的,当某些 Channel Worker 因错误而停止时,我需要执行一项任务(发送电子邮件)。
我没有找到可以编辑以在 SyncConsumer 或 AsyncConsumer 中添加 mi 任务的关闭方法。
频道==2.2.0 频道-redis==2.4.0
解决方案
对于一个完全通用的方法:
您可以尝试覆盖消费者__call__
方法
async def __call__(self, receive, send):
try:
await super().__call__(receive, send):
except:
.... do your stuff
raise
推荐阅读
- c# - 使用 iText7 生成 16x48 数据矩阵的问题
- c# - 在 xpath 中传递 Datatable 项并收到错误“javascript 错误:参数 [0].scrollIntoView 不是函数”
- reactjs - 向 Next.js 联系表单添加验证
- python - 如何在字符串开头打印百分比?
- jenkins - 在 jenkins 中使用脚本控制台归档工件
- url - 如何在drupal中打印博客标签的url
- ruby-on-rails - 我应该如何存储过期的统计数据?
- javascript - 在 next.js 中加载 Jquery 后如何加载脚本
- version-control - 从 Markdown 文本创建 PowerPoint 演示文稿的最佳工作流程是什么?
- python - 在 Django 模型中下载上传的文件它只下载 .html 文件而不是实际的 doc 文件......?