代码之家 › 专栏 › 技术社区 › Saifullah khan

Django Celery仅使用失败的数据集重试当前任务

django-celery celery django python

Saifullah khan · 技术社区 · 7 年前

我有以下代码

from utils import SendSMS
from celery.exceptions import *


@celery.task(bind=True, max_retries=3)
def send_sms(self,sms_list):
    failed_items = []
    for sms_item in sms_list:
        status = SendSMS( **sms_item )
        if status in ['Timeout','Error']:
            failed_items.append( sms_item )

    if len(failed_items) > 0:
        raise self.retry(failed_items)

    return "sms(s) send successfully."

我想使用不同的数据集重试该任务,但只使用失败的项目。

我的意思是,我怎样才能做到这一点:

raise self.retry(failed_items) ?

提前谢谢。

2 回复 | 直到 7 年前

sachin gera 7 年前

@task()
def add(self, x, y):
    if not x or not y:
        try:
           raise Exception("test error")
        except Exception, e:
            add.retry(args=[x, y], exc=e, countdown=30)
    return x+y

Saifullah khan 7 年前

@celery.task(bind=True, max_retries=2)
def send_sms(self,**kwargs):
    sms_list = kwargs.get("sms_list",[])
    failed_items = []
    for sms_item in sms_list:
        status = SendSMS( **sms_item )
        if status in ['Timeout','Error']:
            failed_items.append( sms_item )

    if len(failed_items) > 0:
        exc = Exception(status)
        raise self.retry( exc=exc, sms_list=failed_items)

    return "sms(s) send successfully."

推荐文章

furang · 在Django模板中将芹菜任务的结果返回给客户端

7 年前

furang · 在Django不能叫芹菜

7 年前

Alexander · Django 2,Celery 4.1 ModuleNotFoundError:没有名为Djancelly的模块

7 年前

andilabs · @task\u postrun。连接芹菜中的信号并执行另一个任务会导致一些执行的内场循环

7 年前

juju · Django芹菜daemonization

7 年前

Saifullah khan · Django Celery仅使用失败的数据集重试当前任务

7 年前

Matt · 芹菜任务未超时

7 年前

user714852 · 为什么将导出DJANGO_SETTINGS_MODULE='myproject.SETTINGS'添加到bashrc不再有效?

10 年前

zeenfaiz · Django和Celery的全局变量

11 年前

Gandalf · 为django安装芹菜

12 年前