Python中文
首页
教程
问答
标签
搜索
登录
注册
如何在多个celeryd进程中跟踪撤销的任务
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我有一个提醒类型的应用程序,它使用“eta”参数来调度芹菜中的任务。如果提醒对象中的参数发生了变化(例如提醒时间),那么我将撤消先前发送的任务并对新任务进行排队。在</p> <p>我想知道有没有什么好方法可以在celeryd重启时跟踪被撤销的任务。我希望能够动态地放大/缩小celeryd进程,而且似乎在发送revoke命令之后启动的任何celeryd进程仍将执行该任务。在</p> <p>一种方法是保留一个已撤销任务ID的列表,但是这种方法会导致列表任意增长。修剪这个列表需要保证任务不再在RabbitMQ队列中,这似乎是不可能的。在</p> <p>我还尝试为每个celeryd worker使用共享的--statedb文件,但似乎statedb文件只在worker终止时更新,因此不适合我想要完成的任务。在</p> <p>提前谢谢!在</p>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>不久前我实现了类似的东西,我提出的解决方案与你的非常相似。在</p> <p>我解决这个问题的方法是让工作人员在作业运行时从数据库中获取<code>Task</code>对象(按照文档的建议,通过传递主键)。在您的情况下,在发送提醒之前,工作人员应该执行检查,以确保任务“准备好”可以运行。如果没有,它应该简单地返回而不做任何工作(假设ETA已经改变,并且另一个工人将接受新的工作)。在</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
我想从用户inpu创建一个类的实例
3 回答
我想从用户导入值,为此
2 回答
我想从用户那里得到一个整数输入,然后让for循环遍历该数字,然后调用一个函数多次
6 回答
我想从用户那里收到一个列表,并在其中执行一些步骤,然后在步骤完成后将其打印回来,但它没有按照我想要的方式工作
4 回答
我想从用户那里获取输入,并将值传递给(average=dict[x]/6),然后在那里获取resu
1 回答
我想从第一个列表中展示第一个词,然后从第二个列表中展示十个词,以此类推- Python
8 回答
我想从第一个空lin开始解析文本文件
5 回答
我想从简历、简历中提取特定部分
1 回答
我想从给定字典(python)的字符串中删除\u00a9、\u201d和类似的字符。
9 回答
我想从给定的网站Lin下载许多文件扩展名相同的Wget或Python文件
8 回答
我想从网上搜集一些关于抵押贷款的数据
9 回答
我想从网站上删除电子邮件地址
10 回答
我想从网站上读取数据该网站包含可下载的文件,然后我想用python脚本把它发送给oracle如何?
7 回答
我想从网站中提取数据,然后将其显示在我的网页上
4 回答
我想从网页上提取统计数据。
1 回答
我想从网页上解析首都城市,并在用户输入国家时在终端上打印它们
1 回答
我想从色彩图中删除前n个颜色,而不丢失原始颜色数
5 回答
我想从课堂上打印字典里的键
2 回答
我想从费用表中获取学生上次支付的费用,其中学生id=id
1 回答
我想从较低的顺序对多重列表进行排序,但我无法在一行中生成结果
3 回答