0
セロリのバックエンドをredisからrabbitmqに変更します。新しいブローカーにBROKER_URLを変更させてもらうことができます。しかし、私はどのように既存のスケジュールされたタスクをredisからrabbitmqブローカーに移行するのだろうか?セレスリータスクをRedisからRabbitMQに移行する
可能であれば、私はこれをPythonスクリプトで行いたいと思います。
セロリのバックエンドをredisからrabbitmqに変更します。新しいブローカーにBROKER_URLを変更させてもらうことができます。しかし、私はどのように既存のスケジュールされたタスクをredisからrabbitmqブローカーに移行するのだろうか?セレスリータスクをRedisからRabbitMQに移行する
可能であれば、私はこれをPythonスクリプトで行いたいと思います。
Celeryは、デフォルトで次のコマンドを提供します。
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
これに答えて検索したことがありますか? – theMayer
「migrate」と呼ばれるセロリのためのツールがあるようです。それはトリックを行う必要があります。まだそれを確認することはできませんでした。それがうまくいくなら、私はそれについて答えを出します。 – hanshoi