我有我的生产和开发机器设置使用芹菜在Django。一切工作。我的问题是,当我启动我的开发机器时,它开始消耗任务,如果我有一个错误(我经常在我的开发版本上做),这可以给我很多头痛。
我仍然希望我的开发机器发送要消耗的任务,但是我如何阻止它处理任务并只留下我的生产服务器?
PS,我不想删除我的开发机器上的芹菜设置,因为我仍然希望我的开发机器发送任务被消耗,如果这是有意义的。
这些是我的当前设置…
芹菜
BROKER_URL = 'amqp://admin:xyz@54.111.111.11:5672//'
CELERY_SEND_TASK_ERROR_EMAILS = True
我使用RabbitMQ
您可以尝试:
celery purge
如果你有django-芹菜你可以做
python manage.py celery purge