django-celery

    1热度

    1回答

    我可以单独检查并删除Celery/RabbitMQ任务吗？

    我正在运行Django + Celery + RabbitMQ。在修改某些任务名称后，我开始获得“未注册的任务”KeyErrors，即使在使用该键从Django Celery Beat的Periodic tasks表中删除任务并重新启动了Celery worker之后。 原来Celery/RabbitMQ tasks are persistent。我最终通过reimplementing the l
    django rabbitmq celery django-celery celerybeat 2017-08-28

    1热度

    1回答

    如何摆脱仍在Celery/RabbitMQ队列中的遗留任务？

    我正在运行Django + Celery + RabbitMQ。在修改某些任务名称后，我开始获得“未注册的任务”KeyErrors，即使在使用该键从Django Celery Beat的Periodic tasks表中删除任务并重新启动了Celery worker之后。他们persist甚至在running with the --purge option之后。 我该如何摆脱它们？
    django rabbitmq celery django-celery celerybeat 2017-08-28

    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

    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

    0热度

    3回答

    我该如何防止相同的任务在另一个上执行？

    我有一个任务，从API中提取数据，然后对数据库（SQLite）进行系统自动化（删除，重命名......）。我将任务设置为每5分钟执行一次。但是，有时这项任务需要5分钟才能完成，因此两项任务并行运行。这不好，因为SQLite数据库在0分钟内被锁定到任务。 怎样才可以有，要么， 任务不会，除非前面的任务已经完成或执行 第二个任务排队等候和执行后直接0分钟任务完成了吗？ 我试图使用全局布尔值来防止任务在
    python django celery django-celery 2017-09-25

    2热度

    2回答

    如何重新启动芹菜Wroker由Supervisord运行

    我使用supervisord运行芹菜生产。我的主管配置如下。 [program:celeryd] command=%(ENV_PROJECT_PATH)s/scripts/celery_worker.sh stdout_logfile=%(ENV_PROJECT_PATH)s/celeryd.log stderr_logfile=%(ENV_PROJECT_PATH)s/celeryd.lo
    python django celery django-celery supervisord 2017-10-18

    0热度

    2回答

    芹菜任务队列不能与rabbitmq一起工作

    芹菜任务成功执行无队列 设置。 BROKER_URL = "amqp://user:[email protected]:5672/test" # Celery Data Format CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERYD_TASK_SOFT_TIME_LIM
    python rabbitmq celery django-celery 2017-09-15

    0热度

    2回答

    将参数传递给Celery任务的on_failure方法

    我正在创建一个自定义Celery任务类，以覆盖在任务达到最大重试次数（on_failure）时发生的情况。如果任务失败，我需要更新用户模型的状态。 下面是我的自定义任务类： class ReadyTask(Task): def run(self, user): try: user.get_results() except Exception as
    python task celery scheduled-tasks django-celery 2017-07-28

    -1热度

    1回答

    导入错误：没有模块名为task.control

    我试图导入revoke方法芹菜，取消与一个任务： from celery.task.control import revoke 但这引发错误： ImportError: No module named task.control 为什么我得到这个错误？我找不到有关Celery删除或重构此方法的任何文档。 我使用的是celery==3.1.18，我无法升级它，因为我使用的Django版本依赖于
    django celery django-celery 2017-07-31

    0热度

    2回答

    让用户创建芹菜周期性任务

    我想问你在django应用程序中使用芹菜和redis的情况。我正在学习芹菜约2天，我仍然有点困惑：/我已经安装了芹菜和redis，它工作得很好。我的问题是，我希望用户创建，更新和暂停周期性任务。我读过这篇文章 - http://kindshofer.net/2016/11/19/dynamically_adding_a_periodic_task_to_celery.html和这个问题 - How
    django redis celery django-celery periodic-task 2017-09-19
最新问题