Сперва прочесть правила.

Сори

Есть задача обращения к апи внешнему, получаю результат от него, сохраняю, эта задача может выполнится несколько раз почему то, что не допусьимо

Что используешь в качестве брокера?

Redis

а используешь celery ?

Очень важно просто, что бы только один раз она запустилась

а используешь celery ?

Да

celery beat

?

celery beat

Нет,

хм

Именно надо только что бы одним воркером она запустилась

И один раз, по внешнему событию

а сколько воркеров запущено одновременно?

4

И с одним пробова

те одну и туде задачу подхватывают 1+ воркера?

Временами все норм, временами несколько раз выпоняется

те одну и туде задачу подхватывают 1+ воркера?

Походу

Но не всегда

а 1 если воркер запустить?

То же самое

Что параметр bind значит?

а задаача выполняется каждый раз корректно?

Не могу понять, из доков

а задаача выполняется каждый раз корректно?

Вот именно, надо что бы в любом случае, даже если не корректно выполнялась она больше не выполнялась

Там запросы к внешнему сервису идут

И иногда получаются повторные списания

попробуй тогда ее закинуть в асинк

попробуй тогда ее закинуть в асинк

Смотри, а в чем разница, я как delay запускаю

и таким образом таска всегда будет завешаться корретно

Временами все норм, временами несколько раз выпоняется

возможно это будет релеватно https://github.com/celery/celery/issues/4400

Смотрел это

У меня без ETA задачи

Смотри, а в чем разница, я как delay запускаю

закидываешь в беграунд задачу

Просто асинхронный запрос к апи делаю, получаю результат, но иногда этот запрос несколько раз желается

типа не дожидаешься когда она выполниться

закидываешь в беграунд задачу

Не понял немного?

типа не дожидаешься когда она выполниться

Не дожидаюсь

эм типа как через nohup в linux запускаешь

те задачу начинает выполняться

Не дожидаюсь

Запускаю, и код дальше идет

Да а задача сама по себе выполняеися

Чтобы воспользоваться фоновым обработчиком, необходимо использовать метод .delay. При помощи этого метода мы передаем выполнение функции обработчику celery и функция должна сразу же вернуть нас в консоль без каких-либо задержек:

вот зачем delay

Чтобы воспользоваться фоновым обработчиком, необходимо использовать метод .delay. При помощи этого метода мы передаем выполнение функции обработчику celery и функция должна сразу же вернуть нас в консоль без каких-либо задержек:

Так и делаю)))

То есть заменить на аплиасинк

ну просто видать где-то у тебя рубится задача

вылетает ексепшен и из очереди задача не удаляется и выполняется еще раз пока

ну просто видать где-то у тебя рубится задача

Возможно, там много вариантов, но если она рубится, мне ее заново не надо поднимать вот чем проблемма

Как быть?))))

бо попробуй всю функцию в обработчик ошибок закинуть )

для проверки

и логируй ошибки

То есть ловлю исключение, если есть то просто задача завершается

ловишь исключение, скрипт не падает

записывай лог

либо в асинк засунь там тоже она падает и фиг с ней)

ловишь исключение, скрипт не падает

И задача завершается? Мне не важно что бы она всегда успешно выполнялась, если упала фиг с ней, он по другому пути пойдет обрабатываться,

смотря где поставишь

ставь на входе и выходе метода выполнения

На весь так?

Так?

Блин

либо где все вызываешь

Таск

А что bind=true значит?

где вызывается задача на выполнение

где вызывается задача на выполнение

Ну тут ее никто не ждёт,

Она вызвалась и дальше код пошел

точнее

где весь воркер выполняется

Джанго

Есть вью

В нем так вызыаается

После его вызова дальше функции выполняются

Результат таска в чат падает, через апи

Результат таска в чат падает, через апи

Через другой сервис

В таске только общение с внешним апи идет

Есть разница между delay и applyasync? Что параметр bind даёт (если не использовать вместе с авто поднятием упавших задач)

mock_open это подстава какая-то

По нему итерироваться нельзя

Причём он даже не падает, а просто молча выдаёт ничего

гм

ты сделай bytesio, а потом у open в return_value его отдавай

и будет счастье

ну или stringio

У mock_open нет return_value же

А простой mock нужно заморачиваться с тем, чтобы он работал как контекст менеджер

Чтобы воспользоваться фоновым обработчиком, необходимо использовать метод .delay. При помощи этого метода мы передаем выполнение функции обработчику celery и функция должна сразу же вернуть нас в консоль без каких-либо задержек:

А от асинк отличается? Из документации не могу понять..

да

асинк выкидывает задачу в бэграунд, а сам идет дальше работать

как только задача выполнится он продолжает работать дальше

с этой задачей

а тут ты задачу выкидываешь сразу в бэк

и не джешь ее выполнения

с этой задачей

То есть скрипт в этом месте будет зависать?