标记的问题 [celery]

82
10 回复
如何在Celery中检查任务状态?
如何检查任务是否在芹菜中运行(具体来说,我使用的是celery-django)? 我已经阅读了文档,我用谷歌搜索了,但我看不到像这样的电话:  my_example_task...
41
5 回复
如何动态添加/删除周期性任务到芹菜(celerybeat)
如果我的函数定义如下:  def add(x,y): return x+y 有没有办法动态添加这个函数作为芹菜PeriodicTask并在运行时启动它?我希望能够做类似(伪代码)...
问 7年前
11
1 回复
使用Celery作为Twisted应用程序的控制通道
我正在尝试使用Celery作为Twisted应用程序的控制通道。 My Twisted应用程序是一个抽象层,为各种本地运行的进程提供标准接口(通过ProcessProtocol)。我想...
问 8年前
29
1 回复
Celery:WorkerLostError:工人过早退出:信号9(SIGKILL)
我在我的Django应用程序(在Elastic Beanstalk上)使用Celery和RabbitMQ来管理后台任务,我使用Supervisor对其进行了守护。 现在的问题是,我定义的一个期...
92
8 回复
你如何对Celery任务进行单元测试?
Celery文档提及在Django中测试Celery 但是如果您不使用Django,则不解释如何测试Celery任务。你是怎么做到的?      92 8个答案                     ...
问 3年前
29
3 回复
Django Celery - 无法连接到amqp://guest@127.0.0.8000:5672 //
我正在尝试设置Django-Celery。我正在阅读教程 http://docs.celeryproject.org/en/latest/django /first-steps-with-django.html 我跑的时候     $py...
问 6年前
14
5 回复
RabbitMQ中的celeryev队列变得非常大
我在rabbitmq上使用芹菜。我已经向队列发送了数千条消息,并且它们正在被成功处理,一切正常。但是,几个rabbitmq队列中的消息数量正在增长(队列中有数十...
29
4 回复
使用Django + Celery更新Haystack搜索索引
在我的Django项目中,我正在使用Celery。我将来自crontab的命令切换为周期性任务,但它运行良好,但它只是在模型上调用方法。是否可以从周期性任务更新我的...
11
5 回复
与django和芹菜+ rabbitmq的消费者连接错误?
我正在尝试用django和rabbit-mq建立芹菜。到目前为止,我已经完成了以下工作: 从pip安装芹菜 通过其存储库提供的debs安装rabbitmq 通过rabbitmqctl为ra...
64
2 回复
将所有celery任务的日志消息发送到单个文件
我想知道如何设置更具体的日志记录系统。我的所有任务都使用  logger = logging.getLogger(__name__) 作为模块范围的记录器。 我希望celery登录到“cele...
问 5年前
42
4 回复
RabbitMQ(beam.smp)和高CPU /内存负载问题
我有一个debian盒用芹菜和rabbitmq运行任务大约一年。最近我注意到任务没有被处理,所以我登录系统,发现芹菜无法连接到rabbitmq。我重新启动了rabbitmq-se...
33
8 回复
什么相当于Python的Celery Java项目?
我试图找到一个相当于Java环境的Celery项目,我看过Spring Batch,但是对于分布式任务队列有更好的选择。 感谢。      33 实际上是这个的副本: stack...
82
5 回复
用Celery取消已执行的任务?
我一直在阅读文档和搜索,但似乎无法找到一个直接的答案: 你可以取消已执行的任务吗? (在任务开始时,需要一段时间,需要取消一半) 我在芹菜常见问题...
19
3 回复
如何对芹菜队列加价?
我在芹菜文档中读到了这个: Task.rate_limit http://celery.readthedocs.org/en/latest/userguide/tasks.html# Task.rate_limit 请注意,这是每个工...
问 4年前
32
2 回复
使用node.js创建Celery worker
使用 node-celery ,我们可以启用节点将Celery作业推送到任务队列。我们如何允许节点成为Celery工作者并使用队列?      32 我正在寻找相同的解决方案...
63
4 回复
了解芹菜任务预取
我刚刚发现配置选项CELERYD_PREFETCH_MULTIPLIER( docs < /A>)。默认值为4,但(我相信)我希望预取或尽可能低。我现在把它设置为1,这足够接近我正在寻...
问 6年前
27
2 回复
如何使用@shared_task装饰器进行基于类的任务
如文档所示 @shared_task装饰器允许您创建任务而无需任何具体的应用程序实例。给出的示例显示了如何装饰基于函数的任务。 如何装饰基于类的任务?      2...
问 6年前
17
6 回复
启动Celery:AttributeError:'module'对象没有属性'celery'
我尝试从命令行启动Celery worker服务器:  celery -A tasks worker --loglevel=info tasks.py中的代码:  import os os.environ[ 'DJANGO_SETTINGS_M...
56
6 回复
Celery AttributeError:异步错误
我在我的Mac上运行RabbitMQ和Celery(OS /X 10.13.4),当我运行add.delay(x,y)时,以下代码在本地运行:  #!/usr/bin/env python from celery import...
问 1年前
119
12 回复
检索Celery中队列中的任务列表
如何检索队列中尚未处理的任务列表?      119 您使用的是哪个后端? 2011-04-05 11:08:26Z RabbitMQ,但我想在Python中检索这个列表。 2011-...
问 8年前
15
1 回复
Celery:每个任务的并发限制(每个任务的工作人员数量)?
是否可以在 Celery 中按每个任务级别设置并发性(同时工作者数)?我正在寻找更精细的CELERYD_CONCURRENCY(它为整个守护进程设置并发性)。 使用场景是:...
问 7年前
166
8 回复
删除celery / rabbitmq中的所有待处理任务
如何在不知道每项任务的task_id的情况下删除所有待处理任务?      166 8个答案                              8                          来自
15
2 回复
如何在virtualenv中为Celery(django-celery)编写Ubuntu Upstart作业
我真的很喜欢使用暴发户。我目前有很多新手工作,可以在许多版本中运行不同的gunicorn实例。但是,我在互联网上找到的芹菜新贵脚本的2-3个例子对我不起作用...
16
2 回复
带有create_app,SQLAlchemy和Celery的Flask
我真的很难为Flask,SQLAlchemy和Celery进行正确的设置。我已经广泛搜索并尝试了不同的方法,似乎没有什么工作。我错过了应用程序上下文或无法运行工作程序...
16
1 回复
解决celerybeat是一个单一的失败点
我正在寻找推荐的解决方案来解决celerybeat是芹菜/rabbitmq部署的单点故障。到目前为止,我没有找到任何有意义的东西,通过网络搜索。 在我的情况下,每天...
问 7年前