Как я могу сделать сельдерей повторить для запросов до успешного - PullRequest
0 голосов
/ 11 мая 2019

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

Я продолжаю получать запросы.*

Я пытался использовать класс повторных запросов, так как это не решение, так как он не сохраняет никаких данных, если сельдерей выходит из строя. Я ищу решение, в котором сельдерей только пытается

@shared_task(queue='development',autoretry_for=(Exception,ConnectionError))
def myfunction:
     response = requests.post(URL),headers={"Content-Type":"application/json"},
        json=obj)


1 Ответ

0 голосов
/ 12 мая 2019

Для тех, кто ищет этот ответ

@shared_task(queue='development',autoretry_for=(Exception,ConnectionError)) def myfunction: response = requests.post(URL),headers={"Content-Type":"application/json"}, json=obj) except ConnectionError as exc: raise myfunction.retry(exc=exc) except Exception as exc: raise myfunction.retry(exc=exc)

...