celery

    0热度

    1回答

    芹菜 - 一个任务运行N个任务，等待他们和处理结果

    我需要以下流程： ParentTask运行第一 在某些时候，它产生的ChildTask N个实例，其运行在平行 ParentTask等待那些完成，收集结果，莫名其妙地处理它们，并完成 这似乎是很容易的。不幸的是，从任务中调用Task().delay()（我用它来调用任务）似乎完全被忽略。我完全迷失在这里。 如果你喜欢代码的方法更多，我也包括它。 from celery.task import Ta
    python celery 2017-08-29

    0热度

    1回答

    芹菜帆布组传递参数太多组成任务

    我遇到与下面这种芹菜工作流程的一些非常奇怪的行为链： workflow = group( chain(task1.s(), task2.s()), chain(task3.s(), task4.s()), ) 这是在Django的背景下。 当我调用工作流程如下： workflow.apply_async((n,)) ...对于n的任意整数值，在每个链（task1和task3
    python django celery celery-canvas 2017-08-31

    1热度

    1回答

    TypeError：func（）只需要1个参数（0给出）

    我是新来的python，但我知道自我是自动传递。我无法理解为什么我得到这个错误，我得到同样的错误getGraph函数以及2需要1给定。 这里怎么回事？ CreateDoc是CeleryTasks.py和insert_manager在MongoTriggers.py @app.task def createDoc(self): print ("CeleryTasks:Creat
    python mongodb celery 2017-09-01

    0热度

    2回答

    芹菜+ Python：在另一个任务中排队耗时的任务

    我想查询一个api（这很耗时），有很多项目（〜100），但不是一次全部。相反，我想在查询之间稍微延迟一点。 我现在有是获取异步，并通过查询，并在每次迭代后迭代执行的任务等待一段时间： @shared_task def query_api_multiple(values): delay_between_queries = 1 query_results = []
    python celery django-celery 2017-09-03

    1热度

    1回答

    芹菜任务路线工作不正常

    我在练芹菜，我想我分配任务特定的队列但预期它不工作 我__init__.py import os import sys from celery import Celery CURRENT_DIR = os.path.dirname(os.path.abspath(__file__)) sys.path.append(CURRENT_DIR) app = Celery() app.
    python celery 2017-09-04

    0热度

    1回答

    发布交易提交时的芹菜锁

    我在我的Django项目中使用了一个Celery任务，并带有锁，如this article中所述。它工作的很好，但我的任务创建一个对象，我不希望在数据库中提交对象之前释放锁。我如何才能更改此上下文管理器以等待任务中的对象提交？ @contextmanager def lock(lock_id, oid, expire=600): timeout_at = monotonic() + e
    python django locking celery 2017-09-05

    0热度

    1回答

    有人可以向我解释芹菜组是如何工作的吗？

    当我使用芹菜组和链调度任务如下 (group([group_task]) | sum_task).apply_async() 在组任务可以在许多工人被执行，所有的组任务完成之后，sum_task开始执行（也许在其他工人），所以 谁可以告诉我芹菜知道小组任务全部完成，然后启动sum_task？
    python celery 2017-09-12

    0热度

    1回答

    Django芹菜和rabbitmq不工作，直到重新启动

    我有django，芹菜和rabbitmq问题。 我使用芹菜向FCM设备发送消息，但问题是芹菜不会运行该FCM命令发送消息，直到我重新启动芹菜服务器。 当我重新启动芹菜，并再次尝试，仍然相同，我需要在每次行动后再次重新启动它。 示例代码： from __future__ import absolute_import, unicode_literals from celery import sha
    python django rabbitmq celery django-celery 2017-09-13

    7热度

    2回答

    在芹菜中的多个队列中优先队列？

    我们将芹菜用于异步后台任务，我们有2个队列用于不同的优先级任务。我们有2个节点集群单独服务它们。事情如预期般运作良好。 问： 我们得到多为低优先级任务。为了优化资源利用率，我想知道是否有办法配置worker（侦听高优先级队列）来侦听这两个队列。但只要有一份工作在那里，就从更高优先级的队列中选择工作？否则返回低优先级队列。 我已经通过讨论@Celery Task Priority讨论了基于优先级的任
    celery celery-task 2017-09-13

    0热度

    1回答

    如何在Django应用程序级任务中导入Celery应用程序？

    我跟着导游http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html，但我无法找到如何导入芹菜应用在应用级tasks.py，它这样使用： @app.task() def do_my_task():
    django celery 2017-09-14
最新问题