celery migrate command, used to filter and move messages.
||Migrate tasks from one broker to another.|
Migrate tasks from one broker to another.
- This command is experimental, make sure you have a backup of the tasks before you continue.
$ celery migrate amqp://A.example.com amqp://guest@B.example.com// $ celery migrate redis://localhost amqp://guest@localhost//
on_migrate_task(state, body, message)¶
run(source, destination, **kwargs)¶