2

我在Django中使用Celery设置了我的生产开发机器。一切正常。我的问题是,当我启动我的开发机器时,它开始消耗任务,如果我有一个错误(我经常在我的开发版本上这样做),这会让我很头疼。

我仍然希望我的开发机器发送要使用的任务,但是如何阻止它处理任务并只留下我的生产服务器呢?

PS,我不想删除我的开发机器上的 celery 设置,因为我仍然希望我的开发人员发送要消耗的任务,如果这有意义的话。

这些是我当前的设置...

芹菜

BROKER_URL = 'amqp://admin:xyz@54.111.111.11:5672//'
CELERY_SEND_TASK_ERROR_EMAILS = True

我正在使用 RabbitMQ。

4

1 回答 1

1

You can try:

celery purge

And if you have django-celery you can do

python manage.py celery purge
于 2013-04-30T21:01:24.033 回答