如何指定芹菜工人可以接受的任务批量？
指定芹菜工人可以接受的任务批量可以通过以下步骤实现：
- 创建任务批量：首先，需要创建一个任务批量，将需要分配给芹菜工人的任务进行批量管理。可以使用一个任务批量管理系统或者自定义开发一个任务批量管理工具。
- 定义任务要求：在任务批量中，定义每个任务的具体要求和条件。这些要求可以包括任务的类型、难度、工作量、截止日期等。
- 分配任务：根据芹菜工人的能力和可接受的任务类型，将任务批量中的任务分配给合适的芹菜工人。可以根据工人的技能、经验、可用时间等因素进行匹配。
- 任务接受与拒绝：芹菜工人可以查看任务批量中的任务列表，并选择接受或拒绝某个任务。如果工人接受了任务，该任务将被标记为已分配给该工人。
- 任务进度跟踪：在任务批量管理系统中，可以实时跟踪每个任务的进度和状态。芹菜工人可以更新任务的进度，并及时反馈问题或困难。
- 完成任务和验收：当芹菜工人完成任务后，可以将任务标记为已完成。任务批量管理系统可以提供验收机制，用于确认任务的质量和完成情况。
- 绩效评估和奖励：根据任务批量中的任务完成情况和质量，可以对芹菜工人进行绩效评估，并给予相应的奖励或激励措施。
腾讯云相关产品和产品介绍链接地址：
- 任务批量管理系统：腾讯云批量计算（https://cloud.tencent.com/product/bc）
- 任务进度跟踪：腾讯云云监控（https://cloud.tencent.com/product/monitoring）
- 绩效评估和奖励：腾讯云人工智能（https://cloud.tencent.com/product/ai）
相关·内容
2回答
我正在尝试设计一个系统，调用者将数据发送给运行在GPU机器上的芹菜工人，他们进行一些处理，并将结果返回给调用者。由于GPU可以并行处理一批数据(比方说并行处理N个项目)，因此对于芹菜任务来说，接受N个数据项目并一起处理所有N个项目是有意义的。在调用者端，我可以使用chunks将我的数据项列表分解为一些固定BATCH_SIZE的子列表。job = tasks.predict.chunks(texts,
浏览 27提问于2020-09-04得票数 2
我可以使用python os.nice来降低芹菜任务的质量吗？我在想这样的事情：def maintenance_requests(): request = requests.session()
request.get编辑:因为我的应用程序是IO绑定的，所以我发现离子是我需要的命令。做了一些测试，而且效果很好。谢谢
浏览 0提问于2013-11-08得票数 2
回答已采纳
1回答
我们还设置了一些自动标度机制，以增加更多的芹菜工人的飞行。
问题如下。那么，假设我们有5名工人在任何给定的时间。随后出现了许多任务，增加了吊舱的CPU/RAM使用量。这引发了一个自动标度事件，例如，又增加了两个芹菜工人吊舱。所以现在这两个新来的芹菜工人要做一些长时间的工作。在完成这些任务之前，kubernetes创建了
浏览 7提问于2022-08-02得票数 3
回答已采纳
1回答
我在尝试跑跑任务。但只有一个任务执行。所以，这是我的项目结构：trading_platform：celery.pysettings.pymanage.py
def print_text(text):命令运行:芹菜trading_platform.celery
浏览 2提问于2020-10-25得票数 0
6回答
芹菜工人数据库连接池
、、、
我用的是单独的芹菜(不是在Django内)。我计划在多台物理机器上运行一个工作任务类型。该任务执行以下操作
使多个数据库读写。我使用的是PostgreSQL，但这同样适用于使用连接的其他存储类型。在过去，我使用数据库连接池来避免在每个请求上创建一个新的数据库连接，或者避免将连接打开太长时间。然而，由于每个芹菜工人在一个单独的过程中运行，我不知
浏览 6提问于2013-01-25得票数 53
1回答
使用主管启动django很容易，比如下面基于我发现的一个教程：[program:gunicorn]然而，芹菜似乎需要自己的启动方式：因此，在我的无知/困惑中，我似乎不得不从古
浏览 2提问于2017-05-10得票数 2
回答已采纳
设想情况：
- Push code to server- Startthe u
浏览 4提问于2015-01-16得票数 4
1回答
1)芹菜链。这里是一个简单的链，第一个任务执行，将其返回值传递给链中的下一个任务，依此类推。在芹菜服务器端，还是传递给我的应用程序，然后我的应用把它传递给下一个链项目？&
浏览 1提问于2016-11-19得票数 1
回答已采纳
我目前正在处理文件的气流和芹菜。工作人员需要下载文件，处理文件，然后再上传。我的DAG只有一个工人没问题。但当我加上一件事就变得复杂了。
工作人员接受可用的任务。Worker1可以接受“处理下载的文件”的任务，但是接受“下载文件”任务的是Worker2，所以任务失败了，因为它不能处理不存在的文
浏览 0提问于2019-02-27得票数 3
1回答
具有非同质任务的芹菜
、、、
我有两个芹菜工人，工人1有任务A和B，工人2有任务A、B和C。如果我提交一个任务C，它似乎不会在有任务C的芹菜工人中执行；有没有什么方法可以确保只有工人2被分配任务C？
浏览 0提问于2010-11-19得票数 2
回答已采纳
1回答
我想在Django测试期间同步调用芹菜任务，而不需要运行芹菜工人。为了实现这一点，我在我的CELERY_ALWAYS_EAGER=True中指定了settings.py，但它似乎不起作用。因此，我决定应用override_settings装饰器进行如下所示的特定测试
@override_settings(CELERY_ALWAYS_EAGER=True, BROKER_BACKEND='不幸的是，这个测试仍然调用我的
浏览 2提问于2016-11-21得票数 6
回答已采纳
1回答
姜戈芹菜工人没有接受任务
、、、、
每当我管理芹菜工人时，我都会收到警告。
如果我忽视了这个警告，那么我的芹菜工人就没有收到芹菜的任务。在之后，我也更改了工人的名字，但是这次我没有收到警告，但是芹菜工人仍然没有收到芹菜的预定任务。
我已经检查了<
浏览 5提问于2017-05-12得票数 1
回答已采纳
第一天:从现在起7天内用倒计时调用一个芹菜任务，第2天:撤销这个任务第3天:升级发生，所以所有的工作进程都关闭了，然后在某个时候再恢复。我已经测试过类似的场景，我发现在所有工作进程中都有一个进程的撤销列表。但是消息(对应于任务)保留在任务被委派到的工作进程中。因此，一旦所有工作进程都关闭，撤消列表信息也会丢失。我想知道如果是这样的话，那么当所有的工作人员回来之后，那个进程会不会在不被取消/撤销的情况下开始执行呢？我这么说是因为撤销列表信息只驻
浏览 1提问于2014-11-27得票数 3
回答已采纳
1回答
我正在用芹菜框架编写一个应用程序。我的一些任务相当重量级，可以执行很长时间。我注意到，当我运行5-6个工人，然后把10-20个任务随机分配给工人时，有时如果一个人没有任务，它就不会开始剩下的任务，只有在他们完成任务时(可能在几小时内)，他们才会被其他人处理。如果我此时再运行一个工人-它什么也不做，但可以接受新的任务</e
浏览 3提问于2016-10-03得票数 2
回答已采纳
1回答
我有一个数量为20的mongodb集合，我用它来存储一些关于我当前正在使用cron作业处理的任务的数据。
在使用cron作业时，我的每个集合都有一个worker。我想改善这种安排，我正在研究芹菜。我是否有可能在芹菜中以我所描述的方式在每个集合中拥有4个工作人员？
浏览 1提问于2017-09-11得票数 0
1回答
我有一个芹菜经纪人和几个芹菜工人，他们都和rabbitMQ沟通。在我的设置中，我向我的芹菜工人发送了几个任务，他们将处理所有的任务(需要大约1个小时)，然后我将手动终止我的芹菜工人。我想要转向这样一种系统:如果一个芹菜工作者id 'idle‘(我将其定义为:在timeout_seconds的一段时间内有0个活动任务，我
浏览 17提问于2020-09-01得票数 1
2回答
多名芹菜远程工人
、、
这个问题是关于在不同的机器上使用多个远程芹菜工人。应用程序的实现可以概念化为：我的应用程序(生产者)将每5分钟向队列中添加多个任务(比如50个任务)(假设每隔5分钟就有一个用于循环的python循环迭代将要异步执行的任务列表)。我想要芹菜工人(这将是远程机器)在这些任务被推举后尽快完成。我的问题是，芹菜</e
浏览 0提问于2017-10-30得票数 3
2回答
可以在gpu上运行芹菜吗？
、、、、
问题是-可以在gpu?上运行芹菜。目前，在我的项目中，我的设置如下：--max-tasks-per-child一项任务大约需要12秒才能执行(将大型insert插入postgresql)。
我想要实现的是尽可能多地增加工人。
浏览 9提问于2021-01-31得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
