bin.migrate

The celery migrate command, used to filter and move messages.

Module Contents

Classes

migrate() Migrate tasks from one broker to another.
class migrate

Migrate tasks from one broker to another.

Warning:
This command is experimental, make sure you have a backup of the tasks before you continue.
Example:
$ celery migrate amqp://A.example.com amqp://guest@B.example.com//
$ celery migrate redis://localhost amqp://guest@localhost//
add_arguments(parser)
on_migrate_task(state, body, message)
run(source, destination, **kwargs)