我使用Celery运行数以千计的任务组,每个任务需要几分钟才能运行。Blocks until finished. ret = celery_module.group(task.s(val) for val in data).apply_async但有时也会发生这样的情况,一个节点死了,几个正在运行的任务随之而来。然后发生的情况是
几天后,我有了一个可用的芹菜和芹菜节拍任务列表,并使用django_celery_results存储结果。但是,当我查看表记录时,其中并没有任何有用的信息。是否可以将任务id设置为人类可读的内容?一个例子是使用演示任务,它返回no,但返回一个不可读的任务id。tasks.pydef test(a,b):app.settings中的调度程序
CELE
我使用异步执行一组操作。这些操作很多,每个操作可能需要很长时间,因此,与其在芹菜工作者函数的返回值中发送结果,不如在自定义状态更新时一次将结果发回。这样,调用方就可以实现带有更改状态回调的进度条,并且worker函数的返回值可以是恒定大小的,而不是在操作数中线性的。在这里,它立即打印芹菜任务ID,然后进入无限循环。 while True:
pas