小编Gre*_*gor的帖子

每次重试周期增加芹菜重试时间

我像在Docs-Example中那样用芹菜重试:

@task()
def add(x, y):
    try:
        ...
    except Exception, exc:
        add.retry(exc=exc, countdown=60)  # override the default and
                                          # retry in 1 minute
Run Code Online (Sandbox Code Playgroud)

每次重试此作业时,如何增加重试倒计时 - 例如60秒,2分钟,4分钟等等,直到MaxRetriesExceeded被提升为止?

python celery celeryd

16
推荐指数
3
解决办法
6248
查看次数

在一台机器上共享芹菜工人之间的记忆区域

我想在芹菜中分享我的工作节点之间的小块信息(例如缓存的授权令牌,统计信息......).

如果我在我的任务文件中创建一个全局文件,那么每个工作者都是唯一的(我的工作者是进程并且具有1个任务/执行的生命周期).

什么是最佳做法?我应该在外部保存状态(DB),创建一个老式的共享内存(由于芹菜中不同的池实现,可能很难)?

提前致谢!

python shared-memory celeryd

7
推荐指数
1
解决办法
4033
查看次数

真的很容易python对峙

我觉得不能解决这样的问题真的很蠢,但我指的是空白.我需要提出一个简短而优雅的方法来做到这一点,由于某种原因我不能!

这个概念很简单

我有一份清单,[4,3,5,2,1]我有五个人A, B, C, D, E

A=4 B=3 C=5 D=2 E=1

现在,我需要根据他们的数字按升序排列它们,以便它们成为

['E', 'D', 'B', 'A', 'C']

我真的不明白为什么我不能想出这个D:

python

2
推荐指数
1
解决办法
107
查看次数

标签 统计

python ×3

celeryd ×2

celery ×1

shared-memory ×1