djcelery

    1热度

    1回答

    所以我有一个任务创建一个工作目录并在那里完成所有工作。 该任务从服务器A调用,并在工作服务器上执行。 我需要确保任务完成后删除工作目录/ 取消。 我添加了一个任务,撤销的处理程序,它看起来像这样: @task def my_task(value): task_id = current_task.request.id work_dir = os.path.join(BASE_

    0热度

    1回答

    我正尝试异步地创建一堆芹菜任务。假设有1000个异步启动的任务,并且我只有一个celeryd进程运行来执行任务。芹菜将创建多少个线程来处理这些任务? 如果芹菜有多个线程自动启动来处理任务队列,如何限制芹菜在给定的时间点只执行100个线程。 谢谢。

    1热度

    1回答

    芹菜和django一起使用。我必须为用户提供一个选项,以便检查失败的任务,并根据需要修改失败的任务数据并重新提交。我看过这个主题 - Celery Storing unrecoverable task failures for later resubmission。 所以我明白,芹菜不存储任务的原始参数和kwargs,我们需要照顾。我很好,这样做。 但是,如果我有一个提交链“SubTask1 |

    6热度

    2回答

    我试图在我的django项目上设置芹菜时,对这两个应用程序之间的差异感到困惑。 两者之间有什么区别?在网上阅读教程时,我看到他们都使用了,我不确定哪些对我最好。看起来,djcelery有点像芹菜,但为django量身定制?但是芹菜不需要包含在安装的应用程序中,而djcelery则可以。 谢谢

    3热度

    2回答

    对异步进程运行manage.py celeryd时,一切都按预期工作,但每次启动时都会出现奇怪的警告。这不会导致任何错误,但我很难让它消失或理解其含义。 这就是: /home/user/lib/python2.7/billiard-2.7.3.15-py2.7-linux -x86_64.egg/billiard/forking.py:455: UserWarning: Will add

    0热度

    1回答

    我有一个django芹菜视图,它执行某些任务,并在任务完成后成功将其写入数据库。 我这样做: result = file.delay(password, source12, destination) 而且, if result.successful() is True: #writes into database 但是任务已完成执行后不进入,如果condition.I试图用re

    3热度

    1回答

    我在django芹菜中使用数据库后端。任务信息存储在数据库中名为celery_taskmeta的表中。 这是我的任务: @celery.task def file_transfer(password, source12, destination): result = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-az',

    1热度

    1回答

    当我尝试用芹菜和芹菜节拍启动我的开发服务器时,出现以下错误。有一天这件事情第二天起作用它不会,我没有改变任何可以解释这一点的东西。我开始我的服务器使用的工头和Procfile.dev像这样: Procfile: web: python manage.py runserver celeryd: python manage.py celeryd -E -B --loglevel=INFO --con

    2热度

    1回答

    我有芹菜任务是这样的: @celery.task def file_transfer(password, source12, destination): result = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', source12, destination], stderr=su

    2热度

    1回答

    我有一个生成通过Python的itertools产品大名单的程序;基本上是一组大量的单词组合。有多个集合可以运行products()函数。我想要做的是让Celery帮忙,把每一套芹菜任务分配给不同的芹菜任务,最后把它们结合起来。我的理解是和弦是做到这一点的方法。 所以基本上我有这样的: callback = tabulate_results.subtask() header = [] for