在我的一个芹菜任务中，我正在创建数据库条目。我知道如何读取我的芹菜任务的状态： from celery.result import AsyncResultres.ready() 但是我想知道到底哪个数据库条目是使用芹菜任务ID
浏览 24提问于2019-12-12得票数 0
回答已采纳
1回答
使用Celery时，您可以使用i.inspect()查找活动任务、已调度的任务和所有已注册的任务。但是，我禁用了预取，因此一次只有一个作业注册到一个worker。如何访问队列中没有注册工人的所有作业的列表？
浏览 4提问于2019-08-09得票数 1
回答已采纳
如果我有一个定义如下的函数： return x+ysome_unique_task_id = celery.beat.schedule_task(add, run_every=crontab(minute="*/30"))我还想
浏览 4提问于2012-04-18得票数 54
回答已采纳
2回答
我想开发一个应用程序，它监视数据库中的新记录，并允许我在插入新记录时在Django应用程序的上下文中执行方法。我计划使用一种方法，在这种方法中，Celery任务检查数据库自上次检查以来的更改，并触发上述方法。注意:这些更
浏览 1提问于2013-03-30得票数 1
1回答
在完成一项任务后，celery将其写入redis。然而，条目的关键字是由celery本身决定的(我认为它是任务id)。我想给出具体的名称，因为这是其他服务知道自己的位置的方式。在我的代码中，有一个生产者来创建任务，还有许多工作者。现在，我在所有任务完成后使用tasks_name.get()，并使用我的<
浏览 9提问于2020-12-11得票数 0
回答已采纳
我的问题是节拍调度器不会存储'tasks‘和'workers’表中的条目。我用姜戈和芹菜。在我的数据库(MySQL)中，我添加了一个间隔为120秒的周期性任务"Estimate Region“。下面是我如何启动我的worker：启动work
浏览 2提问于2013-05-23得票数 1
回答已采纳
我想在芹菜+ RabbitMQ broker上实现带有清理过程的任务取消。如何在芹菜工人中获取当前任务的“已撤销”状态？# tasks.py -- celery workerapp = Celery('tasks', broker='amqp://guest@localhostreturn x + y
# cal
浏览 1提问于2015-03-05得票数 1
我编写了一个简单的应用程序，它可以在线获取股票报价，并发布买卖订单。现在这一切都是通过控制台完成的。我阅读并学习了几本关于Flask网络应用的教程。但我不知道如何在获取信息同时显示在Flask应用程序上的同时运行服务器。
浏览 4提问于2017-11-07得票数 0
B实现了一些功能，并且具有很重的依赖性。以前，我可以愉快地使用send_task按名称调用B。现在，我有了更复杂的逻辑，并希望使用canvas来编排任务。遵循用户指南：signature('tasks.add', args=(2, 2), countdown=10)如何按名称注册任务？
浏览 1提问于2018-08-10得票数 0
2回答
我有一个对文本进行分类的程序，并希望在我的django站点的前端与用户进行交互。问题是，程序加载训练集并开始运行需要20秒，而这并不是每次有人输入都可行的。
浏览 5提问于2011-03-06得票数 1
回答已采纳
2回答
使用Django安排电子邮件？
、、、、
我想使用Django计划电子邮件。示例->我想每天下午5:00向注册用户发送购物车信息。如果可能，请分享一些代码。否则，关于如何实现这一点的详细信息就可以了。
浏览 10提问于2019-10-29得票数 0
1回答
芹菜任务撤销被存储在内存中，因此当工作人员重新启动时，它不会持久。在芹菜文档中，可以使用命令celery -A proj worker -l info --statedb=/var/run/celery/worker.state持久化。但是当我运行这个命令时，没有找到错误文件，所以我创建了这个文件，我再次运行了这个命令，但是它告诉我不能确定db类型。
我试图查找如何设置持久数据库在芹菜中使用，但
浏览 0提问于2018-06-08得票数 2
回答已采纳
1回答
芹菜:任务调用后清理数据库
、、、、
我想在Django用pytest测试芹菜任务。
{OperationalError}数据库表被锁定(sqllite)。如果我在测试之前运行worker，并且不使用celery_worker参数，那么任务就会连续运行，但是当所有更新到原始数据库的链接时，我无法在测试数据库(pytestmark = pytest.mark.django_db我尝试
浏览 0提问于2018-06-22得票数 1
回答已采纳
4回答
我正在尝试为我的Django应用程序中的一些芹菜任务编写一些单元测试。这些任务以模型id作为参数，做一些事情，然后更新模型。在运行devserver和celery worker时，一切都运行得很好，但在运行我的测试时，很明显celery任务没有使用在测试运行过程中创建和销毁的django test db。问题是，如何让celery使用</
浏览 0提问于2014-03-01得票数 17
我有一个设置，其中celery_result_backend已配置为“amqp”。我可以在日志中看到我的任务被工作人员执行。但是它正在使用任务id创建队列，但是它的状态是expired.I。我尝试了所有支持的后端: 1)Mysql:它没有将数据放到celery创建的表中2) Redis:它没有把数据放到数据库中
我是两分制。1)调用delay方法
浏览 2提问于2015-07-28得票数 0
4回答
目前，我在Azure实例上设置了带有作业计划程序的定期任务。它们在固定时间触发API (Django)端点。在观察了芹菜之后，看来使用是可行的。使用，是否可以根据我的数据库中的值来设
浏览 0提问于2018-05-11得票数 5
回答已采纳
2回答
我练习django-celery#import datetime# 'hello_task': { },我首先尝试hello_task计划，然后评论它并尝试add-every-30-seconds所以我检查了数据库，发现它保存在它的记录中。还是我把它从<
浏览 8提问于2015-11-04得票数 3
回答已采纳
我有一个FastApi 应用程序，它使用Beanie作为我的odm，并为<code>E 110</code>异步<代码>E 211</代码>任务<代码>E 112</代码>在<code>E 213</code><code>E 114</code>芹菜工作人员<code>E 215</code>内创建一个运行事件循环<
浏览 18提问于2022-10-20得票数 0
回答已采纳
1回答
我的django web应用程序逻辑非常适合后台任务的执行(包括周期性的和独立的、同步的和异步的)。所有的研究似乎都指出使用芹菜是最推荐的方法。现在我很困惑如何把我的桌子和芹菜连接起来。理想情况下，我想做的是拥有我自己的作业模型，它有时间表，任务到期时应该运行，以及任务的参数。类似于C++中的
浏览 3提问于2012-11-30得票数 1
回答已采纳
3回答
我是芹菜和django的新手，所以请原谅我缺乏知识。我正在尝试运行一个测试来做一些计算，并等待测试完成，这样我就可以确保它是为正确的答案完成的。= calculate.apply_async(args=[1])
while not calculate.AsyncResult(c.id).status == "SUCCESS": passfrom ce
浏览 3提问于2014-06-11得票数 19
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
