Ответы пользователя по тегу Celery
  • Как отправить через celery, свой созданный объеку и запустить его в rabbit celer?

    @rodion4dev
    Нужно реализовать собственный json.JSONEncoder с переопределением метода encode, который будет определять передаваемый объект, и, если он является объектом класса ServiceTTS, сериализовать данные этого объекта в простейший тип. Собственную реализацию json.JSONEncoder'а нужно указать в настройках Celery задачи; ровно так же, как собственно-реализованный json.JSONDecoder, который получит на вход простейшие данные и превратит их в объект класса ServiceTTS.

    Но если Вы встали перед необходимостью "передать собственный объект через Celery", значит в вашей архитектуре что-то не так. И я предлагаю Вам не прибегать к реализации энкодера и декодера и подготавливать данные до постановки задачи в Celery.
    Ответ написан
    Комментировать
  • Celery не видит модуль. Как подключить celery к FastApi?

    @rodion4dev
    Неверно указан путь до приложения Celery в docker-compose.yaml в worker.command. Попробуйте celery_worker:celery, если папка api - всего лишь папка (не пакет python); иначе - api.celery_worker:celery
    Ответ написан