celery:打印以apply_async开头的组内每个任务的状态
Celery是一个基于Python的分布式任务队列框架，用于实现异步任务的调度和执行。它可以将任务分发到多个工作节点上并进行并行处理，提高系统的吞吐量和响应速度。
Celery的主要特点包括：
- 分布式架构：Celery支持将任务分发到多个工作节点上进行并行处理，可以实现任务的分布式调度和执行。
- 异步执行：Celery使用消息队列来实现任务的异步执行，任务提交后即可返回，不需要等待任务执行完成。
- 定时任务：Celery支持定时任务的调度，可以按照指定的时间间隔或时间点执行任务。
- 任务结果追踪：Celery可以追踪任务的执行状态和结果，可以通过任务ID获取任务的执行情况。
- 任务优先级：Celery支持设置任务的优先级，可以根据任务的重要性和紧急程度进行调度。
Celery的应用场景包括：
- 异步任务处理：Celery可以用于处理一些耗时的任务，如发送邮件、生成报表、图片处理等，将这些任务放入任务队列中异步执行，提高系统的响应速度。
- 定时任务调度：Celery可以用于定时执行一些重复性的任务，如定时备份数据、定时清理缓存等。
- 分布式计算：Celery可以将计算任务分发到多个节点上进行并行处理，提高计算效率。
腾讯云提供了一个与Celery类似的产品，称为TDMQ（Tencent Distributed Message Queue），它是一种分布式消息队列服务，可以实现任务的异步处理和分布式调度。您可以通过TDMQ来实现类似Celery的功能。
更多关于TDMQ的信息，请访问腾讯云官方网站：TDMQ产品介绍
相关·内容
我对芹菜很陌生，我想要实现一个包含四个任务的链的基本示例。第一个任务将其返回值传递给链中的下一个任务，依此类推。在运行芹菜工人时，我发现了以下错误：
ERROR/ForkPoolWorker-4] Task run-chain[...] raised unexpected: TypeError("unsupported operand type(s) for |: 'chain' and 'AsyncResult'")
下面是我与任务的简单链：
from celery import chain, signature
from celery imp
浏览 8提问于2022-09-27得票数 0
回答已采纳
我正在开发一个使用REST API的Django应用程序。API请求执行一个长时间运行的Celery画布任务(任务链-将输入保存到数据库，执行计算，然后将计算结果保存到数据库)。这个长时间运行的任务依赖于用户的输入。现在，我想添加一个功能，方便用户在自己给定的特定时间执行这个长时间运行的任务，那么我该怎么做呢？ 也就是说，假设有2个用户使用自己的一组输入参数发出相同的API请求，并且用户1希望将其任务安排在上午5:00执行，用户2在上午7:30执行我如何才能做到这一点？ 前端:角度 后端: MySQL，Python (Django，Celery) 在这方面的任何帮助都将受到高度的感谢。
浏览 11提问于2020-06-23得票数 0
回答已采纳
我正在运行一个具有三个芹菜pod的Kubernetes集群，使用一个Redis pod作为消息队列。Celery版本4.1.0，Python 3.6.3，helm的标准Redis pod。
在看似快速涌入的任务中，芹菜豆荚停止处理任何任务。它们在最初的几个任务中会很好，但最终会停止工作，我的任务就会挂起。
我的任务格式如下：
@app.task(bind=True)
def my_task(some_param):
result = get_data(some_param)
if result != expectation:
task.retry(throw=
浏览 12提问于2018-01-17得票数 2
回答已采纳
1回答
我想用标准的方式把芹菜的任务链起来。
我有一个json文件。在该文件中，有许多经过硬编码的urls。我需要废除这些链接，加上废弃的链接，这是找到的，同时刮这些链接。
目前，我就是这样做的。
for each_news_source, news_categories in rss_obj.iteritems():
for each_category in news_categories:
category = each_category['category']
rss_link = each_category['feed']
浏览 1提问于2015-02-05得票数 0
2回答
我正在尝试使用以下代码向celery提交大约1.5亿个作业：
from celery import chain
from .task_receiver import do_work,handle_results,get_url
urls = '/home/ubuntu/celery_main/urls'
if __name__ == '__main__':
fh = open(urls,'r')
alldat = fh.readlines()
fh.close()
for line in alldat:
浏览 0提问于2019-08-22得票数 1
1回答
我有两个任务-- a和b。
任务a在完成上一个任务a后的5分钟内运行。
在完成上一个任务b后，任务b在3分钟内运行。
我如何实现它？我用的是python 3.6.8、Django 2.2.6和celery 4.3.0
浏览 14提问于2019-10-31得票数 1
回答已采纳
我有一个定制的芹菜任务类，然后在装饰器@celeryApp.task中使用。我使用apply_async执行这些任务。
我的任务是：
class CeleryTask(Task):
def run(self, *args, **kwargs):
pass
def on_success(self, retval, task_id, args, kwargs):
pass
def on_failure(self, exc, task_id, args, kwargs, einfo):
pass
然后我宣布我的任务如下：
@
浏览 2提问于2019-07-19得票数 1
回答已采纳
1回答
我设置了一个django芹菜，并且我从rabbitmq切换到使用SQS作为代理。我发现用routing_key值装饰的任务没有在代理中生成消息？
设置为：
CELERY_QUEUES = {
"default": {
"exchange": "default",
"binding_key": "default"},
"sentry": {
"exchange": "default",
&
浏览 2提问于2013-05-18得票数 1
1回答
基于。
我称连锁为：
chain = (nice_task.s(a=1) |
task2.s(a=2)).apply_async()
任务定义为：
@celery.task(bind=True)
def nice_task(self, a):
print a
print self.request.id # None
return a
如何在链内获取任务标识？
我试着打开/关闭CELERY_ALWAYS_EAGER --没有效果。
UPD self.request也有空context。
浏览 1提问于2016-03-26得票数 2
所有人。
app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379/0'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379/0'
celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
def upload():
if checkDou
浏览 0提问于2020-01-29得票数 0
回答已采纳
1回答
在完成一项任务后，celery将其写入redis。然而，条目的关键字是由celery本身决定的(我认为它是任务id)。我想给出具体的名称，因为这是其他服务知道自己的位置的方式。 在我的代码中，有一个生产者来创建任务，还有许多工作者。现在，我在所有任务完成后使用tasks_name.get()，并使用我的命名约定创建新的redis条目。但这似乎是如此的不必要和缓慢。芹菜应该用我的惯例。 我正在考虑给它们重命名，但如果可行的话。如何从producer接收ids。也许是一些自定义的RedisBackend类，但这太深了。
浏览 9提问于2020-12-11得票数 0
回答已采纳
1回答
这是我的密码。我希望将任务、myname、结果传递作为参数传递给签名中的任务反向。
这是我的密码。我希望将任务、myname、结果传递作为参数传递给签名中的任务反向。
from app import app
from app import app
from time import sleep
from celery.utils.log import get_task_logger
import os
from celery import signature, chain, group, chord
from celery.result import allow_join_result
My
浏览 9提问于2022-06-21得票数 1
回答已采纳
我的settings.py
INSTALLED_APPS = (
'django.contrib.admin',
'django.contrib.auth',
'django.contrib.contenttypes',
'django.contrib.sessions',
'django.contrib.messages',
'django.contrib.staticfiles',
'FBIsystem',
'
浏览 0提问于2019-07-12得票数 0
回答已采纳
我有三项芹菜任务：
predictiontraininghealthcheck
我在机器里有4个cpus。我想分配3名工人用于预测和培训，1名用于健康检查。实现这一点的最简单方法是什么？请注意，我将安排这些任务，因此不能直接在apply_async()函数中指定工作人员的数量。
实际吐露：
CELERY = Celery(
CELERY_APP_NAME,
backend=CELERY_BACKEND,
broker=CELERY_BROKER,
include=["src.tasks"],
)
CELERY.conf.update({"
浏览 4提问于2020-09-01得票数 1
回答已采纳
1回答
我最近在我的一个应用程序中集成了 (更具体地说是)。我在应用程序中有一个模型，如下所示。
class UserUploadedFile(models.Model)
original_file = models.FileField(upload_to='/uploads/')
txt = models.FileField(upload_to='/uploads/')
pdf = models.FileField(upload_to='/uploads/')
doc = models.FileField(upl
浏览 0提问于2013-01-02得票数 11
回答已采纳
我正在尝试打印4个远程任务的状态，从组中的每个AsyncResult获取信息。 到目前为止，我可以打印状态，但不能打印产生(或尚未产生) AsyncResult的任务的名称(参见下面的控制台打印) 我遇到的另一个问题是，虽然组是用apply_async(expires=30)启动的，但没有过期，只要有一个子任务“挂起”，循环就会永远继续下去。 from celery import group
ping_results = group(
ping_portal.s(),
ping_factory.s(),
ping_factory_m.s(),
ping_pr
浏览 23提问于2019-05-04得票数 0
最近，我创建了一个芹菜项目，整个项目如下所示
proj
|-- math
| |-- tasks.py (add)
|
我用‘芹菜-A proj worker -l info’的命令启动了一个工人；
-------------- celery@Jacky v3.1.15 (Cipater)
---- **** -----
--- * *** * -- Windows-7-6.1.7601-SP1
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app: XXXX:0x40706d
浏览 1提问于2014-10-09得票数 0
1回答
我想使用celery来执行apply_async任务，但是我的参数是一个使用ISO-8859-1编码的文件，但是celery序列化数据使用了UTF-8。 我使用以下代码从一个url接收文件： import urllib
data = urllib.request.urlopen(url)
content = data.read()
update_task.apply_async([content]) 当我尝试调用这个方法时，我得到了这个错误： UnicodeDecodeError：“utf-8”编解码器无法解码字节
浏览 13提问于2019-01-09得票数 0
2回答
在celery中有没有什么方法可以让我在任务执行失败的时候自动将它放到另一个队列中。
例如，如果任务在队列x中运行，则在异常情况下，将其入队到另一个名为error_x的队列中
编辑：
目前我使用celery==3.0.13和Django1.4，Rabbitmq作为代理。
有时任务会失败。在celery中有没有一种方法可以将消息添加到错误队列中，并在以后处理它。
当celery任务失败时，问题是我没有访问消息队列名称的权限。所以我不能使用self.retry重试把它放到不同的错误队列中。
浏览 1提问于2014-07-24得票数 4
1回答
我们已经启动了一个芹菜工人从Rabbitmq读取数据(一个队列)：
celery -A tasks worker -c 1 (一个进程)
我们发送给RabbitMq 2个链(每个链3个任务)：
chain(*tasks_to_chain1).apply_async() (我们称它为C1，它的任务C1.1，C1.2，C1.3)
chain(*tasks_to_chain2).apply_async() (我们称它为C2，它的任务C2.1，C2.2，C2.3)
我们预计任务将按以下顺序运行: C1.1，C1.2，C1.3，C2.1，C2.2，C2.3。
然而，我们看到的是: C1.1，C2.1，C
浏览 0提问于2021-09-24得票数 0
1回答
我试图通过在pytest套件上运行.delay命令来测试任务：
def test_selected_rows_are_blocked(celery_worker):
id, select_only = 0, ['a', 'b']
tasks.update_table.delay(id, select_only)
# some code here that should be called as soon as task gets started
因此，任务可以运行，但是后面的代码可以同步运行。celery_worker工具使用我
浏览 6提问于2022-07-12得票数 1
1回答
异步任务的芹菜任务注册表
、、、、
我不知道如何以模块化的方式定义芹菜任务(即不是所有的任务都在同一个文件中)，并正确地注册它们以供异步使用。我已经试过了所有我能想到的选择：
使用基于装饰器的任务
使用基于类的任务
在芹菜应用程序对象上使用autodiscover_tasks
手动注册任务，即基于类的任务的app.tasks.register(Task1())
在与celery_app.py相同的目录中执行芹菜工人
在包含celery_app.py的目录中执行芹菜工人
使用celery worker选项为-A命令指定应用程序。
没有为芹菜工人指定应用程序
在基于类的任务中指定空的"na
浏览 2提问于2017-11-01得票数 2
回答已采纳
1回答
我正试着用芹菜来执行一项任务。我需要在用户按下send按钮时向远程服务器发送post请求，因此我尝试在设置文件中使用带有Redis的芹菜配置：
BROKER_URL = os.environ.get("REDIS_URL")
CELERY_RESULT_BACKEND = os.environ.get("REDIS_URL")
CELERY_ACCEPT_CONTENT = ["application/json"]
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER =
浏览 5提问于2021-12-17得票数 1
回答已采纳
我在学习芹菜组的功能
@celery_app.task
def celery_task():
import time
time.sleep(30)
print('task 1')
@celery_app.task
def celery_task2():
import time
time.sleep(10)
print('task 2')
@celery_app.task
def test():
from datetime import datetime
print(datetime.now())
浏览 3提问于2020-05-02得票数 1
回答已采纳
我试图设置一个芹菜任务，使用SQS作为代理。我能够使用以下方法(最低可再生产)使其工作：
from celery import Celery
app = Celery('tasks', broker=f'sqs://{aws_access}:{aws_secret}@')
@app.task
def test(s):
print(s)
我运行这个celery -A tasks worker --loglevel=INFO，然后通过以下方式从shell调用它：
from tasks import test
test.delay('printme&#
浏览 0提问于2019-07-16得票数 0
1回答
我正在尝试编写一个基本任务类，它将在执行某些操作之前检查工作人员的可用性。通过阅读这里的帖子，我得到了以下内容：
class BaseTask(Task):
def apply_async(self, *args, **kwargs):
if not celery.control.inspect().stats():
raise Exception("workersDown")
Task.apply_async(self, *args, **kwargs)
然而，这似乎只是第一次起作用。我知道一个，但它是相关的吗？
浏览 0提问于2014-07-31得票数 1
我正在尝试创建一个芹菜和弦来运行一个任务作为回调，即当队列中的其他人被标记为完成时。
问题是我仍然有这个错误：KeyError: 'kwargs'，我不知道为什么。
下面是我的代码：
@celery_app.task(
base=Base,
bind=True,
ignore_result=True
)
def callback(self, date=None, queries=[], user_email=None, db_session=None, prestodb_session=None):
# Do something
chai
浏览 1提问于2018-08-28得票数 0
1回答
我和一个芹菜工人一起创建了一个烧瓶API。用户触发“开始测试”按钮，该按钮发出一个POST请求，返回url，用户可以使用该url来每5秒获得测试结果(需要更新字体进度栏)。芹菜的任务包括穿线。我的目标是根据线程一致的结果更新芹菜任务状态。我不想等到所有线程完成后才返回它们的结果。我的芹菜任务看起来是这样的：
@celery.task(bind=True) # bind argument instructs Celery to send a "self" argument and use it to record status updates
def run_tests(sel
浏览 1提问于2020-06-05得票数 0
回答已采纳
1回答
我创建了一个芹菜任务如下
import os
import time
from celery import Celery
from dotenv import load_dotenv
load_dotenv()
celery = Celery(__name__)
celery.conf.broker_url = os.environ.get("CELERY_BROKER_URL")
celery.conf.result_backend = os.environ.get("CELERY_RESULT_BACKEND")
@celery.task(name
浏览 4提问于2022-08-08得票数 0
回答已采纳
虽然send_task和apply_task方法的语法不同，但它们有类似的参数。具有队列名称的send_task无法在与apply_async一起工作的地方工作。
task_routes={'celery_tasks.send_email': {'queue': 'email'}})
有什么不同吗？文档显示，这两种方法是相同的。
浏览 5提问于2022-09-20得票数 0
我有这个芹菜的设置：
WORKER_MAX_TASKS_PER_CHILD = 1
TASK_TIME_LIMIT = 30
当我运行一组任务时：
from celery import group, shared_task
from time import sleep
@shared_task
def do_something(arg):
sleep(60)
return arg*2
group([do_something.s(i) for i in range(3)]).apply_async()
我在小组中得到TimeLimitExceeded，然后工人立刻被芹菜杀死。
浏览 7提问于2020-05-01得票数 0
回答已采纳
当用户浏览我的网站时，我试图在后台运行一些任务，但每当我使用Celery调用函数时，它似乎都是同步执行的，而不是异步执行的。
例如，当我调用function.delay()时，整个站点挂起，直到function.delay()返回。以类似方式调用函数的其他方法(apply_async、子任务)也存在同样的问题。
我猜Django或Celery中的某些东西配置错误，但我不知道它是什么。
Settings.py中的芹菜配置：
import djcelery
djcelery.setup_loader()
CELERY_RESULT_BACKEND = "amqp"
CELERYB
浏览 2提问于2011-09-22得票数 4
1回答
假设我有一个模型Event。我想发送一个通知(电子邮件，推送，任何)给所有被邀请的用户一旦事件已经过去。与…有关的东西：
class Event(models.Model):
start = models.DateTimeField(...)
end = models.DateTimeField(...)
invited = models.ManyToManyField(model=User)
def onEventElapsed(self):
for user in self.invited:
my_notificati
浏览 3提问于2020-02-27得票数 11
回答已采纳
1回答
我有一个类扩展了celerys Task。它在旧风格的API中运行得很好，但是我在将它转换成新API时遇到了问题。
# In app/tasks.py
from celery import Celery, Task
celery = Celery()
@celery.task
class CustomTask(Task):
def run(self, x):
try:
# do something
except Exception, e:
self.retry(args=[x], exc=e)
然后我
浏览 1提问于2013-07-12得票数 2
回答已采纳
2回答
我在芹菜上遇到了一个很奇怪的问题：
有一条任务链，其中一条给出了异常，并进行了几次重试。
chain = (err.si(1) | err.si(2))
result = chain.apply_async()
result.state
result.get()
以下是任务的代码：
@celery.task(base=MyTask)
def err(x):
try:
if x < 3:
raise Exception
else:
return x+1
except Exception as exp:
print "retr
浏览 2提问于2012-09-30得票数 7
回答已采纳
我想在启动时发送一个链式任务，就像在这个问题中一样，但是任务不正常。
工人的原木
[2022-07-12 20:51:47,369: INFO/MainProcess] Task task.add_newspapers[5de1f446-65af-472a-a4b6-d9752142b588] received
[2022-07-12 20:51:47,372: WARNING/MainProcess] Now Runing Newspaper Function
[2022-07-12 20:51:47,408: INFO/MainProcess] Task task.check_tasks_
浏览 9提问于2022-07-12得票数 1
堆叠：
django = "==2.2.2“
姜戈-芹菜-节拍= "==1.4.0“
芹菜= "==v4.3.0rc1“
python_version = "3.7“
我有一个类，它从csv/xls文件中导入一些数据并保存da数据，下面是我的芹菜配置：
CELERY_TASK_ALWAYS_EAGER = False
CELERY_BROKER_URL = config('REDIS_BROKER_URL')
CELERY_RESULT_BACKEND = config('REDIS_RESULT_URL'
浏览 0提问于2019-08-16得票数 1
2回答
这是我的芹菜任务
def task_a(arg1, arg2, arg3, arg4)
我将这个任务命名为如下
arg1是列表，arg2,3,4是整数
task_a.apply_async(arg1, arg2, arg3, arg4)
我收到了一条错误消息
File "/opt/envDjango/lib/python3.5/site-packages/celery/app/task.py", line 518, in apply_async
check_arguments(*(args or ()), **(kwargs or {}))
TypeEr
浏览 2提问于2018-05-09得票数 8
回答已采纳
2回答
我对芹菜很陌生。我想并行地运行demo_task，但是它以顺序而不是并行的方式运行任务。如果我做错了什么请告诉我。
import time
from celery import Celery
from celery import chain, group, chord, chunks
import pandas as pd
CONFIG = {
'BROKER_URL': 'redis://localhost:6379/0',
'CELERY_RESULT_BACKEND': 'redis://localhost:637
浏览 14提问于2022-04-22得票数 0
回答已采纳
2回答
我有一个名为tasks.py的python文件，其中我定义了4个单个任务。我想配置芹菜，以便使用4个队列，因为每个队列都分配了不同数量的工作人员。我读到我应该使用route_task属性，但我尝试了几个选项，但没有成功。
我在跟踪这个医生
我的目标是运行4个工人，每个任务一个，不要在不同的队列中混合来自不同工人的任务。有可能吗？这是个好方法？
如果我做错了什么，我很乐意修改我的代码以使它工作。
到目前为止，这是我的配置
tasks.py
app = Celery('tasks', broker='pyamqp://guest@localhost//')
app.
浏览 3提问于2017-03-22得票数 3
回答已采纳
2回答
Celery -异步任务链
、、、、
我正在尝试开发一个概念验证，以便在使用芹菜和redis作为代理的情况下进行异步任务链。
该程序是带有集合的Flask API和三个需要作为异步任务运行的函数，例如从a()返回，是b()的参数，返回b()是c()的参数，c()通过集合对象‘/run’将数据写入mongodb集合。
@celery.task
def a(param):
print("Original: {0}".format(param))
print("Inside Task 1")
param.update({"timestamp_A":str(datet
浏览 13提问于2018-01-15得票数 3
回答已采纳
1回答
我刚开始学习芹菜，我一直在学习西芹，我的芹菜安装与码头有关，我在发送和执行芹菜任务时遇到了问题。
所以有4个码头集装箱，一个用于兔子服务器，一个用于芹菜生产服务器和2个工人。
芹菜任务档案：
"""
CELERY MAIN FILE
"""
from celery import Celery
from time import sleep
celery_obj = Celery()
celery_obj.config_from_object('celery_config') #config file we created in
浏览 5提问于2022-01-12得票数 0
1回答
我想让celery等待特定的任务完成，因此我在celery本身旁边安装了celery-results backend。但我不明白如何编写任务调用才能等待，因为我目前收到以下错误： example_task() missing 1 required positional argument: 'user_pk' views.py： def example(request):
user = request.user
if request.method == 'GET':
result = example_taks.apply_asyn
浏览 11提问于2020-03-29得票数 1
回答已采纳
1回答
芹菜链的克隆
、、
我有一个有趣的问题，试图克隆一个芹菜链，以便在一个群体中使用，我的意图用例类似于group([chain.clone(args=args) for args in it])，但是它总是抱怨没有足够的论据。
我已经用下面的方法把这个分解了
在名为tasks.py的文件中
@app.task
def add(x,y):
return x+y
然后从python壳中
>>> from tasks import add
>>> chain=add.s()|add.s(1)
>>> chain
magic_carpet.celery.add(
浏览 1提问于2018-11-14得票数 3
回答已采纳
遵循上的答案
我得到了一个错误，芹菜似乎将任务签名链转换为字典，导致了下面的错误。
芹菜- 4.4红葡萄酒- 3.3.11
代码-来自@bigzbig
@celery_app.task
def task_one():
return 'OKIDOKI'
@celery_app.task
def task_two(str):
return f'{str} YOUPI'
@celery_app.task
def task_three(str):
return f'{str} MAKAPAKA'
@celery_app.ta
浏览 4提问于2020-03-23得票数 0
1回答
以下是Django芹菜(使用Amazon )的任务。
@task
def upload_task(request, **kwargs):
file = request.FILES['file']
ContactCSVModel.import_from_file(file)
return True
这似乎是可行的，即该文件已成功地添加到我的数据库中，但我不确定它是否使用芹菜。我怎么知道这是否有效。我该看看什么吗？在终点站我跑了..。
manage.py celery worker --loglevel=info，它说我有一项任务叫做contacts.tas
浏览 0提问于2013-03-14得票数 0
回答已采纳
我第一次用芹菜。查看文档，我似乎已经尝试了使用apply_async正确执行任务的所有方法。我从一个信号方法调用任务，所以它在signals.py中。
signals.py
from django.db.models.signals import post_save
from django.dispatch import receiver
from datetime import datetime, timedelta
from games.models import Game
from contacts.models import Contact
from msgs.models impo
浏览 8提问于2018-07-25得票数 0
回答已采纳
我启动了一个任务，定期更新它的状态并观察结果，但是在调用端的第二个周期之后，程序抛出了一个BacklogLimitExceeded异常(任务本身在一段时间后成功完成)
主叫方：
task = signature("worker.taskname", args=(url, ), queue="worker")
g = group(task).apply_async()
while not g.ready():
print(g[0].result)
time.sleep(5)
任务端：
浏览 2提问于2015-07-26得票数 5
我肯定这是在什么地方注意到的，但我正在旋转我的车轮，所以希望这里有人能帮忙。
我正在使用一个使用芹菜的烧瓶应用程序，我正在用Pytest进行测试。以下是两个测试：
def test_celery_tasks_countdown_apply_async(celery_app, celery_worker):
r1 = add.apply_async((4, 4), countdown=2)
r2 = multiply.apply_async((4, 4), countdown=2)
assert r1.get(timeout=10) == 8
assert r2.
浏览 4提问于2022-06-01得票数 0
1回答
芹菜任务状态显示待定
、、、
我正在与芹菜工作，我得到的任务状态是待定的，可能是执行问题。请检查我的密码。
我试图在mongodb数据库中保存任务信息，如id、name、status，为此，我使用任务调用的函数来保存mongodb中的数据。
因为函数调用发生在任务返回语句之前，所以我的任务挂起了吗？？
settings.py
CELERY_BROKER_URL = 'mongodb://localhost:27017/jobs'
CELERY_RESULT_BACKEND = "mongodb"
CELERY_IGNORE_RESULT = False
CELERY_TRACK_STARTE
浏览 0提问于2018-12-31得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
