我正在将我的Celery后端从redis更改为rabbitmq . 我可以让新经纪人改变我的BROKER_URL . 但是我想知道如何将现有的计划任务从redis迁移到rabbitmq代理?
如果可能的话,我想通过Python脚本来做这件事 .
Celery默认提供以下命令 .
celery -b "redis://<url>:<port>/<db>" inspect scheduled > scheduled_tasks.txt celery migrate "redis://<url>:<port>/<db>" "amqp://<username>:<password>@<url>:<port>/<vhost>" celery -b "amqp://<username>:<password>@<url>:<port>/<vhost>" inspect scheduled > post_migration_scheduled_tasks.txt diff scheduled_tasks.txt post_migration_scheduled_tasks.txt
1 回答
Celery默认提供以下命令 .