如何从芹菜工人那里每次发现新的任务结果？
从芹菜工人那里每次发现新的任务结果，可以通过以下步骤实现：
- 首先，芹菜工人是一个任务调度系统，它负责管理和调度各种任务。当一个任务完成后，芹菜工人会将任务结果存储在一个指定的位置，比如数据库、文件系统或消息队列。
- 为了从芹菜工人那里获取新的任务结果，可以使用轮询或订阅的方式。轮询是指定期间内定时查询任务结果的方式，而订阅是通过订阅任务结果的通知来获取新的结果。
- 如果使用轮询方式，可以编写一个定时任务或者一个长轮询的接口，定期向芹菜工人查询任务结果。在查询结果时，可以根据任务的唯一标识符或其他相关信息来获取特定任务的结果。
- 如果使用订阅方式，可以通过芹菜工人提供的订阅接口来注册一个回调函数或消息队列，当任务完成时，芹菜工人会自动发送通知到注册的回调函数或消息队列中，从而获取新的任务结果。
总结起来，从芹菜工人那里每次发现新的任务结果，可以通过轮询或订阅的方式来获取。轮询方式需要定期查询任务结果，而订阅方式则通过注册回调函数或消息队列来接收任务完成的通知。具体的实现方式可以根据芹菜工人的具体接口和文档进行调整。
腾讯云相关产品推荐：
- 数据库：腾讯云数据库（https://cloud.tencent.com/product/cdb）
- 服务器运维：腾讯云云服务器（https://cloud.tencent.com/product/cvm）
- 云原生：腾讯云容器服务（https://cloud.tencent.com/product/tke）
- 网络通信：腾讯云私有网络（https://cloud.tencent.com/product/vpc）
- 网络安全：腾讯云安全产品（https://cloud.tencent.com/solutions/security）
- 人工智能：腾讯云人工智能（https://cloud.tencent.com/product/ai）
- 物联网：腾讯云物联网开发平台（https://cloud.tencent.com/product/iotexplorer）
- 移动开发：腾讯云移动开发平台（https://cloud.tencent.com/product/mpp）
- 存储：腾讯云对象存储（https://cloud.tencent.com/product/cos）
- 区块链：腾讯云区块链服务（https://cloud.tencent.com/product/bcs）
- 元宇宙：腾讯云元宇宙解决方案（https://cloud.tencent.com/solutions/industry/entertainment/metaverse）
相关·内容
1回答
怎样才能最大限度地提高工人的生产力呢？
python、heroku、celery、web-worker、markov-chains
我正在开发一个系统，它将为一个人工智能项目建立一个庞大的n图模型。
我的管道如下：
资源输入-->获取数据-->解析器-->训练器
资源输入(基本上是必须解析的URL)不是固定的，这意味着我可以一次引入数千个资源，稍后再引入几十个资源，等等。
我的想法是将管道的每一步实现为一个芹菜任务，并将其部署到云上(例如，使用Heroku的工人dynos)。但我对芹菜很陌生，我怀疑如何排好这些任务，让我的员工100%地工作，同时保持系统的完整性。
直接的方法是在前一个任务完成后立即开始排队，因此，例如，如果我得到一个由1000个项组成的资源输入，我会调度1000个“获取数据”任务，每个任
浏览 1提问于2012-07-27得票数 2
回答已采纳
3回答
APP 上传完之后，COS 的服务器会不会向用户服务器发回调 ？
对象存储、官方文档
APP 上传完之后，COS 的服务器会不会向用户服务器发回调 ？
如果不发回调的话，用户服务器怎么知道上传是否成功，以及上传了什么文件，上传的文件的存储路径？？
标题：快速搭建移动应用传输服务 - 对象存储 - 文档首页 - 腾讯云文档平台 - 腾讯云
地址：https://cloud.tencent.com/document/product/436/9068
浏览 817提问于2018-03-08
1回答
如何在Google应用引擎上部署芹菜工人
python、django、google-app-engine、rabbitmq、celery
我有一个芹菜工人需要部署到谷歌应用引擎，这有可能吗？我打算为我的主Django应用程序使用一个应用程序，一个用于芹菜工人的应用程序和一个Rabbitmq服务(它由Google云支持)
浏览 3提问于2019-11-15得票数 6
回答已采纳
2回答
芹菜非阻塞客户端
python、celery
import proj.tasks
import time
import sys
import socket
import logging
import datetime
lat_to, ts = proj.tasks.timeme(time.time()) <---- blocking call
lat_from = time.time() - ts
print lat_to, lat_from
芹菜任务阻碍了，所以我不能利用许多工人。有可能打个非阻塞电话吗？
注意:我已经把龙卷风-芹菜作为非阻塞芹菜客户端的一种选择，但我不确定我是否喜欢这种方法，因为我需要启动龙卷
浏览 2提问于2014-11-07得票数 0
回答已采纳
2回答
如何在芹菜中捕获事件
python、celery、django-celery
我刚开始使用芹菜(更具体地说是django- Celery )，我仍然不熟悉它。
我正在开发一个应用程序，它将发送要在工作人员中远程执行的任务，其中每个任务大约需要3分钟才能完成。(不是繁重的处理，web爬行之类的东西，但这是无关紧要的)。
当我发送一个任务时，我会得到一个可以用来获取结果的引用。
>>> result = task_name.delay()
>>> result
<AsyncResult: c34d78d8-b512-4165-9384-2b87933e33b7>
但是，要知道任务何时完成，我必须不断轮询
>>>
浏览 0提问于2012-03-17得票数 4
回答已采纳
2回答
在向远程工作人员发送芹菜任务之前，如何从Django DB检索数据？
python-3.x、django、celery、distributed-computing
我有一个芹菜shared_task，计划在一定的时间间隔运行。每次运行此任务时，都需要首先从Django DB检索数据，以便完成计算。这个任务可能发送也可能不会发送给单独机器上的芹菜工人，因此在芹菜任务中，我不能对本地芹菜数据库进行任何查询。
到目前为止，我已经尝试使用信号来完成它，因为我知道在任务发布到消息队列之前就已经执行了带有包装器@before_task_publish的函数。但是，我不知道如何才能将数据实际用于这项任务。
@shared_task
def run_computation(data):
perform_computation(data)
@before_ta
浏览 17提问于2022-03-23得票数 0
回答已采纳
请描述您的问题
另外一般需要多久呢？比如10分钟的语音文件，需要多久能转换成文字？
标题：简介 - 智能语音服务 - 文档首页 - 腾讯云文档平台 - 腾讯云
地址：https://cloud.tencent.com/document/product/441/6199
浏览 152提问于2018-03-12
2回答
关于蟒蛇芹菜的几个问题
python、django、celery
我把芹菜分成以下几个部分
芹菜
芹菜工
芹菜守护进程
经纪人: Rabbimq或SQS
队列
结果后端
芹菜监测器(花卉)
我的理解
当我在django e执行芹菜任务时，g tasks.add(1,2)。然后芹菜把这个任务添加到队列中。我很困惑上面列出的是4还是5
WHen任务进入队列，然后worker获取该任务并从队列中删除
该任务的结果保存在结果后端。
我的困惑
芹菜守护进程和芹菜工人之间有什么区别？
是Rabbitmq在做队列的工作。这是否意味着任务保存在Rabitmq或SQS中？
花是做什么的。它是否监视工作人员、任
浏览 5提问于2016-04-26得票数 1
4回答
不会申请证书，怎么搞？
官方文档、SSL 证书
请描述您的问题
标题：自动诊断结果查看指引 - SSL证书 - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/400/6760
浏览 346提问于2018-01-28
2回答
远程芹菜工人完成后通知或召回瓶
python、flask、celery、celery-task、remote-client
我在两台不同的机器上运行芹菜客户端(烧瓶)和工人，现在工作人员完成任务后，我需要在客户端回调一个函数。这个是可能的吗？
芹菜客户：-
celery_app=Celery('test_multihost', broker='amqp://test:test@<worker_ip>/test_host', backend='rpc')
result= testMethod1.apply_async((param1, param2,param3), link=testMethod2.s())
@celery_app.task
def te
浏览 7提问于2020-08-14得票数 1
回答已采纳
4回答
RabbitMQ是否能够将消息从队列“推送”到消费者？
queue、rabbitmq
使用RabbitMQ，有没有一种方法可以将消息从队列“推送”到消费者，而不是让消费者“轮询并从队列中提取”消息？
这已经引起了一些关于我正在做的项目的争论。一方的论点是，让消费者(即，windows服务)在新消息到达之前“轮询”队列在某种程度上是低效的，并且比使消息从队列自动“推入”到订户/consumer(多个)的想法更不可取。
我似乎只能找到支持消费者“轮询并从队列中拉出”消息的想法的信息(例如，使用windows服务来轮询队列中的新消息)。关于“推送”消息给消费者/订阅者的想法没有太多的信息……
浏览 1提问于2014-10-23得票数 17
1回答
基于ZeroMQ的分布式任务处理
python、zeromq
我试图使用ZMQ推拉来构建一个分布式任务处理系统。这是在Java中通过队列和侦听器使用JMS实现的；空闲的侦听器可以接收队列的消息并执行it.Once --队列是跨节点分布的，这就像负载平衡器一样。
使用ZMQ (使用Python -不想现在使用芹菜)，我正在尝试推拉。有不同的处理时间的工人。然而，即使是当一个工人是自由的，任务是严格循环的方式。这就是说，不管工人是否自由，任务都是以循环的方式进行的。
有什么方法可以用ZMQ模式来模拟分布式队列吗?这样，我就可以在每个节点中有一个工人‘轮询’队列，并将消息从队列中取出并处理。
浏览 1提问于2015-07-06得票数 0
6回答
短信回调地址，取不到回调的内容？
官方文档、api、短信
云官网上有相应的短信api描述（https://cloud.tencent.com/document/product/382/5809）：
功能描述
用户收到短信后，回复短信，腾讯云短信服务可以通过回调业务 url 的方式，通知业务方用户回复了短信。
URL 示例
https://yun.tim.qq.com/sms/smscallback
问题是设置了回调地址，在回调地址里面，怎么取到参数呢？我测试了，是有回调，但是POST参数全是空，取不到数据。SDK也没有这个例子代码。
[附加信息]
浏览 1482提问于2018-05-04
2回答
AWS SQS:这是SQS每次推送消息时叫我消费者的一种方式吗？
java、amazon-web-services、aws-lambda、aws-sdk、amazon-sqs
有什么方法可以让AWS SQS调用我的REST呢？基本上，只要消息被推送到AWS SQS，我就想听到它并执行所需的操作。我可以安排一个监听器，它可以每秒钟提取消息，但这不是一个优化的解决方案，队列也可能是空的(有时)。
提前谢谢！！
浏览 3提问于2017-02-27得票数 2
回答已采纳
1回答
利用现有芹菜工人生产气流加速器工人
python、celery、airflow、celery-task
我试图将动态工作流引入到我的领域中，这涉及到不同模型推断的多个步骤，其中一个模型的输出被输入到另一个model.Currently中，很少有芹菜工作人员分散在主机上来管理推理链。随着复杂性的增加，我们正在尝试动态地构建工作流。为此，我得到了一个动态DAG设置和塞勒伊执行器工作。现在，有什么办法我可以保留目前的芹菜设置和路线气流驱动的任务给相同的工人？我理解这些工作人员中的设置应该可以访问DAG文件夹和环境，与气流服务器相同。我想知道如何在这些服务器中启动芹菜工人，这样气流就可以从python应用程序的手动工作流中执行相同的任务。如果使用命令“气流芹菜工人”启动员工，则无法访问应用程序任务。如果
浏览 5提问于2021-05-27得票数 1
回答已采纳
6回答
如何使用SQL数据库创建时间事件体系结构
c#、sql-server、event-programming、polling
我问题的标题是一般性的，因为我觉得这个问题是一般性的，但为了搭建舞台，我将提供一个具体的例子。
我们使用由数据库表驱动的本地工作流引擎。在这些表中隐藏着一个表示工作流的有向图。该图包含阶段和活动；在两个阶段节点之间绘制一条线，生成的活动节点包含要执行的代码。我们使用CSScript实时编译和执行代码。
在工作流中，任务记录表示要执行的工作。每个任务都包含一些XML形式的相关元数据。Task记录遍历有向图，并在Task通过活动时执行代码。因此，在任何给定的时刻，每个阶段都可能包含x个任务，等待在一个活动上执行。
若要对活动执行任务，需要对其进行调度。包含日期时间、taskid、stageid和a
浏览 0提问于2016-10-26得票数 7
回答已采纳
2回答
芹菜只占用20%的Cpu (峰值)
concurrency、rabbitmq、load、celery、cpu
我正在运行一个芹菜+ rabbitmq应用程序。我启动了一堆ec2机器，但我发现我的芹菜工人机器只使用了大约15%的cpu (峰值为20%)。我已经为每台机器配置了2个芹菜工人。
芹菜工人不应该接近使用100%的CPU利用率吗？
更多信息:我没有使用celery --concurrency选项或eventlet，尽管我使用了多个worker。默认情况下，并发设置为8。我的任务在php中运行，主要是io阻塞，所以如果我们有更多的进程并行运行也不会有问题。有没有办法将celery配置为根据CPU使用率运行更多的任务
浏览 4提问于2019-10-18得票数 2
1回答
更新客户端芹菜任务已经完成
python、flask、celery
我有以下要求。我正在创建一个web应用程序(没有前端)，它将接收帖子并收到请求。它的功能如下。客户端将在URL上发布一篇文章，触发一项耗费大量时间的任务。客户端还可以发出Get请求并检索taks的结果。
我在考虑用芹菜开始这项任务。这个任务是一个非常大的算术计算。我的问题是如何通知客户端他触发的任务已经完成，他可以检索结果。
所以我就这样想：
client ->posts to web app -> web app starts task to celery -> request closed
web app notifies -> client triggered
浏览 2提问于2015-11-26得票数 10
1回答
来自用户的循环调度CPU限制的操作
cloud、message-queue、distributed-computing、messagebroker
我们有最终用户API来执行一些长时间(30s-1h)的CPU绑定操作。用户可以创建任务，多次轮询任务状态，最终得到结果。 在内部，我们有任务队列和一些可以处理这些任务的工人。 当User1创建了许多大任务，然后User2创建了一个小任务时，就会出现问题。User2希望快速获得结果，但所有工作人员都在处理来自User1的任务。来自User1的任务位于队列末尾。 Expectation是以循环方式处理来自两个用户的任务。 有没有什么现成的解决方案来解决这类问题呢？ (更新)找到相同的问题：What are some queuing mechanisms for implementing roun
浏览 25提问于2019-09-24得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
