Вставка задач Celery непосредственно в Redis

Question

У меня есть система Эрланга. Я хочу, чтобы эта система могла запускать задачи Celery в другой системе на основе Python. У них один хост, и Celery использует Redis в качестве своего брокера.

Можно ли вставлять задачи для Celery непосредственно в Redis (в моем случае, из Erlang) вместо использования Celery API?

Answer 1

Да, вы можете вставлять задачи непосредственно в Redis или любой другой бэкэнд, который вы используете с сельдереем.

Вам нужно будет соответствовать формату сериализации сельдерея (который по умолчанию находится в JSON) и выяснить, к каким ключам он вставляется. Используемая структура ключа четко не задокументирована, но эта часть исходного кода - хорошее место для начала.

Вы также можете использовать команду redis monitor, чтобы посмотреть, какие ключи использует сельдерей в режиме реального времени.