将 Celery 任务从 Redis 迁移到 RabbitMQ
Migrate Celery Tasks from Redis to RabbitMQ
我正在将我的 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
我正在将我的 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