celery retry发送的队列
2024-09-25 23:41:40
celery retry时，将发送到原有的队列，并在任务中加入执行的时间，以及当前重试的次数。
worker立刻读取该任务，同时记录一条【任务】到 unacked中，表示该任务在worker中还未执行。
eyJleHBpcmVzIjogbnVsbCwgInV0YyI6IGZhbHNlLCAiYXJncyI6IFsiMTIzNCJdLCAiY2hvcmQiOiBudWxsLCAiY2FsbGJhY2tzIjogbnVsbCwgImVycmJhY2tzIjogbnVsbCwgInRhc2tzZXQiOiBudWxsLCAiaWQiOiAiZmJlNjBlOGMtMTk1Yi00ZTI2LTg4ZTYtOTIwYzkzZjIyZDdlIiwgInJldHJpZXMiOiA4LCAidGFzayI6ICJ0YXNrcy5tYWluIiwgInRpbWVsaW1pdCI6IFtudWxsLCBudWxsXSwgImV0YSI6ICIyMDE5LTExLTE5VDE4OjU4OjU0LjQ2ODAwMCIsICJrd2FyZ3MiOiB7fX0=
{"expires": null, "utc": false, "args": ["1234"], "chord": null, "callbacks": null, "errbacks": null, "taskset": null, "id": "fbe60e8c-195b-4e26-88e6-920c93f22d7e", "retries": 8, "task": "tasks.main", "timelimit": [null, null], "eta": "2019-11-19T18:58:54.468000", "kwargs": {}}
发送的方式 apply_async(args=[data], eta=【执行时间】)
一次重试的过程会读写几次redis，传输的对象比较大。
重试的任务QPS稍微多，会用大量的网络流量——>DBA告警找你
最新文章
- SQL Server-聚焦计算列持久化（二十一）
- .net面试(汇总2)
- LINUX安全设置
- ThinkPHP查询数据与CURD
- 在Eclipse中制作SSH配置文件提示插件
- shell语句记录-awk
- opennebula 自定义安装目录
- Remastersys打包你自己的ubuntu成iso文件，保存原来的所有配置
- BZOJ 2754: [SCOI2012]喵星球上的点名
- java形参是否会改变实参
- Cocos2dx-Android 之Makefile通用高级写法
- mysql 查询 45 道题
- JavaScript严格模式说明带示例
- fiddler抓取https失败解决方案
- python学习：删除空白
- 手写JavaScript常用的函数
- 【C#数据结构系列】图
- 一个windows计划任务的Nginx日志自动截断的批处理命令
- 虚拟机扩容mac
- IncrediBuild 2.40 过期时间