芹菜任务工人在生产中未更新
是指在芹菜任务工人系统中，某个任务工人在生产过程中没有及时更新任务的状态或进展情况。
芹菜任务工人是一种任务管理系统，用于协调和管理团队成员之间的任务分配和工作进展。它可以帮助团队成员更好地组织和分配任务，提高工作效率和协作能力。
当一个任务工人在生产中未更新时，可能会导致以下问题：
- 任务进度不可控：没有及时更新任务状态，团队其他成员无法了解任务的进展情况，导致整个项目的进度不可控。
- 工作重复或遗漏：其他成员可能会重复执行同一个任务，或者某些任务被遗漏，导致工作效率低下。
为了解决这个问题，可以采取以下措施：
- 提醒和监督机制：系统可以设置提醒和监督机制，定期向任务工人发送提醒，要求他们更新任务状态。同时，团队领导或项目经理可以监督任务的更新情况，并及时跟进。
- 自动化更新：可以通过技术手段实现任务状态的自动更新。例如，当任务工人完成某个任务时，系统可以自动更新任务状态，并通知相关成员。
- 激励机制：可以设置激励机制，鼓励任务工人及时更新任务状态。例如，可以给予任务工人一定的奖励或认可，以提高他们的积极性。
对于芹菜任务工人系统，腾讯云提供了一款名为"腾讯云·腾讯会议"的产品，它是一款集合了任务管理、团队协作、在线会议等功能的综合性工具。腾讯云·腾讯会议可以帮助团队更好地管理任务和协作，提高工作效率。
腾讯云·腾讯会议产品介绍链接地址：https://meeting.tencent.com/
相关·内容
3回答
有一个包含不同机器的集群，每个机器在指定的路径(~/celery_node/)中都有一个项目代码。一开始，集群中没有运行的芹菜工作进程。
问题#1:我如何在每台机器上启动一些芹菜工人，而不是登录到任何一台机器上，或者只是登录到一台机器上并在其他机器上启动芹菜工人？
问题#2:如果每台机器已经启动了一些芹菜工作进程，我如何在不远程登录的情况下重新启动它们？
浏览 1提问于2015-09-23得票数 0
3回答
当姜戈+芹菜离线时处理
、、、
我正试图找出如何处理芹菜在我的django项目，当它离线时，出于某种原因。
我在文档中发现了事件，所以我猜想当芹菜离线并通过电子邮件通知我的芹菜工人停工时，我可以以某种方式捕捉到这个事件。
我的问题是如何实施这种行为？有没有什么例子或Django应用程序？这就是我应该如何处理这些情况吗？
浏览 8提问于2015-12-28得票数 2
回答已采纳
1回答
如何检测故障并自动重启芹菜工人
、、、、
我在我的django支持的网站上使用Celery和Celerybeat。服务器操作系统为Ubuntu16.04。通过使用芹菜节拍，芹菜工人每10分钟完成一次工作。有时，工作人员在没有任何有用的日志消息或错误的情况下关闭。因此，我想找到一种方法来检测芹菜工人的状态(开/关)(不是拍子)，如果停止了，就自动重新启动它。我怎么能这么做？谢谢
浏览 1提问于2019-02-25得票数 3
在Django应用程序中运行使用芹菜任务的测试时，我不能完全测试需要从数据库获取数据的任务，因为它们没有连接到Django创建的测试数据库。
将芹菜中的设置为True部分解决了这个问题，但正如所说，这并不完全反映代码将如何在真正的芹菜工人上运行，也不适合测试。
在不设置task_always_eager = True的情况下运行Django测试时，如何使芹菜任务使用Django测试数据库
浏览 0提问于2017-02-05得票数 13
回答已采纳
我有两个服务器，每个服务器上有一个芹菜工人。我使用Redis作为经纪人，与工人合作。
我的问题是，如何使大多数情况下只运行一个员工，一旦该员工被破坏，另一个员工将作为备用工作人员启动？
基本上，只要把一个工人当作后援就行了。
在读取了文档之后，我知道如何通过工人上的队列分别将任务指定给特定的工作人员。
浏览 1提问于2019-07-20得票数 1
回答已采纳
1回答
我需要建立一个系统来处理两种类型的任务。一种类型可以自己创建更多任务，也可以创建另一种类型的任务。将有很少的工人(2-3)和只有一个主机。最重要的要求是系统应该很好地处理重新启动:即在重新启动时，正在进行的任务应该从头开始，而工作人员应该在重新启动之前收集排队的任务。从芹菜的角度看，它似乎适合这个用例。然而，我有几个问题：
1)芹菜能否如所述处理整个系统的重新启动？(芹菜+工人+经纪人，一切重新启动，完全停电)。
2)在这种情况下，最好的经纪人是什么？我更喜欢SQLAlchemy + SQLite，因为它更“自我包含”，但是如果RabbitMQ是正确的选择，考虑到需要优雅地处理完全重新启动，那
浏览 0提问于2015-04-20得票数 15
回答已采纳
因此，我有一个Django应用程序，它偶尔会向芹菜发送一个任务，以进行异步执行。我发现，当我在开发中处理代码时，Django开发服务器知道如何自动检测代码更改的时间，然后重新启动服务器，以便查看更改。然而，我的应用程序的RabbitMQ/Celery部分并没有注意到开发中的这些变化。如果我更改稍后将在芹菜任务中运行的代码，芹菜仍将继续运行旧版本的代码。只有这样，我才能让它得到的变化是：
阻止芹菜工人
停止RabbitMQ
复位RabbitMQ
启动RabbitMQ
将用户添加到我的Django应用程序配置为使用的RabbitMQ中
为该用户设置适当的权限
重新启动芹
浏览 2提问于2014-02-28得票数 14
回答已采纳
3回答
使用Celery ver.3.1.23，我试图动态地将计划任务添加到celery节拍中。我有一个芹菜工人和一个芹菜节拍实例在运行。
运行task.delay()触发一个标准的芹菜任务y工作正常。当我在配置中定义一个预定的周期性任务作为一个设置时，celery beat会运行它。
然而，我需要的是能够添加一个在运行时在指定的crontab上运行的任务。在将任务添加到persistent scheduler之后，celery节拍似乎没有检测到新添加的任务。我可以看到celery-schedule文件确实有一个包含新任务的条目。
代码：
scheduler = PersistentScheduler
浏览 2提问于2016-05-20得票数 9
1回答
这个问题是一个非常严重的内存泄漏，直到服务器崩溃(或者您可以通过杀死芹菜工人服务来恢复，该服务释放所使用的所有RAM )。
在这件事上似乎有一堆报告中的bug，但是在芹菜API文档中很少注意到这个警告。
警告:后端使用资源存储和传输结果。为了确保资源得到释放，最终必须在调用任务后返回的每个 AsyncResult实例上对上的每个AsyncResult实例进行调用get()或遗忘()。
可以合理地假定泄漏与此警告有关。
但是，根据我对芹菜的理解，概念上的问题是，AsyncResult实例是在用户会话中的多个Django视图中创建的:一些是在启动/生成一个视图中的新任务时创建的，另一些则是稍后手动
浏览 0提问于2019-02-25得票数 2
1回答
关于芹菜我没什么问题。请帮我一把。
我们需要把项目代码放在每个芹菜工人身上吗？如果是的话，如果我正在增加工作人员的数量，并且正在更新我的代码，那么在所有员工实例中更新代码的最佳方法是什么(而不每次都手动将代码推送到每个实例中)？
在芹菜工人中使用-Ofair作为参数，即使设置了PREFETCH_LIMIT=8 or so，也可以禁用工人的预取
重要事项: rabbitmq是将任务分配给工人，还是由工人从代理中提取任务？
在一个系统中有一个以上的芹菜工人(子进程和核数一样多)有意义吗？我看到很少有人在一个单一的系统中管理多个芹菜工人。
为了补充前面的问题，这两种场景之间的性能
浏览 0提问于2019-06-20得票数 3
我尝试了我能找到的所有东西，包括：
stackoverflow
Github问题
我从上面得到的是，如果我只使用芹菜和芹菜节拍，我必须在添加/删除任务后重新启动芹菜节拍。但是如果我组合了django-celery-beat就不需要重启它了。
我将一步一步地遵循：
from celery import Celery
from celery.schedules import crontab
app = Celery('tasks')
app.config_from_object('celeryconfig')
app.conf.timezone = '
浏览 0提问于2016-12-20得票数 14
2回答
芹菜节拍队列包含过时任务
、、、、
我在Django中使用定期芹菜任务。我过去在app/tasks.py文件中有以下任务：
@periodic_task(run_every=timedelta(minutes=2))
def stuff():
...
但是现在这个任务已经从我的app/tasks.py文件中删除了。然而，我一直在我的芹菜日志中看到对此任务的调用：
[2013-05-21 07:08:37,963: ERROR/MainProcess] Received unregistered task of type u'app.tasks.stuff'.
我使用的芹菜节拍调度器似乎没有更新它的队列。下面是
浏览 5提问于2013-05-21得票数 8
1回答
我正在学习芹菜，我想问：
是让芹菜在Ubuntu中启动时自动运行的最简单的方法。现在，我通过终端手动启动celery -A {prj name} worker -l INFO。可以进行任何类型的配置，这样芹菜就可以捕捉tasks.py代码中的变化，而无需重新启动芹菜。现在，每当我在ctrl+c代码中更改某些内容时，我都会输入celery -A {prj name} worker -l INFO。如果我能自动启动芹菜，==>需要重新启动Ubuntu而不是，我可以预见这种方法在生产中会出现问题。
(安装程序: VPS，Django，Ubuntu18.10(没有码头)，没有外部资源，使用Red
浏览 1提问于2020-11-19得票数 0
回答已采纳
我已经创建了一个芹菜工人与一个单一的芹菜节拍调度任务，运行时间间隔为5秒。如何在不停止的情况下，动态地向芹菜工人添加另一个节拍任务？
示例
app.conf.update(
CELERY_TASK_RESULT_EXPIRES=3600,
CELERY_TIMEZONE = 'UTC',
CELERYBEAT_SCHEDULE = {
'long-run-5-secs': {
'task': 'test_proj.tasks.test',
'schedule'
浏览 13提问于2015-11-13得票数 6
回答已采纳
1回答
姜戈芹菜工人没有接受任务
、、、、
每当我管理芹菜工人时，我都会收到警告。
./manage.py celery worker -l info --concurrency=8
如果我忽视了这个警告，那么我的芹菜工人就没有收到芹菜的任务。
在之后，我也更改了工人的名字，但是这次我没有收到警告，但是芹菜工人仍然没有收到芹菜的预定任务。
我已经检查了芹菜的节拍记录，以及芹菜节拍的时间安排。
我还检查了芹菜花，它显示了两个工人和第一个工人正在接收任务而没有执行任务，如何把所有的任务都交给第二个工人呢？或者我怎样才能让第一个工匠停用，我所缺少的芹菜是什么？
我的django settings.py
RABBITMQ_USERNA
浏览 5提问于2017-05-12得票数 1
回答已采纳
1回答
我想把django和芹菜结合起来。
因此，我遇到了autodiscover_tasks()，我不完全确定如何使用它们。芹菜工人得到其他应用程序添加的任务(在本例中是节点后端)。
到目前为止，我用这个来启动这个工人：
celery worker -Q extraction --hostname=extraction_worker
效果很好。
现在我不知道django-芹菜集成的总体想法是什么。工作人员仍然是从外部启动(例如，使用上面的命令)，还是应该从django应用程序中管理和启动他们？
我的celery.py看起来像：
# set the default Django settings mo
浏览 0提问于2020-05-29得票数 0
回答已采纳
1回答
芹菜如何进行蓝绿调配？
、、、
我在担心芹菜的部署。
所以我正在寻找安全的部署，比如芹菜的蓝绿色部署。
但是对芹菜来说这是可能的吗？如果芹菜工人在执行任务的过程中被杀死(分离)，该任务可能会失败。或者另一个工人试图捕获失败的任务，检测到芹菜工人被杀死(分离)？
有没有人尝试安全地部署celery worker代码？
浏览 0提问于2015-08-24得票数 0
2回答
我使用的是 + RabbitMQ。
当芹菜工人不可用时，所有任务都在RabbitMQ中等待。
就像它在线一样，所有这些任务都会立即执行。
我能以某种方式阻止它的发生吗？
例如，有100个(相同的)任务在等待芹菜工人，当芹菜工人上线时，我可以只执行其中的一个吗？
浏览 1提问于2014-10-25得票数 0
1回答
因此，我们有一个库伯内特斯集群运行一些豆荚与芹菜工人。我们正在使用python3.6运行这些工作人员，芹菜版本为3.1.2 (我知道，非常老，我们正在对其进行升级)。我们还设置了一些自动标度机制，以增加更多的芹菜工人的飞行。
问题如下。那么，假设我们有5名工人在任何给定的时间。随后出现了许多任务，增加了吊舱的CPU/RAM使用量。这引发了一个自动标度事件，例如，又增加了两个芹菜工人吊舱。所以现在这两个新来的芹菜工人要做一些长时间的工作。在完成这些任务之前，kubernetes创建了一个降级事件，杀死了这两个工作人员，也杀死了那些长期运行的任务。
此外，由于遗留的原因，如果任务没有完成，我们就没
浏览 7提问于2022-08-02得票数 3
回答已采纳
2回答
我有芹菜任务，100输入数据在队列中，需要执行使用5名工人。
如何获得哪个工作人员正在执行哪个输入？
每个工人执行多少输入和它的状态？
如果任何任务失败，如何单独获得失败的输入数据并与可用的工作人员一起重新执行？
是否有任何可能的方法来定制芹菜根据工人的具体情况。
我们可以把芹菜工人限制和花结合起来。
我没有使用任何框架。
浏览 3提问于2016-01-12得票数 3
我正在做一些NLP工作，还有一些模型是由Tensorflow培训的。我提供了一些API来使用这些模型来完成word裁剪，并通过芹菜发送请求。
具体情况如下：
芹菜将把任务分派给不同的工人(大约4-5人)，因此每个工人必须加载上述模型，因此内存将被占用很多。
，那么，有什么方法在工人之间分享模型吗？，我不知道芹菜工人的潜在机制。
谢谢
浏览 4提问于2017-06-05得票数 3
回答已采纳
我有两个系统的服务，一个负责处理我的芹菜工人(10个排队等待不同的任务)和一个处理芹菜拍打。
部署新代码后，我重新启动芹菜工人服务，以获得新任务并更新芹菜作业。
我应该重新开始芹菜拍打与芹菜工人的服务吗？
还是自动获得新任务？
浏览 1提问于2017-12-08得票数 1
回答已采纳
2回答
我有芹菜课的任务
from celery import Task
from django.db import transaction
from config import celery_app
class RefreshData(Task):
name = "refresh-data"
@transaction.atomic
def run(self, *args, **kwargs):
SomeClass().some_fuc()
celery_app.register_task(RefreshData)
现在我想以同步模式(
浏览 4提问于2022-02-17得票数 0
回答已采纳
假设我有三台服务器A，B & C，服务器C将有芹菜任务代码，我需要从服务器A&B执行它们。
从芹菜中，我看到有一个作为芹菜工人运行的task.py文件
from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
然后我们有另一个python文件(比方说client.py)，它调用这些任务。
from tasks import add
add.dela
浏览 1提问于2020-04-22得票数 5
回答已采纳
1回答
我有一个Django项目，并安装了Celery + RabbitMQ来异步执行繁重的任务。当我调用任务时，RabbitMQ管理员显示任务，芹菜打印任务被接收，但任务没有执行。
以下是任务的代码：
@app.task
def dummy_task():
print("I'm Here")
User.objects.create(username="User1")
return "User1 Created!"
从这个角度来看，我把任务交给芹菜：
def task_view(request):
result
浏览 3提问于2022-08-22得票数 2
回答已采纳
2回答
在ECS法门操作芹菜工人
、、、、
我正在做一个使用AWS ECS的项目。我想使用芹菜作为分布式任务队列。芹菜工人可以建立为EC2类型，但由于实例处于空闲状态的时间很长，我认为AWS运行该工作并立即退出将具有成本效益。
您对如何在AWS云中有效地使用芹菜工人有建议吗？
浏览 0提问于2018-11-09得票数 5
回答已采纳
1回答
我正在构建一个Flask应用程序，在这里，我希望在运行Flask应用程序之后启动一些异步后台任务。我一直在阅读有关酒瓶和芹菜的例子和手册，例如，但是在许多例子中，芹菜背景任务被绑定到Flask路由函数。也就是说，当从客户端收到对特定URL绑定的Flask函数的请求时，才会运行芹菜后台函数。
我想要的，除了这一点，是有芹菜背景任务开始时，瓶应用程序运行。我在这篇文章中创建了一个最小的工作示例(myapp.py，烧瓶+芹菜+ RabbitMQ)：
from flask import Flask
from celery import Celery
import time
app = Flask(_
浏览 4提问于2021-05-23得票数 0
回答已采纳
1回答
我有一个芹菜工人需要部署到谷歌应用引擎，这有可能吗？我打算为我的主Django应用程序使用一个应用程序，一个用于芹菜工人的应用程序和一个Rabbitmq服务(它由Google云支持)
浏览 3提问于2019-11-15得票数 6
回答已采纳
1回答
我希望即使没有芹菜工人也能执行芹菜任务。该芹菜任务应该像普通函数一样工作，并且无论如何都会被执行。
浏览 37提问于2020-06-18得票数 0
1回答
我有一个芹菜经纪人和几个芹菜工人，他们都和rabbitMQ沟通。在我的设置中，我向我的芹菜工人发送了几个任务，他们将处理所有的任务(需要大约1个小时)，然后我将手动终止我的芹菜工人。 我想要转向这样一种系统:如果一个芹菜工作者id 'idle‘(我将其定义为:在timeout_seconds的一段时间内有0个活动任务，我将预先定义)，则该工作者将被程序化地终止。所有工作者都将有大约相同数量的任务要运行，并且都将在同一时间处于“空闲”状态。 我已经设置了可以终止工人的代码，但我不确定如何检测工人是否“空闲”并准备终止。我想我想使用signal，但它看起来并不符合我的要求
浏览 17提问于2020-09-01得票数 1
我有一个django项目，在这个项目中，我使用芹菜和rabbitmq来执行一组异步。任务。所以我计划的设置是这样的。
Django应用程序运行在一台服务器上。
芹菜工人和兔子从另一台服务器上跑。
我最初的问题是，如何从位于另一个服务器上的芹菜任务中访问django模型？
假设我无法访问Django模型，那么一旦任务完成，我是否可以向Django应用程序发送一个回调，传递值，以便根据传递的值更新Django的数据库？
浏览 3提问于2016-08-18得票数 5
要获取芹菜任务的信息，我需要task_id。当手工启动芹菜任务时，我可以使用task.id轻松地获得此任务的id (并将其写入DB或执行其他操作)。如果我用芹菜打，它会定期地把任务交给工人，那似乎是不可能的。
所以我的问题是，如何从任务中得到id，拍打把任务发送给芹菜的工人？
当工作人员接收到任务时，控制台将显示任务id。所以我担心的是，在任务被敲打发送给工人的那一刻，它没有任务id。
获得task_id的手动案例：
task = tasks.LongRunningTask.delay(username_from_formTargetsLaden, password_from_formTarg
浏览 0提问于2019-06-27得票数 3
回答已采纳
1回答
我有一个Django应用程序和一个芹菜工人-每个运行在它自己的服务器上。目前，Django应用程序使用SQLite存储数据。我想使用Django的ORM从工人那里访问数据库。不幸的是，我并不完全清楚，因此我有一些问题。
有没有可能没有黑客/解决办法？我希望有一个简单的解决方案(我不想实现REST接口来访问对象)。我想，如果我开始使用可以从两个服务器访问的PostgreSQL实例，就可以实现这一点。
工人的机器上需要哪些项目文件(只有Django + tasks.py文件)？
你能给我提供一个例子或教程吗？我试着查了一下，但发现只是一些教程/答案，这些都是当地芹菜工人的问题。
浏览 5提问于2019-01-30得票数 0
2回答
我正在运行一个芹菜+ rabbitmq应用程序。我启动了一堆ec2机器，但我发现我的芹菜工人机器只使用了大约15%的cpu (峰值为20%)。我已经为每台机器配置了2个芹菜工人。
芹菜工人不应该接近使用100%的CPU利用率吗？
更多信息:我没有使用celery --concurrency选项或eventlet，尽管我使用了多个worker。默认情况下，并发设置为8。我的任务在php中运行，主要是io阻塞，所以如果我们有更多的进程并行运行也不会有问题。有没有办法将celery配置为根据CPU使用率运行更多的任务
浏览 4提问于2019-10-18得票数 2
1回答
我需要实施一个系统，其功能如下：
将数据传输到远程位置。
数据完全传输后，在远程服务器上开始计算。
计算完成后，将得到的计算数据返回到源。
用于跟踪/编辑每个任务的进度的web界面。
我正在考虑使用: 1. Rails 4) 2.芹菜作为分布式解决方案。3. Zmq将消息传递给RoR应用程序，并在芹菜中的不同“类别”之间传递消息，如下所述。
为了使这些部件相互分离，我正在考虑有3组芹菜工人，每一组都属于一个单独的类别:- A。“同步”工人，B。‘'Render’工人，和C.“费奇”工人。
我想使用zmq子或广播模型在这些工作人员和web应用程序之间传递消息，以便
浏览 1提问于2014-11-14得票数 0
1回答
我正在使用芹菜作为我的网络应用程序。芹菜执行父任务，然后执行更多的任务。
芹菜问题
我无法从luigi获得依赖关系图和可视化工具来查看我的父任务的状态
芹菜不提供机制重新启动失败的管道，并从失败的地方开始。
这两件事我很容易从路易吉那里得到。
所以我在想，一旦芹菜执行了父任务，然后在这个任务中执行Luigi管道。
这会有什么问题吗?我需要根据队列大小自动调整芹菜工人的规模。这会影响到多台机器上的任何luigi员工吗？
浏览 1提问于2016-05-05得票数 3
回答已采纳
1回答
我试图将动态工作流引入到我的领域中，这涉及到不同模型推断的多个步骤，其中一个模型的输出被输入到另一个model.Currently中，很少有芹菜工作人员分散在主机上来管理推理链。随着复杂性的增加，我们正在尝试动态地构建工作流。为此，我得到了一个动态DAG设置和塞勒伊执行器工作。现在，有什么办法我可以保留目前的芹菜设置和路线气流驱动的任务给相同的工人？我理解这些工作人员中的设置应该可以访问DAG文件夹和环境，与气流服务器相同。我想知道如何在这些服务器中启动芹菜工人，这样气流就可以从python应用程序的手动工作流中执行相同的任务。如果使用命令“气流芹菜工人”启动员工，则无法访问应用程序任务。如果
浏览 5提问于2021-05-27得票数 1
回答已采纳
2回答
我有API代码，它将任务添加到队列中，然后使用这些任务的芹菜工人。
目前，我有两个代码库相同。但是我希望芹菜工人只需要简单的Python任务，而没有django代码，因为工人只需要处理任务，而不需要django。有可能。
为了启动芹菜工人，我需要使用这一行。
celery -A django_project worker --queue high
我应该写什么而不是django_project
浏览 2提问于2016-05-03得票数 10
回答已采纳
2回答
码头使用标签影响启动顺序
、、、、
我的Django应用程序使用芹菜定期处理任务。可悲的是，这导致了3个连续的(应用程序，芹菜工人，芹菜拍打)他们每一个有一个非常自己的启动外壳脚本，而不是一个码头入口点脚本。因此，我的想法是有一个入口点脚本，它能够处理我在我的码头输入的实验室--Compose.yml。根据标签容器应该开始作为应用程序，芹菜拍打或芹菜工人实例。我以前从未做过这样的实现，但我问自己，这是否可能，因为我在trafik加载器项目中看到了类似的东西，例如：
loadbalancer:
image: traefik:1.7
command: --docker
ports:
- 80:
浏览 0提问于2020-04-19得票数 1
回答已采纳
1回答
我在分发姜戈和芹菜。
我用Django和芹菜做了一个小项目。Django将要求芹菜工人对数据库中的一些数据进行处理。然后将数据传回Django。
我的想法是：
在一台服务器上安装Django堆栈
一台服务器上的消息队列(RabbitMQ)
芹菜工人在一台服务器上
因此，共计3台服务器
然而，问题是芹菜必须使用Django的一些代码，例如模型，因为它访问模型。因此，它还需要settings.py文件来知道什么是服务器。
这是否意味着对于#3，我需要在服务器上安装Django和芹菜，但是禁用Django而只运行芹菜？例如，芹菜-A PROJECT_NAME worker -l信
浏览 2提问于2014-12-15得票数 5
回答已采纳
2回答
多名芹菜远程工人
、、
这个问题是关于在不同的机器上使用多个远程芹菜工人。应用程序的实现可以概念化为：
我的应用程序(生产者)将每5分钟向队列中添加多个任务(比如50个任务)(假设每隔5分钟就有一个用于循环的python循环迭代将要异步执行的任务列表)。我想要芹菜工人(这将是远程机器)在这些任务被推举后尽快完成。
我的问题是，芹菜/拉比My是否会自动处理任务分发(因此，没有工人从队列中捡起一个已经被工人捕获的任务--即确保工作不会重复)并均匀地分配任务，这样就没有工人在其他工人努力工作时懒散地工作了，或者必须在设置中配置/编程这些任务吗？*？
如果有人能转发给我相关的文档，我会非常感激的(我正在查看芹菜文档
浏览 0提问于2017-10-30得票数 3
2回答
我愿意将任务从web服务器(运行Django)发送到一个远程机器，该机器保存着Rabbitmq服务器和一些我用芹菜实现的工作人员。
如果我遵循芹菜的方式，似乎我必须在两台机器之间共享代码，这意味着复制web应用程序代码中的工作人员逻辑代码。
所以：
这样做有什么最佳做法吗？由于代码是多余的，所以我正在考虑使用git子模块(在web应用程序代码repo中复制的=>，以及工人代码回购)。
那我是不是应该用点芹菜以外的东西呢？
我是不是遗漏了什么？
浏览 6提问于2015-02-18得票数 1
5回答
我有一个用芹菜做的项目。我周期性地遇到这样一种情况:我的请求正在向芹菜发出，但是任务并没有被传递给工人，而是服务器只是返回了一个500错误。
当我重新开始芹菜的时候，它又开始工作了。我只是猜测这个工人被绞死了，这样就没有工人了。如果我启动了另一批工人，请求就会重新开始工作(这支持了我的理论)。
问题：
我了解芹菜在默认情况下原木为stderr。我没有看到任何错误，所以我希望有另一个芹菜原木某处。那会在哪呢？
有没有办法查找工人的状况？有空房吗？挂起来了吗？
还能有别的事吗？
浏览 6提问于2016-04-12得票数 4
回答已采纳
1回答
我正在用芹菜框架编写一个应用程序。我的一些任务相当重量级，可以执行很长时间。
我注意到，当我运行5-6个工人，然后把10-20个任务随机分配给工人时，有时如果一个人没有任务，它就不会开始剩下的任务，只有在他们完成任务时(可能在几小时内)，他们才会被其他人处理。如果我此时再运行一个工人-它什么也不做，但可以接受新的任务。
它是一个bug还是一个特性，我如何解决我的需求？当我们有自由工人而不开始工作的时候，等待几个小时是没有意义的。
浏览 3提问于2016-10-03得票数 2
回答已采纳
1回答
芹菜比多进程慢？
、、
我有两台电脑，c1和c2。c1是双核处理器，c2是四核处理器。因此，我使用6个工人将这两台计算机与芹菜连接起来，以完成一些任务。然而，当我在c1中使用6个工作进程的多处理时，似乎芹菜中的每个工作进程在多处理中都较慢？为什么会这样呢？那么与多进程相比，芹菜的优势是什么呢？
例如：
我有一个函数：
def readFromHBase(inputData):
...
return data
我使用芹菜和多进程从100000个样本中读取了1,000个文件。
在芹菜中，我设置了6个工人跨越两台计算机c1和c2，如上所述。每个工人将读取10个文件，直到1000个文件
浏览 2提问于2013-07-02得票数 2
2回答
芹菜:了解全局
、、、
芹菜似乎是一个很好的工具，但我很难理解各种芹菜成分是如何协同工作的：
工人们
应用程序
任务
消息代理(如RabbitMQ)
据我所知，命令行：
celery -A not-clear-what-this-option-is worker
应该运行某种芹菜“工人服务器”，它本身需要连接到代理服务器(我不太确定为什么需要这么多服务器)。
然后，在任何python代码中，可以通过实例化应用程序将一些任务发送给工作人员：
app = Celery('my_module', broker='pyamqp://guest@localhost//')
浏览 3提问于2017-03-07得票数 4
2回答
对于django项目，我喜欢运行由芹菜工人更新的索引，以避免达到页面解析时间。我注意到芹菜-干草堆可以做到这一点，但我想知道为什么它是如此复杂。一种简单得多的解决方案是简单地从post_save信号应用异步任务并从那里调用信号处理器，因此不是从信号处理器内部而是在信号处理器之前应用异步部分。
我猜我漏掉了什么？
我知道在delete信号的情况下，实例可能不再存在...
浏览 2提问于2017-05-03得票数 3
3回答
我正在尝试测试Django应用程序的功能。
我的一些任务是用芹菜。
如何使用PyCharm在测试环境中运行芹菜？
浏览 4提问于2019-09-29得票数 1
回答已采纳
在这个项目中，我尝试轮询一个长期运行的任务的task.state并更新它的运行状态。它在开发中工作，但是当我将项目移动到生产服务器上时，它就不能工作了。我一直在“等待”，甚至我可以看到任务从花开始。但是，当任务完成时，我仍然可以得到更新的结果，这是在task.state ==的“成功”时进行的。我在生产中使用python2.6、Django 1.6和芹菜3.1，结果是后端AMQP。
@csrf_exempt
def poll_state(request):
data = 'Fail'
if request.is_ajax():
if &
浏览 8提问于2014-07-01得票数 8
回答已采纳
1回答
我对芹菜有一个问题:从某一点(芹菜工人的日志没有显示根本原因)，所有的任务(每5分钟由赛利拍安排)都被工人撤销和丢弃。
在赛利波和赛利(工人)的日志中没有任何线索可以说明为什么会发生这种情况。我注意到，从某一点开始，1/ 50任务被撤销，被撤销任务的频率不断上升，直到24小时后所有任务都被系统地撤销。
我使用Redis作为代理，问题发生在Linux部署芹菜上。
你知道问题的起因是什么吗？如果你需要更多的信息，不要犹豫问！
浏览 5提问于2015-10-27得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
