This document describes the current stable version of Celery (4.4). 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//
-
args
= '<source_url> <dest_url>'¶
-
progress_fmt
= 'Migrating task {state.count}/{state.strtotal}: {body[task]}[{body[id]}]'¶
-