我在Django中使用Celery设置了我的生产和开发机器。一切正常。我的问题是,当我启动我的开发机器时,它开始消耗任务,如果我有一个错误(我经常在我的开发版本上这样做),这会让我很头疼。
我仍然希望我的开发机器发送要使用的任务,但是如何阻止它处理任务并只留下我的生产服务器呢?
PS,我不想删除我的开发机器上的 celery 设置,因为我仍然希望我的开发人员发送要消耗的任务,如果这有意义的话。
这些是我当前的设置...
芹菜
BROKER_URL = 'amqp://admin:xyz@54.111.111.11:5672//'
CELERY_SEND_TASK_ERROR_EMAILS = True
我正在使用 RabbitMQ。