2017-05-29 5 views
0

Ich ändere mein Sellery-Backend von redis nach rabbitmq. Ich kann den neuen Broker mit der Änderung meiner BROKER_URL arbeiten lassen. Wie auch immer, ich frage mich, wie man vorhandene geplante Aufgaben von redis nach rabbitmq broker migrieren kann?Sellerie-Aufgaben von Redis auf RabbitMQ migrieren

Ich würde dies gerne per Python-Skript tun, wenn möglich.

+0

Gibt es irgendetwas, das Sie bei Ihrer Suche nach einer Antwort darauf versucht oder ausgegraben haben? – theMayer

+1

Anscheinend gibt es ein Werkzeug für Sellerie namens "migrieren". Es sollte den Trick machen. Habe es aber noch nicht verifizieren können. Wenn es funktioniert, werde ich eine Antwort darauf geben. – hanshoi

Antwort

0

Sellerie bietet standardmäßig folgende Befehle.

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