windows上的芹菜结果后端
芹菜结果后端是指在Windows操作系统上运行的一个后端服务，用于处理与芹菜结果相关的业务逻辑和数据处理。下面是对该问答内容的完善和全面的答案：
- 芹菜结果后端概念：芹菜结果后端是一个后端服务，用于处理与芹菜结果相关的业务逻辑和数据处理。它可以接收来自前端的请求，对芹菜结果进行处理，并返回相应的结果给前端。
- 芹菜结果后端分类：芹菜结果后端可以根据具体的功能和应用场景进行分类，例如可以分为芹菜结果数据处理后端、芹菜结果分析后端等。
- 芹菜结果后端优势：芹菜结果后端具有以下优势：
- 高效性：通过后端服务的处理，可以提高芹菜结果的处理效率和响应速度。
- 可扩展性：后端服务可以根据需要进行水平或垂直扩展，以应对不断增长的用户和数据量。
- 稳定性：后端服务可以提供稳定的运行环境，确保芹菜结果的可靠性和稳定性。
- 芹菜结果后端应用场景：芹菜结果后端可以应用于各种与芹菜结果相关的场景，例如：
- 农业领域：用于芹菜种植的数据处理和分析。
- 餐饮行业：用于芹菜相关菜品的推荐和营销。
- 健康管理：用于芹菜的营养价值分析和健康指导。
- 推荐的腾讯云相关产品和产品介绍链接地址：以下是一些腾讯云的相关产品，可以用于支持芹菜结果后端的开发和部署：
- 云服务器（CVM）：提供稳定可靠的云服务器实例，用于部署芹菜结果后端服务。链接地址：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CDB）：提供高性能、可扩展的云数据库服务，用于存储和管理芹菜结果相关的数据。链接地址：https://cloud.tencent.com/product/cdb
- 人工智能平台（AI Lab）：提供丰富的人工智能开发工具和服务，可以用于芹菜结果的数据分析和处理。链接地址：https://cloud.tencent.com/product/ailab
总结：芹菜结果后端是一个用于处理与芹菜结果相关的业务逻辑和数据处理的后端服务。它具有高效性、可扩展性和稳定性等优势，可以应用于农业、餐饮、健康管理等领域。腾讯云提供了一系列相关产品，如云服务器、云数据库和人工智能平台，可以支持芹菜结果后端的开发和部署。
相关·内容
我建立了芹菜的基本例子的芹菜使用红葡萄酒作为面包师和后端。
当我在Windows上运行worker时，运行delay().get()不会返回。
浏览 2提问于2016-09-07得票数 0
回答已采纳
1回答
TL:博士，我想在后端找到结果。
我有一个酒瓶/芹菜项目，我对芹菜很陌生。用户发送一批用于芹菜工作的任务。芹菜将结果保存到后端SQL数据库(由芹菜自动创建的表，名为celery_taskmeta)。
我想让用户看到他的批处理的状态，并从后端请求结果。
我的问题是，所有的结果都在一张桌子上。我有哪些选项可以将这个批处理，这样用户就可以区分批处理了？
我的想法：
我能为每一项任务添加一个lable吗？“Bob的批次编号12”然后查询celery_taskmeta的结果如何？
我能把每一批批次放在命名的后端表中吗?所以请芹菜将结果保存到一个名为task_12的表中。
与团体一起尝试
浏览 4提问于2020-12-16得票数 0
是否可能只将芹菜结果保存在特定参数上，例如失败的任务？
我一直在寻找，但唯一的办法，我可以管理的是回到芹菜的结果后端和解析数据以外的芹菜。
有更好的办法吗？
(注意:我使用mongodb作为芹菜结果后端。)
浏览 3提问于2020-08-12得票数 0
回答已采纳
1回答
我有一项大约需要3分钟才能完成的任务。它从远程服务器中提取数据，并对其进行cpu密集型分析。此任务将由api调用调用。在api调用时，我计划给客户一个独特的任务id，并将任务分配给芹菜工人。然后，客户端将使用给定的任务id轮询服务器，以查看该任务是否由芹菜工人完成，并将其结果保存到结果后端。我想使用nginx，gunicorn，烧瓶和篡改它们，以便于部署，以防我需要在多台机器上分发这个体系结构。
问题是，由于负载均衡器的原因，客户端可能会轮询不同的服务器，如果处理不好，则轮询服务器的结果后端可能没有任务的结果，而其他服务器的芹菜结果后端则有。
是否可以对多个芹菜实例使用单个结果后端，并使不同的
浏览 2提问于2019-07-11得票数 1
回答已采纳
1回答
在芹菜中查询结果后端的所有结果的最简单方法是什么？我使用一个MySQL数据存储作为我的结果后端。
芹菜将结果存储为BLOB类型，因此我无法以纯文本的形式检索结果。
如果您想知道我为什么要这样做，用例是查询所有由芹菜执行的任务的结果。
浏览 0提问于2019-04-28得票数 1
回答已采纳
2回答
我把芹菜分成以下几个部分
芹菜
芹菜工
芹菜守护进程
经纪人: Rabbimq或SQS
队列
结果后端
芹菜监测器(花卉)
我的理解
当我在django e执行芹菜任务时，g tasks.add(1,2)。然后芹菜把这个任务添加到队列中。我很困惑上面列出的是4还是5
WHen任务进入队列，然后worker获取该任务并从队列中删除
该任务的结果保存在结果后端。
我的困惑
芹菜守护进程和芹菜工人之间有什么区别？
是Rabbitmq在做队列的工作。这是否意味着任务保存在Rabitmq或SQS中？
花是做什么的。它是否监视工作人员、任
浏览 5提问于2016-04-26得票数 1
1)我目前正在开发一个web应用程序，该应用程序公开一个REST，并使用Django和芹菜来处理请求并解决它们。为了解决请求，必须向amqp队列提交一组芹菜任务，以便在工人(位于其他机器上)上执行这些任务。每项任务都是非常密集的CPU，需要很长时间才能完成。
我已经配置了芹菜也使用amqp作为结果后端，我使用RabbitMQ作为芹菜的经纪人。
每个任务都返回一个结果，需要随后存储在DB中，而不是由工作人员直接存储。只有“中心节点”--运行django的机器-- RabbitMQ队列中的芹菜和发布任务--才能访问这个存储DB，因此工作人员的结果必须以某种方式返回到这台机器上。
问题是我如何处理之
浏览 1提问于2013-02-06得票数 7
回答已采纳
1回答
我有一个与芹菜图书馆集成的django项目。我怎样才能清除我的芹菜后端结果数据？
我正在使用django-db作为我的芹菜工人后端。
CELERY_RESULT_BACKEND = 'django-db'
浏览 1提问于2018-04-02得票数 1
回答已采纳
1回答
我使用sql server和rabbitmq作为结果，后端/代理用于芹菜workers.Everything工作正常，但为了将来的目的，我们计划在需要监视此代理/后端的不同机器上使用多个远程工作人员。问题是，您需要提供对代理和数据库url的直接访问，这样可以打开许多安全risks.Is --有一种方法可以通过ssh为远程芹菜工作者提供远程代理/数据库？
浏览 3提问于2021-01-04得票数 0
回答已采纳
1回答
我是Python和芹菜的新手--Redis，所以如果我的理解不正确，请纠正我。
我一直在调试一个代码库，它的结构类似-
TaskClass ->芹菜任务
HandlerClass1, HandlerClass2 -> --这些是扩展对象类的python类
应用程序创建TaskClass say dumyTask实例，dumyTask通过获取处理程序的签名创建芹菜子任务(我相信这些子任务是唯一的)，dumySubTask1, dumySubTask2。
我不明白的是什么？
1)芹菜如何管理dumySubTask1, dumySubTask2和dumyTask的结果？我的意思是，dum
浏览 2提问于2017-06-16得票数 0
我们在Windows上的IIS下运行一个烧瓶站点，对于进程外的任务，我们使用芹菜.芹菜在Windows下给我们带来了一些问题，但目前我们满意的是运行3.1.12版本，使用RabbitMQ/AMQP作为后端，它在Windows下工作。
新版本的芹菜(4)有，所以我正在寻找一个可行的替代方案。
RQ似乎是一个非常好的任务队列，但它也不支持Windows ( )
我看到了更多的、似乎不那么受欢迎的任务队列，如：
但目前还不清楚这些软件是否支持Windows和水瓶座。我想知道是否有人有在Windows下运行Python任务队列的经验。也许是我提到的其中之一，或者另一种选择。
浏览 0提问于2017-02-20得票数 24
回答已采纳
我一直在从事芹菜和AMQP的后端存储工作。我不喜欢它为每个任务/响应创建一个新的队列，我找到了新的RPC结果后端，它可以正常工作。
但是，这个在描述RPC后端时说：
新RPC结果后端这个新的实验版本的amqp结果后端是一个很好的替代方案，可以在经典RPC场景中使用，在中，启动任务的过程总是检索结果的过程。
这是什么意思？芹菜是否支持访问不同进程启动的任务的过程？这听起来很有趣，有什么关于我如何实现这一点的建议吗？
非常感谢,
浏览 1提问于2014-07-18得票数 1
1回答
我有一个项目"A" (Django)，其中我想生成消息发送给芹菜经纪人，例如Redis。
在另一个项目"B" (同一台机器中的纯python )上，我想启动一个芹菜服务器工作人员来监视代理中的消息并执行任务。任务在B中定义。
当任务完成时，他们会将结果保存在redis中(也用作结果后端)。
当回应准备好后，我想让django知道。
这个是可能的吗？
我主要担心的是，A不应该从B导入任务，所以我应该使用类似于send_task('task_name')的东西。
实际上，我应该创建两个单独的芹菜实例，但只运行一个服务器工作人员？
实例1只发送消息
浏览 2提问于2019-01-10得票数 0
1回答
在我的应用程序中，我使用芹菜和RabbitMQ。
在本地主机上，一切都很好：
我向少数员工发送任务，他们计算任务并将结果返回给call.py (我使用)。
问题从这里开始：
在我的笔记本电脑(macbook)上，我有RabbitMQ，台式机(pc，windows) -芹菜工人。我启动了call.py (在笔记本电脑上)，它将数据发送到我的桌面(员工)，他们接收并计算任务，最后(当所有任务成功时)我的笔记本电脑没有收到任何工人的响应。
没有错误什么都没有。
我的笔记本电脑ip - 192.168.1.14。当我将芹菜实例化时，我在broker和后端参数中使用这个ip。
在rabbitmq-env
浏览 6提问于2014-10-22得票数 0
1回答
我正在处理的应用程序请求来自静态HTML页面和API端点的内容，并且需要在结果后端支持这两种内容类型。
有没有办法在芹菜结果后端同时使用HTML和JSON？我尝试过设置CELERY_ACCEPT_CONTENT = ['text/plain', 'application/json']，但它在所有的HTML结果上抛出错误is not JSON serializable。
浏览 1提问于2017-02-20得票数 1
1回答
我在试着弄清楚芹菜是如何和什么时候清理任务的。通过查看，我发现：
根据CELERY_TASK_RESULT_EXPIRES设置，将自动清除旧结果。默认情况下，这将在1天后到期:如果您有一个非常繁忙的集群，您应该降低此值。
但是这个引用来自于RabbitMQ结果后端部分，我在数据库后端部分中没有看到任何类似的文本。因此，我的问题是:是否有一个后端不可知论的方法，我可以采取旧的任务清理芹菜，如果没有，是否有一个DB后端特定的方法，我应该采取？以防万一我用的是姜戈芹菜。谢谢。
浏览 3提问于2012-10-30得票数 11
回答已采纳
1回答
我使用芹菜w/ Django来处理某个任务，该任务返回需要放入模型记录中的JSON值。现在，我看到了将它保存在Django数据库中的两个选项：
作为任务签名的一部分传入记录的id。然后芹菜可以用它来update记录。
或者，我可以返回任务的结果，并启用芹菜的django-db结果后端，该后端将位于芹菜自己的task_result表中。这意味着我必须在记录中持久化AsyncResult Id，每当客户端请求记录时，我将查找并查看进程是否已经完成。
在我看来，选择1似乎更好，但由于我最近几年没有与芹菜合作，我想知道它是否有缺点，和/或哪种情况更适合选择2。
谢谢!
浏览 3提问于2017-04-13得票数 2
4回答
我感兴趣的是定期定期运行一组特定的操作。显然，这是的任务，对吗？
不幸的是，互联网似乎存在一些分歧。
让我详细介绍一下我的设置。首先，我的开发环境在Windows中，而我的生产环境则托管在 (Linux)上。Windows上没有真正的cron，对吗？而且，我使用！对Django有什么建议？
当然是！不幸的是，设置芹菜对我来说或多或少是一场噩梦--请看。这只是我在芹菜上遇到的问题之一。其他的包括一个套接字错误，我是唯一一个得到这个问题的人。
别误会，芹菜看起来很酷。不幸的是，它似乎缺乏支持，并且在其首选后端中内置了一些奇怪的限制。不幸的是，不管程序多么酷，如果它不能工作，那么它就不能工作！
我希
浏览 3提问于2011-06-08得票数 11
回答已采纳
1回答
我是芹菜的新手，正在尝试理解芹菜中的后端参数。
我尝试了这个文档- ，并且能够执行一个任务。
我在工作窗口中看到了这个结果-
[2015-07-04 15:45:32,633: INFO/MainProcess] Task tasks.add[95eee2f4-8491-4200-8628-30ea131d9777] succeeded in 0.0166970053688s: 20
但是，当我使用后端参数时，我不确定结果存储在哪里。
这是我的后端参数-
app = Celery('tasks', broker='amqp://guest@localhost//'
浏览 2提问于2015-07-05得票数 0
1回答
在芹菜中有没有一种干净的方法来知道它的代理和/或结果后端是否停机？ 我正在使用RabbitMQ broker和Redis后端的芹菜。 目前，我发现的最简单的方法是提交一个虚拟任务，它会在代理宕机时引发kombu.exceptions.OperationalError，并在后端宕机时引发redis.exceptions.ConnectionError。 然而，这感觉有点老生常谈。有没有更好的方法？
浏览 52提问于2019-03-22得票数 0
回答已采纳
1回答
API前端架构
、、、
我想要建立一个网站，是一个前端的API。基本上，前端需要一些用户输入，并使用它来查询API和检索结果。当检索结果时，将显示结果。这都是异步完成的。
我的问题是：
我是否使用像芹菜这样的东西来处理背景中的API查询？
假设我使用AJAX (我将使用AJAX)，我是否有不同的URL来处理用户输入和检索查询结果？
我是否使用像长轮询这样的方法来获取和显示JavaScript的结果？
考虑到检索到的结果可以进一步过滤，我正在考虑使用memcached作为存储。这样合适吗？
如果有什么我错过了，或者有更好的方法，我会很高兴听到它。
编辑:我意识到我用错误的方式解释了需求，所以我会
浏览 5提问于2011-11-30得票数 1
我使用Redis broker和数据库结果后端( Postgres DB )运行Django芹菜，这与我在主应用程序中使用的相同。
最近，我遇到了这样一种情况: Postgres服务器被重新启动，而工作进程失去了它们的DB连接。在这种情况下，即使DB返回并且主Django站点正常响应，也没有芹菜任务再次成功。在进行任何处理之前，我需要重新启动celeryd进程。所有芹菜任务都报告了相同的错误：
DatabaseError: terminating connection due to administrator command
SSL connection has been closed une
浏览 2提问于2013-08-14得票数 3
回答已采纳
我正在尝试通过“任务名称”将一个任务从机器A上的芹菜工人发送到机器B上的芹菜工人。 所有任务都是在机器B上定义的，并且只有一个任务在机器A上。我想向机器A worker传递一个task_name，并在机器B上使用相同的task_name执行任务。 我如何与其他人沟通。 我们在两个工作者中是否保持相同的broker_url？ 我使用Redis作为代理url和结果后端。
浏览 21提问于2018-12-19得票数 2
我目前的争论是，我们是否应该坚持使用Pika来实现RabbitMQ，还是转向芹菜，如果我们使用芹菜，所有的好处是什么。据我所知，芹菜是一个分布式作业队列，它简化了任务分发的管理。它使用代理(RabbitMQ、Redis等)在客户端和工作人员之间发送和接收消息，还可以选择使用后端(如Redis )来存储结果。其中，as RabbitMQ是一个消息队列，可用于异步方式执行作业。最后，如果我们使用RabbitMQ并在python中使用Pika实现它，它将执行相同的任务，即在后台执行长时间运行的进程。
我在使用芹菜时看到的几个优点是：
可以使用后端(如redis)存储每个任务的结果。
更容易实
浏览 5提问于2022-06-28得票数 2
我在Windows Azure中有一个运行Django的Web角色。我有一个要异步运行的耗时的计算，用例如下:客户端发送计算请求，服务器返回一个ID来检查计算结果，然后客户端可以使用该ID在计算结果出来后立即检索该结果。
现在我缺少后端部分，我想使用Windows Azure中的Worker角色来实现这一点。因为我想保持Azure独立，所以我想用芹菜来处理这部分。缺点是我找不到任何关于这个话题的资源。有谁有什么见解吗？
首先要感谢大家！
浏览 2提问于2014-02-06得票数 4
我用Django编写了一个API，目的是作为我们使用的站点后端和外部服务之间的桥梁，这样网站就不必处理对外部API的许多请求(CRM、日历事件、电子邮件提供者等等)。
API主要轮询其他服务，分析结果并将其转发到网站后端。
最初，我选择了一个基于芹菜的任务队列，因为在我看来，这是将处理卸载到另一个实例的正确工具，但我开始认为它并不符合这个目的。
由于该网站期望同步响应，我的代码包含了许多内容：
results = my_task.delay().get()
或
results = chain(fetch_results.s(), parse_results.s()).delay().get()
浏览 1提问于2019-02-28得票数 4
回答已采纳
2回答
我和雷迪斯一起用芹菜。
当前Redis用作代理，并因此作为后端使用。
BROKER_TRANSPORT = 'redis'
BROKER_URL = 'redis://domain:8888/0'
CELERY_RESULT_BACKEND = 'redis://domain:8888/0'
我想澄清几件事：
使用结果后端有什么好处？我是说我用它会得到什么
我怎么才能看到它的作用呢？我是说什么东西会被储存在Redis里吗？那个仓库是永久性的吗？我怎么能质疑呢？那种储存会随着时间等而增长吗？
我能用芹菜花监控结果吗？
浏览 9提问于2016-05-03得票数 15
回答已采纳
1回答
管理芹菜任务成果
、、、
我对芹菜很陌生，我以为我在某个地方读到过，任务的结果只能停留一段有限的时间。然而，我的后端(redis)在运行了许多任务之后变得非常臃肿。
是否有一种在任务结果上设置TTL的方法，或者是我需要手动清除的东西(以及如何)？
浏览 1提问于2015-03-13得票数 9
回答已采纳
我正在使用Django，芹菜和Jobtastic来尝试设置一些任务，我将在我的主要set应用程序上轮询这些任务。我使用RabbitMQ作为我的代理。
问题是，虽然任务在启动Celery后正常显示，但尝试获取状态如下所示：
def get_state(request, task_id):
if request.is_ajax():
task = AsyncResult(task_id)
data = task.result or task.state
print(data)
json_data = json.dumps(da
浏览 25提问于2017-07-08得票数 0
1回答
我已经建立了一个使用芹菜的队列系统，它接受web请求并执行一些任务来处理这些请求。我使用Redis作为芹菜的后端，但我认为这个问题适用于所有后端。
芹菜将任务名称返回为celery-task-meta-<task ID>，并将其存储在后端。这对我来说毫无意义。我怎样才能改变芹菜发送给Redis的结果的名称呢？我已经搜索了所有的试图找出如何做到这一点。
Redis CLI监视器显示芹菜正在使用SETEX方法并发送以下输入：
"SETEX“"celery-task-meta-dd32ded3-00aa-4884-8b21-42f8332e7fac”"86400
浏览 0提问于2019-05-09得票数 1
1回答
我使用的是芹菜3.0.12。
我有两个队列: Q1，Q2。
通常，我将主任务放在Q1中，然后调用Q2中的子任务。我不想存储子任务的任何结果。所以我的子任务有装饰器@celery.task(ignore_results=True)。
我的主任务现在应该等到子任务完成。因为我不写结果。我不能使用: AsyncResult。有没有办法在主任务中等待，直到子任务完成，而不将状态存储到后端。我使用AsyncResults的所有尝试并不都是成功的燃料(它依赖于后端)。get()似乎也依赖于后端。
整个故事都是用代码写的：
@celery.task(ignore_result=True)
def subta
浏览 1提问于2013-01-11得票数 4
回答已采纳
1回答
我有一个芹菜应用程序，它使用后端存储已完成任务的结果。
当任务排队/运行时，我可以获得有关它们的信息，但是在它们完成之后，如何从结果后端获得所有任务I的列表？
我希望在python应用程序中这样做，并且不依赖于特定的后端(例如，将来我可能希望在文件系统和MySQL之间切换作为结果存储)。
浏览 1提问于2017-03-16得票数 1
回答已采纳
我一直在创建一个烧瓶应用程序来处理由用户接收的GNSS数据。在烧瓶应用程序中，数据处理在后端完成。由于GNSS数据处理需要很长时间，目前用户必须等待几分钟才能通过电子邮件获得结果。
因此，我决定把芹菜和烧瓶结合起来。
基于可用的文档，我已经通过下载rabbitmq-server-3.7.3.exe文件在本地C:驱动器上安装了RabbitMQ服务器。
为了学习芹菜与酒瓶的集成，我曾经尝试用以下命令重新启动rabbitmq-server，我遵循了。
服务rabbitmq服务器重启
它给了我以下错误
'service‘不被识别为内部或外部命令、可操作的程序或批处理文件。
创建task
浏览 0提问于2018-03-05得票数 0
1回答
我有许多耗时的任务需要由几台机器来分担。我现在有一台主机器，用芹菜工人来做这项工作。我使用RabbitMQ作为代理，使用redis作为本地运行在该机器中的后端。主计算机还负责部署任务和返回结果。
我想知道是否有可能让从机器远程连接到代理，并在主计算机中产生后端以获取作业，以便所有机器一起工作。我想我只需要配置RabbitMQ和redis设置，然后启动奴隶机器中的芹菜工人。非常感谢。
浏览 0提问于2015-07-16得票数 0
回答已采纳
想看看是否有一种方法可以优化芹菜任务的结果检查过程。
例如，我有以下代码：
for task_id in tasks: # tasks is a list of celery task ids
res = app.AsyncResult(task_id)
if res.successful():
tasks_ids[task_id] = res.result # here I am storing task results
当前方法的问题是，我必须循环处理芹菜任务，并逐一检查它们。而且，除了使用数据库结果后端之外，它还将为每个芹菜任务生成一个查询(至少我认为是这
浏览 3提问于2015-07-30得票数 1
回答已采纳
我们正在使用芹菜eta任务来安排未来(就像几个月)的任务。现在使用rabbitMQ后端，因为mongo后端在工人重新启动时确实释放了这些任务。
实际上，带有rabbitMQ后端的任务在芹菜和rabbitMQ重新启动时似乎是持久的，但是撤销消息似乎在rabbitMQ重新启动时丢失了。我想，如果撤消消息丢失了，那些应该被终止的eta任务无论如何都会执行。
浏览 2提问于2014-04-09得票数 2
回答已采纳
1回答
我的笔记本电脑上有芹菜，而拉比特姆克是经纪人，红葡萄酒是后端。我只是使用了所有的默认设置并运行celery -A tasks worker --loglevel=info，然后所有这些都起作用了。工作人员可以完成任务，而我则通过调用result.get()获取执行结果。我在这里的问题是，为什么即使我根本没有运行回比特My和redis服务器，它也能工作。我也没有在服务器上设置帐户。在许多教程中，第一步是在启动芹菜之前运行代理和后端服务器。
我对这些工具并不熟悉，也不太明白它们是如何在幕后工作的。如有任何意见，将不胜感激。提前谢谢。
浏览 3提问于2015-06-23得票数 1
回答已采纳
我正在使用Django开发一个web应用程序，它使用芹菜处理异步任务，特别是处理事务性电子邮件。
一个在我的电子邮件任务是排定与ETA选项，但它是执行多次并行导致邮件链，非常阳极。我不知道到底是什么原因。我检查了两次Django代码，我确信它只发布了一次。
我使用Redis作为代理/后端结果。
我的芹菜守护进程托管在Heroku上，并通过以下命令启动：
python manage.py celeryd -E -B --loglevel=INFO
谢谢你的帮助。
编辑：我在这里找到了一个有效的解决方案，多亏了#芹菜IRC频道上的一个家伙：
浏览 5提问于2013-02-25得票数 2
回答已采纳
芹菜似乎不能正确处理异常。
如果我有任务：
def errorTest():
raise Exception()
然后我会打电话给
r = errorTest.delay()
In [8]: r.result
In [9]: r.state
Out[9]: 'PENDING'
它会像这样无限期地挂着。
检查日志显示错误抛出在任务中(如果您想要消息，请询问)，我知道后端和一切都设置得很正确，因为其他任务只是正常工作并返回结果。
有没有什么特别的东西需要我去捕捉芹菜中的异常？
/Celery版本是3.0.13，broker是在我的本地机器上运行的RabbitMQ
浏览 0提问于2013-02-05得票数 33
回答已采纳
1回答
芹菜时间统计-任务名称
、、、
我有一些相当繁忙的芹菜队列，但不确定哪些任务是有问题的。是否有一种方法可以聚合结果，以确定哪些任务需要很长时间？我有10-20名员工在2-4台服务器上。
使用redis作为代理，并将其作为结果后端。我注意到了Flower上的繁忙队列，但不知道如何将每个任务的时间统计数据聚合起来。
浏览 2提问于2016-05-30得票数 6
1回答
我有一些芹菜工人将他们的结果存储在一个MongoDB后端。看来效果很好。但是，我还需要将唯一的taskID (以及其他一些任务结果元数据)存储在Neo4J图形数据库中。
我的主要目标是在不混淆数千个结果的情况下，引用来自Neo4J内部的任务结果。因此，Neo4J为任务结果提供可视化功能。
我需要一些关于用芹菜实现这一目标的最佳方法的建议。
以下是我一直在考虑的一些选择：
使用芹菜的子任务，并创建单独的任务，由不同的工作人员处理，以发送数据到Neo4J。
使用芹菜的HTTP回调任务(Webhooks)将数据直接发布到Neo4J的REST
扩展主要任务以包括对Neo4J的REST的调用
浏览 0提问于2013-09-17得票数 1
回答已采纳
1回答
在我们的环境中，我们在AWS上使用RabbitMQ和芹菜在多个节点上并行运行任务。
最近，我们将RabbitMQ转换为一个由3个节点组成的集群，配置了一个ha策略，并在所有3个节点中添加了一个用于端口5672的AWS弹性负载平衡器(ELB)。我们的芹菜工人和客户代码都使用ELB DNS作为代理URL。
我们注意到，自该更改以来，等待异步任务完成将引发异常IOError: Socket closed。
ELB将在60秒后关闭所有空闲连接。我们有几个小时才能完成的任务。
在员工端将BROKER_HEARTBEAT设置为低于60个已解决连接下降值。但是我们似乎找不到任何能保持客户端连接活动的设置。
浏览 2提问于2016-12-08得票数 15
2回答
我有一个任务链：
result = celery.chain(task_a.s(), task_b.s())()
我只对task_b()的结果感兴趣，然而芹菜将task_a()和task_b()的结果保存到后端。
有没有办法只存储task_b()的结果
浏览 3提问于2019-06-06得票数 2
1回答
这个问题是一个非常严重的内存泄漏，直到服务器崩溃(或者您可以通过杀死芹菜工人服务来恢复，该服务释放所使用的所有RAM )。
在这件事上似乎有一堆报告中的bug，但是在芹菜API文档中很少注意到这个警告。
警告:后端使用资源存储和传输结果。为了确保资源得到释放，最终必须在调用任务后返回的每个 AsyncResult实例上对上的每个AsyncResult实例进行调用get()或遗忘()。
可以合理地假定泄漏与此警告有关。
但是，根据我对芹菜的理解，概念上的问题是，AsyncResult实例是在用户会话中的多个Django视图中创建的:一些是在启动/生成一个视图中的新任务时创建的，另一些则是稍后手动
浏览 0提问于2019-02-25得票数 2
我不知道result_expires是如何工作的。
我读过，
result_expires
默认值:1天后到期。
存储任务墓碑后的时间(以秒或时间增量对象为单位)将被删除。
在此之后，内置的定期任务将删除结果(celery.backend_cleanup)，前提是启用芹菜节拍。这项任务每天凌晨4点开始。
..。
当使用数据库后端时，芹菜节拍必须运行以确保结果过期。
(出发地：)
所以，为了让这件事起作用，我必须做这样的事情：
python -m celery -A myapp beat -l info --detach
这就是文档所指的“芹菜节拍是启用的”吗？或者，不需要手动执行该配
浏览 2提问于2018-12-12得票数 1
回答已采纳
2回答
当启动芹菜时，它会重试连接到我的rabbitmq代理，这给了它必要的时间加载。这很好，因为我使用的是docker，我不能保证服务启动的顺序，也不能保证什么时候服务会启动。
然而，在试图连接到我设置为结果后端的本地mysql服务器时，芹菜并没有使用相同的怜悯措施，而是立即死亡，并合理地抱怨它无法锁定mysqld套接字：
OperationalError: (2002, "Can't connect to local MySQL server through socket '/var/run/mysqld/mysqld.sock' (2)")
我想在放弃之前
浏览 3提问于2017-08-21得票数 6
回答已采纳
1回答
我集成了芹菜来分发任务，并使用Redis作为结果后端。现在一切都正常了。但是在运行了一些任务之后，Redis充满了已经阅读过的结果。如何在阅读后删除这些结果。
我想要这样的东西：
async_result.get_and_delete()
浏览 1提问于2017-01-06得票数 4
回答已采纳
1回答
php中唯一的芹菜工作库是gjedeer/celery-php，它不支持redis作为后端。https://github.com/gjedeer/celery-php/issues/9 你有什么办法在php中得到结果吗？
浏览 9提问于2021-01-19得票数 0
回答已采纳
1回答
我目前正在为我的工作探索芹菜，我正在尝试建立Elasticsearch后端。是否有任何方法将结果值作为字典/JSON而不是文本发送？因此，Elasticsearch中的结果将被正确显示，并且可以使用嵌套类型？
芹菜自动制图
{
"celery" : {
"mappings" : {
"backend" : {
"properties" : {
"@timestamp" : {
"type" : "d
浏览 0提问于2019-07-24得票数 1
我正在建设一个任务的网站，需要相当长的时间来处理，并需要大量的计算。我编写了代码，以便任务能够提供部分输出(产生结果)。我使用芹菜工人在另一台机器上运行任务，并设置使用update_state()发送更新的任务。
我的celery_tasks.py文件是这样的
@celery.task(name="my_task")
def my_task():
final_output = []
for output_part in long_process():
my_task.update_state(state="PROGRESS", m
浏览 4提问于2021-11-01得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
