Celery是Python的分布式任务队列框架,用于异步和并行执行。
我有一个用Django编写的REST API,其中和端点在发布芹菜任务时对其进行排队。响应包含任务ID,我想用它来测试任务是否已创建并获得...
获取RecursionError / KeyError尝试在Celery beat中添加Periodic Task
我尝试在Django上使用Celery击败设置一些周期性任务。我正在使用下一个设置:python3.6 django == 1.11.10 celery == 4.2.1 kombu == 4.2.1我的计划工作人员通过docker -...在Docker容器中运行
AWS SWF和SQS关系是否与Celery和RabbitMQ类似?
我需要知道它们之间的实际差异。我刚刚在高层次上了解了这些技术。
我开始有这么多芹菜任务,我想将它们分解成较小的文件,而不是将它们放在一个大的tasks.py中,但我没有设法让芹菜去发现它们。工作......
app = Celery('myapp',broker ='amqp:// user:pass#1 @ localhost:5672 //',backend ='rpc://',include = ['myapp.tasks'])我得到这个错误ValueError:文字无效...
谁知道我可以在哪里添加额外的芹菜配置到气流芹菜执行器?例如,我想要http://docs.celeryproject.org/en/latest/userguide/configuration.html#worker-pool-restarts这个属性......
我对芹菜的基本了解及其运作方式。在我目前的项目中,我遇到了确定任务优先级的需求。我的意思是,如果有两种任务,比如说芹菜中的A和B ......
如何使用aws或digitalocean和broker作为redis或rabbitmq在Production Server中设置Celery。请详细说明我们如何能够恢复连接拒绝错误的同时...
我遇到了以下种类的芹菜工作流程的一些非常奇怪的行为:workflow = group(chain(task1.s(),task2.s()),chain(task3.s(),task4.s()),)这是在上下文中......
django-channels / celery:如何跟踪任务列表的进度?
我“成功地”从视图向客户端发送一条消息,其中包含一组任务(不是实际的芹菜组)的状态。问题是:这真的忽略了所有任务是否实际......
如何设置Celerybeat和Flask的定期任务,每小时查询一次数据库?环境如下所示:/ | -app | -__ init__.py | -jobs | -task.py | -celery-beat.sh | -...
与celery相关的气流cfg设置有:broker_url ='amqp:// guest:guest @ rabbitmq_server:8080'celery_result_backend = db + postgresql:// developer:password @ postgres_server:5432 / db_name气流......
无法将响应数据保存到实例的字段;正确保存同一块中的其他数据(Django / Celery)
我正在运行一项任务,即在第三方服务上创建帐户,并将该服务响应中的相关数据保存到我的个人资料对象中。任务正在运行,数据将返回...
我不能让我的芹菜工人经常听默认队列。芹菜不断退出。 $:docker-compose up启动tasker_rabbitmq_1启动tasker_celery_1附加到...
当我们用芹菜水平扩展时,我们正在经历芹菜的意外行为(增加我们的实例数量)。我们的任务当前处理时间只是......
我正在使用Django 2.0,Python 3.6和Celery 4.1在芹菜完成任务之后,我想执行一个在数据库中进行更新的代码。我怎样才能做到这一点 ?
使用django-celery-3.0.17,celery-3.0.21和django-1.5.1,我正在尝试监控链执行。我找到了一个解决方案,但对我来说似乎有点奇怪,所以我正在寻找一个更简单的解决方案......
我正面临芹菜的一个奇怪问题。有时celery进程是针对特定任务和工作者运行的,但实际上,它没有执行它应该执行的功能。我见过芹菜文件......
使用Celery和Python将输入和图像处理作业发送到多台机器
最近我一直在使用python 3.x在Ubuntu中玩芹菜和花(用于一台机器上的仪表板和任务可视化)。首先我安装了rabbitmq-server,radis,celery和...
总芹菜和django noob在这里,很抱歉,如果问题是微不足道的。基本上问题是@ app.task定义的任何函数都没有被celery处理,它只是正常运行,好像......