This document describes the current stable version of Celery (4.3). For development docs, go here.

celery.bin.migrate

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

class celery.bin.migrate.migrate(app=None, get_app=None, no_color=False, stdout=None, stderr=None, quiet=False, on_error=None, on_usage_error=None)[source]

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)[source]
args = '<source_url> <dest_url>'
on_migrate_task(state, body, message)[source]
progress_fmt = 'Migrating task {state.count}/{state.strtotal}: {body[task]}[{body[id]}]'
run(source, destination, **kwargs)[source]