我想运行一个由beat调度的复杂任务。让我们假设定义了默认的add/mul任务。 @app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(
crontab(),
add.s(2,3) | mul.s(2)
) 但这将在worker中返回一个错误: NotImplementedError: chain is not a real task 如何使用芹菜节拍安排一个非琐碎的任务?
我目前正在使用nitrous.io运行Django和芹菜,然后Cloudamqp作为我的代理与免费计划(最多3个连接)。我能够很好地进行连接,并且可以很好地启动定期任务。
当我跑的时候
celery -A proj worker -l info
Cloudamqp上立即创建了两个连接,我可以在第三个连接上手动创建多个任务,一切都很好。然而,当我运行芹菜节拍与
celery -A proj worker -B -l info
所有3个连接都被使用了,如果芹菜节拍创建了1个或更多新任务,则会创建另一个连接,从而超过允许的最大连接数。
我已经尝试过了,目前已经设置了