芹菜:一次执行一个任务
芹菜是一种蔬菜，它在云计算领域中没有特定的概念或应用场景。然而，我们可以将芹菜的特点与云计算中的一些概念进行类比。
芹菜一次执行一个任务，这可以与云计算中的任务调度和并行计算概念相关联。在云计算中，任务调度是指将任务分配给不同的计算资源进行处理的过程。类似于芹菜一次执行一个任务，云计算中的任务调度可以将多个任务分配给不同的计算节点并行执行，以提高计算效率和性能。
此外，芹菜的一次执行一个任务也可以与云计算中的容器技术相关联。容器是一种轻量级的虚拟化技术，可以将应用程序及其依赖项打包成一个独立的运行环境。类似于芹菜一次执行一个任务，容器技术可以将应用程序按照任务的粒度进行划分和执行，实现更高效的资源利用和任务管理。
在腾讯云的产品中，与任务调度和容器技术相关的产品包括：
- 云批量计算（https://cloud.tencent.com/product/bc）：提供高性能、高可靠的批量计算服务，支持任务调度和并行计算，适用于大规模计算任务的处理。
- 云原生容器服务（https://cloud.tencent.com/product/tke）：基于Kubernetes的容器管理平台，提供弹性伸缩、高可用性和自动化运维等功能，适用于容器化应用的部署和管理。
需要注意的是，以上产品仅作为示例，具体的选择应根据实际需求和场景进行评估。
相关·内容
重新启动芹菜会导致所有周期性任务(芹菜节拍时间表)重新设置，并从芹菜重新启动的时间开始，还是保留计划？
例如，假设我有一个每天下午12点执行的周期性任务。现在我下午3点重新开始芹菜。这个周期性的任务会被重置为每天下午3点运行吗？
浏览 1提问于2021-10-13得票数 0
回答已采纳
1回答
我安排了每三个小时一次的芹菜节拍任务：
'sync_stuff': {
'task': 'celery_tasks.sync_stuff',
'schedule': crontab(hour='*/3')
}
有时，完成任务需要超过3个小时，我希望确保在旧实例仍在运行时，芹菜不会再次调度和运行任务。
在芹菜或芹菜的背景下，有什么方法可以做到吗？
浏览 0提问于2019-07-01得票数 8
回答已采纳
1回答
我使用节点-芹菜来实现芹菜和狂犬病。
就像芹菜一样，我们定义任务，然后推动它们。
我在tasks.py中定义的任务如下：
import os
import logging
from celery import Celery
import requests
backend = os.getenv('CELERY_BACKEND_URL', 'amqp')
celery = Celery('tasks', backend=backend)
celery.conf.update(
CELERY_RESULT_SERIALIZER='
浏览 5提问于2017-03-16得票数 1
我正在处理芹菜时间表任务，遇到了一个问题。 假设有一个计划任务每5分钟运行一次。 这个任务可以在我的一些API中手动执行， 我总是希望这个任务的间隔是5分钟。 例如，如果该任务在8:00自动执行， 在8:01，我第二次执行了这个任务， 现在我希望下一次芹菜自动运行的时间是8:06。 那么有没有办法在芹菜中做到这一点呢？
浏览 12提问于2020-08-21得票数 0
回答已采纳
我是异步任务的新手，我正在使用django-celery，并希望使用django-celery-beat来调度周期性任务。
然而，看起来芹菜节拍并不能接受一次性的任务。我是否需要两个芹菜实例，一个作为工人，一个作为一个关闭任务，另一个作为节拍，用于计划任务才能正常工作？
浏览 8提问于2019-07-05得票数 1
1回答
看来芹菜(v4.1)既可用于某些任务的预取，也可用于CELERY_ACKS_LATE=True (讨论)。
我们目前使用的是CELERY_ACKS_LATE=False和CELERYD_PREFETCH_MULTIPLIER=1
在这两种情况下，兔子中都有未被确认的信息。
有时，我们会遇到网络问题，导致芹菜与兔子失去连接几秒钟，收到以下警告：consumer: Connection to broker lost. Trying to re-establish the connection...
当发生这种情况时，未被确认的消息将返回到Ready，这似乎是标准行为，并且正在被另一个消费者使用。
浏览 1提问于2018-01-12得票数 1
1回答
我正在使用django开发web应用程序，我使用芹菜在后台运行任务。一切都很好，但我有一个问题，我想要运行芹菜任务的具体时间，如下午2点至下午3点。
浏览 1提问于2020-02-09得票数 2
回答已采纳
2回答
我使用的是 + RabbitMQ。
当芹菜工人不可用时，所有任务都在RabbitMQ中等待。
就像它在线一样，所有这些任务都会立即执行。
我能以某种方式阻止它的发生吗？
例如，有100个(相同的)任务在等待芹菜工人，当芹菜工人上线时，我可以只执行其中的一个吗？
浏览 1提问于2014-10-25得票数 0
我有一个芹菜应用程序，它使用redis作为代理，我可以使用以下命令获取应用程序的统计数据
芹菜-A test.celeryapp检查统计数据
这给了我一些数字如下所示
"total": {
"test.celerytasks._generate_data": 14493666,
"test.celerytasks.cleanup_data": 14493,
}
这些数字描述了这些任务从day1执行了这么多次吗？如何理解这些结果
我应该如何获得在过去1小时/天内处理的芹菜任务的数量？我能得到最后一小时/天的
浏览 4提问于2022-03-23得票数 0
1回答
几天来，我一直在寻找一种实际的方法来处理芹菜任务中的错误。
在芹菜文档中，我们确实了解到了。
重要的是要注意的是，工作人员不知道会崩溃，如果是这样的话，通常是一个无法恢复的错误，需要人工干预(工作者中的错误，或者任务代码)。
..。
因此，对Python使用retry，如果您的任务是幂等的，那么如果需要这样的可靠性级别，就将它与acks_late结合起来。
但是，如果我的任务因为逻辑错误而有缺陷，那么盲目地重新尝试并不能解决问题。
在其他分布式系统中，我使用poison queue存储消息，然后在错误修复后重新处理。用于路由的芹菜文档非常健壮，使我相信类似的方法可以用芹菜手工完
浏览 3提问于2013-04-07得票数 2
回答已采纳
1回答
我正在使用Django和芹菜：
在celery.py中，我有：
app.conf.beat_schedule = {
'send_notes_email': {
'task': 'send_notes_email_async',
'schedule': crontab(minute=3),
},
}
任务设置完成：
@app.task(bind=True, name='send_notes_email_async', max_retries=3)
def send_
浏览 17提问于2018-09-05得票数 0
我有一个Dockerrun.aws.json文件，它使用Beanstalk多容器在EC2实例上部署芹菜容器。
在每个部署中，默认情况下，Beanstalk或ECS代理将杀死所有实例上的现有芹菜容器，然后创建一个新的芹菜容器。这会不成熟地杀死芹菜任务，这会产生问题，因为任务无法完成。
芹菜容器有supervisord，它实际上监视芹菜过程，并在芹菜关闭时将其调出。
有人能建议我们如何通过允许芹菜容器/进程完成他们已经从SQS中消耗的任务来优雅地杀死它们吗？
浏览 1提问于2019-01-03得票数 0
1回答
我正在使用芹菜处理Django应用程序中的异步任务。大多数任务都很短，几秒钟内就能完成，但我有一项任务可能需要几个小时。
由于服务器上的处理限制，芹菜被配置为一次只运行两个任务。这意味着，如果有人启动两个长期运行的任务，它会有效地封锁所有其他芹菜加工站点长达几个小时，这是非常糟糕的。
是否有任何方法配置芹菜，使其一次只处理一种任务？类似于：
@task(max_running_instances=1)
def my_really_long_task():
for i in range(1000000000):
time.sleep(6000)
注意，我不想取消my_re
浏览 1提问于2017-05-15得票数 1
回答已采纳
2回答
如何配置芹菜任务
、、、、
我在一个项目中使用了Celery，我将它作为一个调度器(作为周期性任务)。
我的芹菜任务如下所示：
@periodic_task(run_every=timedelta(seconds=300))
def update_all_feed():
feed_1()
feed_2()
...........
feed_n()
但是随着提要数量的增加，到达其他提要需要很长时间(例如，当芹菜使用提要编号n时，需要很长时间才能到达下一个提要(n+1)。我想使用Celery的并发性来启动多个提要。
看完文档后，我发现我可以调用一个芹菜任务，如下所示：
feed.delay()
浏览 2提问于2014-10-27得票数 1
我有一个django项目，有几个芹菜任务。此外，我还有几个测试(使用django TestCase)，我正在模拟芹菜任务。我不想在考试中跑芹菜。
我在网上搜索了很多，但没有运气。所以我想问:有没有办法不去模拟这些函数，并在django运行服务器中执行任务代码呢？
更多信息(我现在不能更新)：
python 2.7 django 1.11 芹菜4.3
非常感谢你的帮助！)
浏览 0提问于2020-03-18得票数 0
1回答
在我的项目中，我有一个芹菜任务，它每30秒由芹菜节拍发送给工人。我想知道芹菜是如何执行芹菜任务的？无论是为每个任务产生一个新线程，还是为task.How产生一个新工作线程，我们都可以知道任务是否完成并从我正在使用RabbitMQ的message broker队列中删除。
浏览 1提问于2017-10-30得票数 1
1回答
我必须从数据库(Oracle)调用一些存储过程。我用芹菜和红葡萄酒以异步的方式称呼这个SP。
tasks.py
@task
def carga_ftp():
tabla = Proc_Carga()
sp = tabla.carga()
return None
@task
def conci(idprov,pfecha):
conci = Buscar_Conci()
spconc = conci.buscarcon(idprov,pfecha)
return None
我需要为每个任务指定不同的并发。对于任务CONCI，我需要1的并发性，对于
浏览 0提问于2015-04-16得票数 2
回答已采纳
我在经营姜戈，芹菜和RabbitMQ。我试图实现的是确保与一个用户相关的任务按顺序执行(具体来说，当时的一个任务，我不希望每个用户任务并发)。
每当为用户添加新任务时，都应该依赖于最近添加的任务。如果此类型的任务已为此用户排队，且尚未启动，则其他功能可能包括不向队列中添加任务。
我做了一些研究然后：
我无法找到将新创建的任务与芹菜中已经排队的任务连接起来的方法，链似乎只能链接新任务。
我认为这两种功能都可以使用自定义RabbitMQ消息处理程序实现，尽管编写代码毕竟很困难。
我还读过关于芹菜-任务树的文章，这可能是确保执行顺序的最简单方法，但是如何将新任务与已经"
浏览 2提问于2015-04-30得票数 19
我目前正在开发一个具有以下配置的应用程序：
Django 1.8
Python2.7
芹菜3.1.x (Amazon作为borker )
目前，我正在运行多个芹菜，每个芹菜的并发性= 4。因此，我的问题是，当我在代码中调用芹菜()时，任务在我的worker中开始执行几乎需要5到10秒。
我想知道，为什么我要得到这个延迟，以及如何减少，这样我就可以像调用delay()那样立即完成任务。
我使用RabbitMQ进行了同样的检查，并且我可以看到，当我调用delay()时，这些任务就开始执行。
提前谢谢
浏览 1提问于2017-01-11得票数 1
1回答
我正在尝试使用芹菜3.1从自定义管理命令运行一个任务。
如果我从视图中调用我的任务，它可以正常工作，但是当从我的管理命令启动相同的任务时，任务将只在当前上下文中同步运行(而不是通过芹菜异步运行)。
我没有装芹菜。
要在命令行上获得异步任务处理，需要向管理命令中添加什么？
浏览 0提问于2015-12-16得票数 1
回答已采纳
2回答
芹菜配送队伍与工人
、、、、
我对芹菜很陌生，我正在努力了解排队是如何工作的。如果我有两个任务，比如task1和task2，我把它们放在不同的队列中，在task1上我只使用一个工人，而在task2上我使用多个工作，task1一次只运行一个，因为我只有一个工作人员？task2运行的次数会和我的员工一样多吗？我的理解正确吗？
浏览 0提问于2018-12-26得票数 3
回答已采纳
1回答
芹菜工人只工作一次
、、、
全面步骤：
启动django
找个芹菜工人
python manage.py芹菜工人--app=芹菜工人:app -Ofair -n W1
上载url列表文件，循环url列表将每个url发送到任务fetch_article
工人工作
上传另一个url列表文件
工人不采取行动
views.py：
@csrf_exempt
def upload(request):
job_name = request.POST.get('job_name')
if not job_name:
return JsonResponse(
浏览 0提问于2015-07-01得票数 0
回答已采纳
2回答
我可能不正确地使用芹菜。但是我正在开发的聊天机器人需要用于异步任务的带有redis的芹菜。这是我使用的框架：。
我的特定用例目前要求我运行一个芹菜任务 currently ，并在这两者之间等待一些任意时间，从30分钟到3天不等。就像这样
@celery.task
def myAsyncMethod():
while true:
timeToWait = getTimeToNextAlarm()
sleep(timeToWait)
sendOutMessages()
基本上，我有一个不存在的异步进程。我很确定不应该用这种芹菜。因此，我的问题
浏览 3提问于2017-07-27得票数 4
回答已采纳
2回答
我把芹菜分成以下几个部分
芹菜
芹菜工
芹菜守护进程
经纪人: Rabbimq或SQS
队列
结果后端
芹菜监测器(花卉)
我的理解
当我在django e执行芹菜任务时，g tasks.add(1,2)。然后芹菜把这个任务添加到队列中。我很困惑上面列出的是4还是5
WHen任务进入队列，然后worker获取该任务并从队列中删除
该任务的结果保存在结果后端。
我的困惑
芹菜守护进程和芹菜工人之间有什么区别？
是Rabbitmq在做队列的工作。这是否意味着任务保存在Rabitmq或SQS中？
花是做什么的。它是否监视工作人员、任
浏览 5提问于2016-04-26得票数 1
1回答
是否可以使用芹菜设置多个更新任务，在Django/Heroku上仅在一个工作人员上同时运行？如果我将某些函数安排为每5分钟运行一次，它们将在开始运行时自动重叠，还是等待所有其他任务完成？我对芹菜很陌生，坦率地说，我对芹菜能做什么感到困惑。)
浏览 1提问于2012-10-01得票数 2
2回答
我有一个芹菜任务，它接收来自SQS队列的消息并尝试运行它。如果失败，应该每10秒至少重试144次。我认为正在发生的事情是，它失败并重新进入队列，同时创建一个新的队列，将其复制到2。这2次再次失败，并遵循相同的模式创建2个新消息，总共变成4个消息。因此，如果我让它运行一段时间，队列就会阻塞。
我没有得到的是正确的方式，重新尝试它，而不重复。下面是重试的代码。请看是否有人能带我到这里来。
from celery import shared_task
from celery.exceptions import MaxRetriesExceededError
@shared_task
def se
浏览 8提问于2016-05-04得票数 4
这是一个一般性的问题，我寻求答案，因为我看到了一个芹菜任务，从我的公司代码库从以前的雇员。
这是一个共享任务，它调用一个端点，如
@shared_task(time_limit=60*60)
def celery_task_here(some_args):
data = get_data(user, url, server_name)
# some other logic to build csv and stuff
def get_data(user, url, server_name):
client = APIClient()
client.force
浏览 3提问于2020-05-12得票数 0
回答已采纳
1回答
芹菜如何进行蓝绿调配？
、、、
我在担心芹菜的部署。
所以我正在寻找安全的部署，比如芹菜的蓝绿色部署。
但是对芹菜来说这是可能的吗？如果芹菜工人在执行任务的过程中被杀死(分离)，该任务可能会失败。或者另一个工人试图捕获失败的任务，检测到芹菜工人被杀死(分离)？
有没有人尝试安全地部署celery worker代码？
浏览 0提问于2015-08-24得票数 0
2回答
我使用Django和芹菜完成一个异步任务。我需要知道如何正确地杀死芹菜任务。
例如，在Django视图中有一个芹菜任务：
...
sometask.delay(some1, some2)
...
要杀死这个"sometask“，我可以在任务中使用sys.exit()吗？示例：
@shared_task
def sometask(some1, some2):
...
...
if some1 == False:
sys.exit('Abort!')
这个sys.exit()将在芹菜任务中工作吗？
诚挚的问候,
浏览 0提问于2014-03-28得票数 3
1回答
姜戈芹菜工人没有接受任务
、、、、
每当我管理芹菜工人时，我都会收到警告。
./manage.py celery worker -l info --concurrency=8
如果我忽视了这个警告，那么我的芹菜工人就没有收到芹菜的任务。
在之后，我也更改了工人的名字，但是这次我没有收到警告，但是芹菜工人仍然没有收到芹菜的预定任务。
我已经检查了芹菜的节拍记录，以及芹菜节拍的时间安排。
我还检查了芹菜花，它显示了两个工人和第一个工人正在接收任务而没有执行任务，如何把所有的任务都交给第二个工人呢？或者我怎样才能让第一个工匠停用，我所缺少的芹菜是什么？
我的django settings.py
RABBITMQ_USERNA
浏览 5提问于2017-05-12得票数 1
回答已采纳
我有用Python编写的带有多个组件的“项目”：有几个不同的金字塔和Twisted应用程序正在运行。
我们要用芹菜来卸下金字塔和扭曲的部分工作。为了明确起见，我们正在看一个芹菜实例/配置，它处理多个金字塔和扭曲应用程序的工作。
我在网上找到的所有信息包括一个或多个应用程序的多个芹菜，多个应用程序没有一个芹菜。芹菜将执行4-5功能，这是所有这些应用程序的共同功能。
对于这类设置，是否存在任何推荐的策略/常见的缺陷，或者我们是否应该对所有不同项目导入的独立celery_tasks包感到满意？
浏览 1提问于2013-07-27得票数 0
回答已采纳
1回答
雷迪斯芹菜与雷迪斯单独
、、、、
我很难理解使用芹菜有什么好处。我知道你可以用芹菜和红宝石，RabbitMQ等，但为什么我不直接得到客户端的那些消息队列服务，而不是坐在芹菜前面呢？
浏览 1提问于2016-08-28得票数 0
回答已采纳
1回答
我试图将动态工作流引入到我的领域中，这涉及到不同模型推断的多个步骤，其中一个模型的输出被输入到另一个model.Currently中，很少有芹菜工作人员分散在主机上来管理推理链。随着复杂性的增加，我们正在尝试动态地构建工作流。为此，我得到了一个动态DAG设置和塞勒伊执行器工作。现在，有什么办法我可以保留目前的芹菜设置和路线气流驱动的任务给相同的工人？我理解这些工作人员中的设置应该可以访问DAG文件夹和环境，与气流服务器相同。我想知道如何在这些服务器中启动芹菜工人，这样气流就可以从python应用程序的手动工作流中执行相同的任务。如果使用命令“气流芹菜工人”启动员工，则无法访问应用程序任务。如果
浏览 5提问于2021-05-27得票数 1
回答已采纳
1回答
芹菜对任务的eta有限制吗？我想在12天后执行foo方法，芹菜会有问题吗？或者我需要为这么长的eta配置任何芹菜设置吗？
next_run = datetime.now() + timedelta(days = 12)
foo.apply_async(args=[], eta = next_run)
浏览 1提问于2015-12-16得票数 2
1回答
我目前已经设置了Airflow并正常工作，使用CeleryExecutor作为后端来提供水平缩放。这非常有效，特别是当工作节点位于EC2上的自动伸缩组中时。 除了Airflow之外，我还使用纯芹菜来处理来自Flask/Python的简单异步任务(不需要整个管道)。到目前为止，这些普通芹菜任务的量非常小，我只是在与Flask相同的机器上运行普通芹菜工人。现在需要在系统中运行大量的普通芹菜任务，所以我也需要扩展我的普通芹菜。 要做到这一点，一种方法是在Airflow worker服务器上运行纯芹菜worker服务(从自动伸缩等方面受益)。但这似乎不是一个优雅的解决方案，因为它在同一台机器上创建了
浏览 15提问于2019-10-05得票数 1
我有一个蟒蛇芹菜-红色的队列处理，上传和下载，一次有价值的演出和演出数据。
很少有上传需要几个小时的时间。然而，一旦完成了这样的任务，我就会看到这种奇怪的芹菜行为，芹菜调度程序再次将刚刚结束的任务重新发送给工作人员(我正在运行一个工人)，并且在同一任务上只发生了2次！
有人能帮我知道为什么会发生这种事吗?我怎样才能阻止它？
这些任务绝对是干净利落地完成的，没有错误报告，只是这些是非常长时间运行的任务。
浏览 0提问于2014-12-05得票数 5
回答已采纳
有人能告诉我芹菜是在线程中执行任务，还是在单独的子进程中执行任务？这些文档似乎无法解释它(读3遍)。如果它是一个线程，它如何传递GIL (特别是事件的通知对象和方式)？
你如何比较芹菜的异步和Twisted的反应堆模型？芹菜到底是使用反应堆模型吗？
谢谢,
浏览 5提问于2013-08-19得票数 7
考虑到芹菜已经是运行任务队列的堆栈的一部分(也就是说，它不是仅仅为运行crons而添加的，这似乎是一个过分的IMHO )。
作为crontab的替代品，它的“定期任务”功能如何有益？特别是寻找以下几点。
对crontab的主要利弊
用例中芹菜比crontab更好的选择
Django特定用例:用于运行基于django的定期任务的芹菜和crontab，而芹菜已作为django-celery包含在堆栈中，用于查询django任务。
浏览 4提问于2013-08-12得票数 50
回答已采纳
2回答
我以前从未使用过芹菜，我也是django的新手，所以我不确定是否应该在我的项目中使用芹菜。
我的项目简介：
有一个API用于向科学计算集群发送(通过SSH)作业。API是对不同科学作业队列供应商的抽象。我的项目基本上是用django为这个API做一个web。
因此，我关心的是，如果我使用芹菜，我将在本地web服务器中有一个队列，在每个远程集群中有一个队列。我担心这可能会使实现变得没有必要。
API还在开发中，有些特性还没有完全完成。有一个函数用于检查远程作业执行的状态(运行、完成等)。但是对状态更改的回调支持还没有准备好。这里是我认为芹菜可能合适的地方。我会有一个或几个定期任务监视工作状态。
浏览 0提问于2013-09-17得票数 0
回答已采纳
1回答
我们需要扩展芹菜，以避免有限的芹菜工人排起长队，而是在ACI中产生新的芹菜容器来分发这些任务。 为了实现这种扩展(在ACI中生成新的芹菜容器)，我们需要知道等待执行的任务的数量，并相应地在ACI上生成这些容器。 任何建议都将不胜感激。
浏览 11提问于2020-07-25得票数 0
2回答
芹菜队列同时获取多条消息
、、、
我正在开发一个基于码头的芹菜支持的Python应用程序，其中一个功能是触发并发送一个给定数字的文本消息。工作流程如下：
用户上传带有一组条目的CSV，每60秒向CSV发送文本消息cron作业轮询数据库，以获取任何新条目并在找到新条目时将它们添加到队列中，将它们放入队列并触发文本消息。
目前，如果我上传一个CSV文件与3个条目，每个短信动作是顺序触发，而不是并行(默认芹菜过程bheaviour)。例如，如果调度程序每10秒从队列中获取一个作业，发送3条文本消息所需的时间将为30秒。由于这些作业是相互独立的，所以我想并行化这一点，以便同时发送所有三个文本消息。
我尝试增加队列的并发性，但假设每个线
浏览 2提问于2021-09-15得票数 3
3回答
如何延迟芹菜任务的执行？
、、、
我有一个小脚本，用于将任务排入队列进行处理。这个脚本进行了大量的数据库查询，以获取应该入队的项目。我面临的问题是，芹菜工人在脚本将任务排入队列后立即开始拾取任务。这是正确的，这是芹菜应该工作的方式，但这经常导致我的脚本和芹菜工作人员之间的死锁。
有没有一种方法可以让我将脚本中的所有任务排入队列，而不是将执行延迟到脚本完成或固定的时间延迟？
我在芹菜或django-celery的文档中找不到这一点。这个是可能的吗？
目前，作为一个快速解决方案，我考虑将所有要处理的项添加到一个列表中，当我的脚本执行完所有查询后，我可以简单地迭代列表并将任务排入队列。也许这可以解决问题，但当您有数千个项目要排队时，
浏览 0提问于2012-10-22得票数 18
回答已采纳
1回答
关于芹菜我没什么问题。请帮我一把。
我们需要把项目代码放在每个芹菜工人身上吗？如果是的话，如果我正在增加工作人员的数量，并且正在更新我的代码，那么在所有员工实例中更新代码的最佳方法是什么(而不每次都手动将代码推送到每个实例中)？
在芹菜工人中使用-Ofair作为参数，即使设置了PREFETCH_LIMIT=8 or so，也可以禁用工人的预取
重要事项: rabbitmq是将任务分配给工人，还是由工人从代理中提取任务？
在一个系统中有一个以上的芹菜工人(子进程和核数一样多)有意义吗？我看到很少有人在一个单一的系统中管理多个芹菜工人。
为了补充前面的问题，这两种场景之间的性能
浏览 0提问于2019-06-20得票数 3
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回答
首先，我有一个使用芹菜运行的模块。
其次，我还运行了另一个模块，用于将任务推送给芹菜工人。它导入第一个模块并将其命名为async。
现在，第一个模块加载一些大文件，这些文件只需要加载一次。我希望在芹菜启动时加载，但是当我运行第二个模块将任务推送到芹菜工作时，我不希望再次导入这些文件。
我能不能用celery调用一个函数，让它在worker初始化时第一次加载，然后在我运行第二个模块时不再调用这个函数，它只是将任务推给worker？
干杯
浏览 2提问于2013-12-19得票数 0
我能够成功地将Django芹菜工人部署为AWS ECS服务中的码头容器，使用FARGATE作为计算。
但是我关心的是芹菜容器是24/7运行的。如果我只能在任务分配时运行容器，我可以按照AWS FARGATE计费方法节省很多钱。
浏览 0提问于2019-08-30得票数 3
回答已采纳
1回答
有没有可能在高吞吐量的情况下，Task.delay会默默地被杀死？我正在使用芹菜与RabbitMQ作为后端。不完全了解芹菜的内部结构以及芹菜是如何控制行为的。
浏览 1提问于2017-01-27得票数 0
回答已采纳
1回答
1)芹菜链。
在医生上我读到：
这里是一个简单的链，第一个任务执行，将其返回值传递给链中的下一个任务，依此类推。
>>> from celery import chain
>>> # 2 + 2 + 4 + 8
>>> res = chain(add.s(2, 2), add.s(4), add.s(8))()
>>> res.get()
16
但是，链项的结果到底在哪里传递给下一个链项呢？在芹菜服务器端，还是传递给我的应用程序，然后我的应用把它传递给下一个链项目？
这对我来说很重要，因为我的结果很大，可以把它们传递给应
浏览 1提问于2016-11-19得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
