带签名的芹菜chord KeyError
是一个错误类型，通常在使用芹菜（Celery）分布式任务队列框架时出现。下面是对该错误的完善且全面的答案：
概念： 带签名的芹菜chord KeyError是指在使用芹菜框架时，调用chord函数时可能会出现的错误。chord函数用于将一组任务作为一个整体进行调度和执行，其中每个任务的结果将作为参数传递给最后一个任务（回调任务）。当chord函数执行时，如果其中一个任务的结果无法找到或获取，就会抛出带签名的芹菜chord KeyError。
分类： 带签名的芹菜chord KeyError属于芹菜框架的错误类型，具体归类为任务调度和执行错误。
优势： 带签名的芹菜chord KeyError的优势在于它能够提供详细的错误信息，帮助开发人员快速定位和解决问题。通过错误信息，开发人员可以了解到具体是哪个任务的结果无法找到或获取，从而有针对性地进行修复。
应用场景： 带签名的芹菜chord KeyError通常在以下情况下出现：
- 在使用芹菜框架进行分布式任务调度时，调用chord函数时出现了任务结果无法找到或获取的情况。
- 当任务结果存储在数据库或缓存中，但由于某种原因导致无法访问数据库或缓存时，可能会引发该错误。
推荐的腾讯云相关产品和产品介绍链接地址： 腾讯云提供了多个与云计算相关的产品，以下是一些推荐的产品和其介绍链接地址：
- 云服务器（CVM）：提供弹性、可靠的云服务器实例，支持多种操作系统和应用场景。详细介绍请参考：https://cloud.tencent.com/product/cvm
- 云数据库 MySQL 版（CDB）：提供高性能、可扩展的云数据库服务，适用于各种规模的应用。详细介绍请参考：https://cloud.tencent.com/product/cdb
- 人工智能平台（AI Lab）：提供丰富的人工智能开发工具和服务，包括图像识别、语音识别、自然语言处理等。详细介绍请参考：https://cloud.tencent.com/product/ailab
- 云存储（COS）：提供安全、可靠的对象存储服务，适用于存储和处理各种类型的数据。详细介绍请参考：https://cloud.tencent.com/product/cos
请注意，以上推荐的产品和链接仅为示例，实际选择产品时应根据具体需求和情况进行评估和决策。
相关·内容
遵循上的答案
我得到了一个错误，芹菜似乎将任务签名链转换为字典，导致了下面的错误。
芹菜- 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回答
将芹菜画布序列化为json很容易，如下所示：
import json
from celery import Celery
from celery import chain
app = Celery()
@app.task
def add(a, b):
return a + b
@app.task
def mult(a, b):
return a * b
def main():
canvas = chain(add.s(1, 2), mult.s(2), mult.s(2))
print json.dumps(canvas)
if __name__ == '
浏览 0提问于2016-10-15得票数 2
我对芹菜吐露有点陌生。
例如，我有一个名为myapp.tasks.my_task的任务。
当我使用myapp.tasks.my_task时，我可以在已注册的芹菜任务中看到celery inspect registered。这不意味着任务已经成功注册了吗？为什么它会为它引发以下错误：
KeyError celery.worker.consumer.consumer in on_task_received
Received unregistered task of type 'my_app.tasks.my_task'.
The message has been ignored
浏览 18提问于2021-08-23得票数 5
我们正在用芹菜实现一个工作流。首先，我们需要并行运行一些任务，当它们全部完成时，我们需要运行一个任务。
似乎我们可以使用和弦，或团体和链：
chord(tasks, task)
vs
group(tasks) | task
这两者到底有什么区别？他们似乎也在做同样的事。
浏览 4提问于2015-07-02得票数 6
回答已采纳
我正在尝试向我的芹菜程序发送消息，但我不知道如何格式化这些消息。无论我怎么尝试，我都会从KeyError: 'chord'或ValueError('not enough values to unpack (expected 3, got 0)'的celery中得到隐秘的错误。在哪里可以找到有关如何格式化这些消息的信息。我只是想通过rabbitmq web界面来实现这一点。
这是我的芹菜应用的样子：
from celery import Celery
import time
app = Celery('tasks', backend='r
浏览 1提问于2017-05-22得票数 0
在我在stackOverflow上看到的所有类似问题中：
错误声明未注册任务的名称。我有个不同的问题。任务的名称不是显示，而是Received unregistered task of type <AsyncResult: e8018fcb-cd15-4dca-ae6d-6eb906055f13>，结果是KeyError: <AsyncResult: e8018fcb-cd15-4dca-ae6d-6eb906055f13>。
这是我的回溯：
KeyError: <AsyncResult: 4aca05f8-14c6-4a25
浏览 0提问于2016-06-15得票数 0
1回答
当我运行员工从队列中获取作业时，我会收到未注册的错误。我就是这么做的
芹菜-A任务
上述命令将在特定时间安排作业。之后，任务将添加到默认的queue.Now中，我在其他终端中运行芹菜工人，如下所示
芹菜工人-Q默认值
但是我得到了以下错误
[2014-08-19 19:34:02,466: ERROR/MainProcess] Received unregistered task of type 'TasksReg.vodafone_v2'.
The message has been ignored and discarded.
Did you remembe
浏览 3提问于2014-08-19得票数 1
TypeError: on_chord_error()缺少2个必需的位置参数：'exc‘和'traceback’。
芹菜4.3.0
阅读本文档
chord_head_list = (add.s(i, i) for i in range(4))
res_chord = (group(chord_head_list) | callback.s().on_error(on_chord_error.s())).delay()
print(res_chord.get(timeout=20))
@app.task(name='tasks.callback')
def
浏览 0提问于2019-07-19得票数 2
我试图运行一个芹菜任务，但正在收到一个KeyError，我猜这是因为芹菜试图从chatbot.tasks.add获得我的tasks.py文件。但是，我很愚蠢，我把add()模块放在本地bot/tasks目录中。这就是导致错误的原因。当我在Python中时，我认为我可以通过只执行from chatbot.tasks import add来解决这个问题，但是我一直得到一个"no模块名为.“。错误。
那么，现在如何成功地将正确的键(chatbot.tasks.add)传递给贝壳中的芹菜呢？
编辑:追溯错误：
[2018-02-13 04:32:47,609: INFO/MainProcess
浏览 0提问于2018-02-13得票数 0
以前有人在芹菜(Python中的分发任务工作人员)中见过这个错误吗？
回溯(最近一次调用)：文件"/home/mcapp/.virtualenv/lister/local/lib/python2.7/site-packages/celery/task/trace.py"，第228行，在trace_task R= retval =trace_task(*args，**kwargs)文件"/home/mcapp/.virtualenv/lister/local/lib/python2.7/site-packages/celery/task/trace.py"，第41
浏览 1提问于2013-05-25得票数 2
试着弄个芹菜为基础的刮刀。芹菜工人似乎自己起作用，但当我运行芹菜拍打服务器时，工人给了我这个关键错误。
File "c:\users\myusername\.virtualenvs\django-news-scraper-dbqk-dk5\lib\site-packages\celery\worker\consumer\consumer.py", line 555, in on_task_received
strategy = strategies[type_]
KeyError: 'core.tasks.scrape_dev_to'
[2020-1
浏览 1提问于2020-10-04得票数 2
回答已采纳
我试着用芹菜和弦并试着运行下面的例子-
@celery.task(ignore_result = False)
def add(x, y):
return x + y
@celery.task(ignore_result = False)
def tsum(numbers):
return sum(numbers)
from celery import chord
callback = tsum.s()
header = [add.s(i, i) for i in range(5)]
result = chord(header)(callback)
print result
浏览 4提问于2014-11-12得票数 1
为了响应请求，我在django应用程序中从celery启动了一个chord。chord可以正确执行，但django从未释放pub-sub通道。杀死django服务器将释放该频道，然后该频道将从redis-cli pubsub channels中消失。
本地的Celery 4.1.1或4.2.0rc4Redis 4.0.9Python本地版，1个celery worker，1个api serverResults在这种情况下无关紧要(但文档上说不要忽略它们)完整示例项目，地址：
在点击/api/start/并在运行celery的选项卡中查看任务完成后，我看到还有5个通道。杀死django会移除通道
浏览 61提问于2018-05-31得票数 0
2回答
我正在使用芹菜弦来构建大型文档页面内容的并行AI处理。因为这是一个没有公共签名的单次使用函数，所以我正在对要分发和重新聚合的对象进行酸洗。处理单个页面的任务是成功读取参数并执行所需的函数。但是，它尝试将结果返回到队列以进行后续聚合时会失败。
有没有人知道一种方法，可以为一个名为via Chord的任务指定一个result_serializer？
和弦生成
callback = processPageResults.subtask(kwargs={'cdd_id' : cdoc.cdd_id,'user_id':user.id},options={'ser
浏览 0提问于2020-05-28得票数 1
2回答
我已经浪费了很多时间，弄清楚如何用妖魔化的芹菜来执行django项目中的任务。
版本
django version is 1.3
celery version is 3.1
我的目录结构是
project/
./manage.py
./settings.py
./celeryapp/
./celeryqueue.py
./tasks.py
我通过创建"/etc/init.d/celeryd“(在中指定)，能够以妖魔化的方式运行芹菜。
还复制了指定的用于妖魔化芹菜的配置文件
# Name of nodes to start
# he
浏览 3提问于2014-04-25得票数 0
回答已采纳
2回答
目前我正在做芹菜组任务，我想在所有任务完成后调用upload_local_directory(Output_file)方法。我尝试了下面的方法，但它没有等待工作完成。 tasks = [make_tmp_files.s(page.object_list, path + str(uuid.uuid4() + '.csv')) for page in paginator]
job = group(tasks)
job.apply_async()
job.get()
output_file = 'final.zip'
upload_local_directory_
浏览 27提问于2020-11-30得票数 1
回答已采纳
2回答
当使用芹菜创建子任务(即chord、chain、group)并且有多个队列(即高优先级、低优先级)时，子任务继承了创建它的任务的路由参数吗？
浏览 5提问于2015-12-06得票数 1
回答已采纳
我在芹菜中使用了一个Chord来进行回调，当一组并行任务完成执行时，这个回调就会被调用。具体来说，我有一组函数来包装对外部API的调用。在处理结果并在Chord回调中更新我的数据库之前，我希望等待所有这些返回。我希望在所有API调用完成后执行回调，而不管它们的状态如何。
我的问题是，只有当组的子任务没有引发异常时，回调函数才会被调用。但是，如果一个子任务引发异常，则调用一个可选的错误处理程序on_error()，并使用chord的task_id的字符串表示形式。组中的其余任务确实会继续执行，但永远不会调用回调。
我将用下面的一个例子来说明这一点：
@app.task
def maybe_suc
浏览 2提问于2017-10-18得票数 6
我运行芹菜v5.2.3在一个码头集装箱运行ubuntu。
在这里，我试着让芹菜和弦发挥作用，但我所做的每一次尝试：
File "/usr/local/lib/python3.7/site-packages/celery/result.py", line 1056, in result_from_tuple
res, nodes = r
ValueError: not enough values to unpack (expected 2, got 1)
在此错误之后，chord继续重试：
retry: Retry in 1.0s: ValueError('
浏览 2提问于2022-04-06得票数 0
回答已采纳
1回答
现在我有一些大任务，它们都是由一些小任务组成的，我把它们放到经纪人那里，当一项大任务的所有小任务完成后，我需要一个回调来处理这些小任务的结果，我知道芹菜只有一个大任务才能完成，但是我有很多这样的任务，如果我写这样的话：
chord([task11.s(),task12.s()])(mycallback.s()).get()
chord([task21.s(),task22.s()])(mycallback.s()).get()
第二行直到第一行完成才开始，但是这样的话，一些工人会长时间成为偶像，这是不好的，那么芹菜中是否有一些在某些条件发生时可以回调，但不阻止这个过程？
===========
浏览 3提问于2017-02-23得票数 1
回答已采纳
我正在尝试在芹菜中创造一个和弦，它在一个组中的任务是和弦本身。因此，想法是-每个单独的子和弦首先执行，然后这些和弦的结果最后被父任务的回调使用。下面是我想要做的代码
-- tasks.py
import celery
from celery import chord
@celery.task
def add(x, y):
print "add called..."
return x + y
@celery.task
def tsum(numbers):
return sum(numbers)
@celery.task
def gr_add(x):
浏览 0提问于2014-01-28得票数 1
1回答
芹菜任务待定
、、、、
基本上，我希望能够创建一个由chord group of chains组成的chains。除了我似乎无法完成这一工作之外，所有的子链都必须在chord回调启动之前完成。
所以我的想法是创建一个while循环，如下所示：
data = [foo.delay(i) for i in bar]
complete = {}
L = len(data)
cnt = 0
while cnt != L:
for i in data:
ID = i.task_id
try:
complete[ID]
except KeyError
浏览 4提问于2014-08-08得票数 0
回答已采纳
1回答
使用芹菜构建一组连续任务的最佳方法是什么？我的代码有很多独立的任务(所以它们都可以是不可变的签名)，但是如果其中一个任务抛出异常，我想停止序列。
我一直在寻找解决这个问题的方法，但我被困住了。我们用芹菜3.1.12 + RabbitMQ。
首先，我们使用chord声明头任务成功，以便回调发生。它工作得很好，只不过我们需要向标题中添加更多的任务。
所以我试着在和弦上做个链子。这也有效，但是chord挂起挂起，因为当子任务引发异常时，链不会退出。
人为的例子：
@celery.task
def bite(food):
if food == 'salad':
浏览 1提问于2014-08-10得票数 3
1回答
我试图在更新完成后使用chord启动报告更新。
@shared_task(autoretry_for=(Exception,), retry_backoff=True, retry_kwargs {'max_retries': 5})
def upload(df: pd.DataFrame, **kwargs):
ed = EntityDataPoint(df, **kwargs)
uploadtasks, source, subtype = ed.upload_database()
chord(uploadtasks)(final_report.si(
浏览 9提问于2022-06-20得票数 0
回答已采纳
使用：
celery==5.2.7
django-celery-results==2.4.0
django==4.1
pytest==7.1.2
pytest-django==4.5.2
pytest-celery==0.0.0
我正在尝试测试一个任务(start_task)，它用回调任务创建一个chord (N个work_task任务)来总结工作。
def test_function(db):
...
obj = make_obj
...
start_task.delay(obj)
我称之为start_task，它创建了一个work_task。chord永远
浏览 14提问于2022-10-06得票数 -2
2回答
我正试图在芹菜框架之上构建一个应用程序。
我有一个模块settings/celery_settings.py，它的代码可以像这样初始化芹菜应用程序(我扩展了一些变量)：
from __future__ import absolute_import
from celery import Celery
pfiles = ['other_tasks.test123', 'balance_log.balance_log']
app = Celery('myapp')
# here I just have some parameters defined
浏览 3提问于2016-02-29得票数 3
回答已采纳
1回答
姜戈芹菜和弦未执行
、、、
我有一个程序，它通过Python的迭代工具生成大量的产品列表；基本上是一组各种各样的单词组合。要通过products()函数运行多个集合。我想做的是得到芹菜来帮助这一点，把每一套给不同的芹菜任务，然后结合到最后。我的理解是和弦就是这样做的。
从本质上说，我有这样一个：
callback = tabulate_results.subtask()
header = []
for combo in combos_to_run:
header.append(run_product.subtask(args=(object_terms, combo)))
result = chord(heade
浏览 1提问于2013-03-17得票数 3
我正在使用带有芹菜的Django 1.6。我已经将这个任务作为日程表来运行。一切看起来都是正确的，但是当Celery(节拍)运行时，我得到了这个导入错误：
Did you remember to import the module containing this task?
Or maybe you are using relative imports?
Please see http://bit.ly/gLye1c for more information.
The full contents of the message body was:
{'utc': True, &
浏览 3提问于2014-04-30得票数 0
2回答
我在跑芹菜3.1.11和花0.6.0。
我有一个芹菜应用程序配置为这样；
# myapp.tasks.celery.py
from __future__ import absolute_import
from celery import Celery
class Config(object):
BROKER_URL = 'amqp://'
CELERY_RESULT_BACKEND = 'amqp'
CELERY_TASK_RESULT_EXPIRES = None
CELERY_RESULT_SERIALIZER
浏览 3提问于2014-04-23得票数 2
回答已采纳
1回答
和弦超时
、、、
使用芹菜，我构建了一个和弦：
from celery import chord
chord(task1, chord(task2, task3))
但是，它通常会引发超时：
Chord '0f3dd024-8fe3-4b1b-ab9b-6081569c9738' raised:
"TimeoutError('Operation timed out (3.0)',)"
Traceback (most recent call last):
File "python2.7/site-packages/celery/b
浏览 6提问于2015-08-12得票数 4
2回答
芹菜:未注册任务
、、
我试着跟踪。我用的是芹菜4.1.0版
|-module
|-tasks
|-__init__.py
|-tasks.py
__init__.py的内容是空的。我已经创建了一个名为tasks.py内部任务目录的文件。
from celery import Celery
app = Celery("tasks", broker="redis://localhost:6379/0", backend="redis://localhost:6379/0")
@app.task
def add(x, y):
return
浏览 1提问于2018-03-21得票数 2
3回答
在第23行，它说表达式不能用作函数。我不明白这意味着什么。我不知道它要求我改变什么，并希望得到一些帮助。起初，我认为这可能是我的头中预定义的M_PI常量，我将其更改为PI并在代码中直接定义它，但这是行不通的。
#include "std_lib_facilities_4.h"
int main() {
const double PI = 3.141592653589793238463;
//formula for area of a circle is pi*r^2
//area of a 14" circle is 153.94&#
浏览 5提问于2015-09-12得票数 4
回答已采纳
1回答
我正在尝试将现有的芹菜群组调用转换为chord，以防止死锁。前面的代码有重试次数和过期时间。我设法让chord在没有这些设置的情况下工作，但当我尝试应用这些设置时，我看不到正在运行的任务。我在文档中没有看到任何关于将相同的设置作为一个整体应用于和弦的内容。我运行的是celery版本3.1.6。
前面的代码：
jobs = group([reset_device.s(topoid, dev_list[i],
waittime_list[i], skipflag) for i in range(len(dev_list))]
).apply
浏览 3提问于2017-07-27得票数 0
回答已采纳
1回答
我正在开发一个web应用程序，该应用程序将接收用户的请求，并且必须访问多个外部API来编写该请求的答案。这可以直接从主web线程使用类似gevent之类的内容来导出请求。
或者，我在想，我可以将传入的请求放到队列中，并使用工作人员来分配负载。这样做的目的是尽量保持实时，同时将请求分给几个工作人员。这些工作人员将只查询众多外部API中的一个。然后，他们接收到的响应将进行一系列转换，保存到DB中，转换为公共模式，并保存到公共DB中，最终组成一个大响应，通过web请求返回。web请求很可能一直处于阻塞状态，用户正在等待，因此保持排队和离队的速度是非常重要的。
外部API调用可以很容易地转换为单个任务
浏览 1提问于2013-05-02得票数 6
3回答
我在用芹菜，我有几项任务需要按顺序执行。
例如，我的任务是：
@celery.task
def tprint(word):
print word
我想做这样的事情：
>>> chain(tprint.s('a') | tprint.s('b'))()
然后我得到了TypeError: tprint() takes exactly 1 argument (2 given)。
和chord一样，在这种情况下，我需要在一组任务之后执行一项任务：
>>> chord([tprint.s('a'), tprint
浏览 5提问于2012-11-29得票数 43
回答已采纳
我有一个并行处理超大文本文件中的每一行的celery任务。我还有一个芹菜任务，它需要在处理每一行之后运行-它合并并处理每一行的输出。因为我正在处理的数据集非常庞大，有没有办法让芹菜与生成器一起工作，而不是列表？
def main():
header_generator = (processe.s(line) for line in file)
callback = finalize.s()
# Want to loop through header_generator and kick off tasks
chord(header_generator)(call
浏览 0提问于2015-06-09得票数 2
3回答
我用的是celery.chord(...)创建一组任务和一个在该组中的所有任务完成后调用的方法。
我使用amqp结果后端(但我想切换到memcached)。
我的工人每秒一次又一次地打印这行代码。我不知道如何打破这个无限循环。我可以访问rabbitMQ web界面，但我找不到ID为"32ba5fe4-...“的内容。
[2013-03-22 14:18:26,896: INFO/MainProcess] Task celery.chord_unlock[32ba5fe4-918c-480f-8a78-a310c11d0c3a] retry: Retry in 1s
[2013-03-2
浏览 0提问于2013-03-22得票数 5
3回答
我想有芹菜任务，这取决于2个或更多其他任务的结果。我已经研究了和，但只有当任务只有一个依赖任务时，它们才是好的。
我知道TaskSet，但似乎没有一种方法可以在TaskSetResult.ready()变为True时立即执行回调。我现在的想法是有一个周期性的任务，每隔几毫秒左右轮询一次TaskSetResult.ready()，并在它返回True时触发回调，但对我来说，这听起来相当不优雅。
有什么建议吗？
浏览 0提问于2011-07-05得票数 11
回答已采纳
1回答
我正在尝试调用一个创建chord的方法，并在我在另一个方法中构建的另一个chord中使用该chord。但是我不能让它以正确的顺序调用回调。
#celery obj
app = Celery('tasks', backend=BACKEND, broker=BROKER)
下面是我用来测试它的简单方法：
@app.task
def first_task(args):
return 'first_task'
@app.task
def first_body(args):
return 'first_body'
@app.tas
浏览 0提问于2018-06-26得票数 3
1回答
我对芹菜很陌生，并试图在我的应用程序中使用它。下面是我的基本应用程序结构
my_app
|-run.py
|-app
|-mod1
|-mod2
|-tasks
|-__init__.py
|-email
|-other_tasks_file
我想把我所有的背景任务限制在任务模块上。在任务的init.py中
from celery import Celery
celery = Celery('my_app', broker='redis://localhost:6379/0')
在我的任务
浏览 2提问于2016-05-14得票数 6
回答已采纳
我对码头、芹菜和rabbitMQ比较陌生。
在我们的项目中，我们现在有以下设置:运行多个码头容器的物理主机：
1x rabbitmq:3-管理容器
# pull image from docker hub and install
docker pull rabbitmq:3-management
# run docker image
docker run -d -e RABBITMQ_NODENAME=my-rabbit --name some-rabbit -p 8080:15672 -p 5672:5672 rabbitmq:3-management
1x芹菜容器
# pull docke
浏览 1提问于2015-04-08得票数 17
回答已采纳
1回答
芹菜多不起作用
、、
我有这个项目文件夹结构
api
-- __init__.py
--jobs/
-- __init__.py
-- celery.py
-- celeyconfig.py
-- tasks.py
--api_helpers/
--views/
任务有一个名为ExamineColumns的任务
我使用celery worker -A api.jobs --loglevel=Info启动工作人员
它工作得很好，我可以执行任务。
这是芹菜检验的命令
$ celery inspect registered
浏览 2提问于2013-07-04得票数 1
1回答
我正在尝试运行芹菜作为任务管理，但在一个组中运行多个任务时遇到问题。在组中的所有任务完成后，我想要收集结果。如果组中只有一个任务，则工作流工作正常，它会等待所有任务完成。但是，如果组中有2个或更多任务，或者我没有正确运行它，它就会失败。以下是代码示例 @celery2.task(name='square')
def square(a):
log.info(f'In square group {a}')
return a**a
@celery2.task(name='add_one')
def add_one(a):
b
浏览 12提问于2020-04-24得票数 2
回答已采纳
2回答
芹菜任务消失
、、、、
我使用cron脚本运行django项目，执行一个管理命令。此命令为芹菜创建循环任务：
for r in pr:
log_task(tasks_logger.info, "to_queue", r)
remind.delay(r, now, send_all)
任务是这样的：
class RTask(Task):
abstract = True
def on_failure(self, exc, task_id, args, kwargs, einfo):
r = args[0]
log_task(logger.er
浏览 4提问于2014-03-12得票数 9
回答已采纳
我的需求是从Celery中的一个任务内部创建另一个任务。传递的参数将取决于父任务的输出。是的，我希望这是一种递归，它在某个点上停止(基于一些IF子句)。芹菜能做到这一点吗？
我研究了Group/Chord/等子任务原语。然而，它们并不像我想要的那样灵活。有没有办法做到这一点？
浏览 2提问于2014-11-21得票数 0
1回答
我有一个Django应用程序，定期运行在芹菜上。
Procfile
worker: celery -A myproject worker --loglevel=INFO
beat : celery -A myproject beat --scheduler redbeat.RedBeatScheduler
我已经尝试了django_celery_beat.schedulers:DatabaseScheduler，和RedBeatScheduler相同的结果。
settings.py
...
CELERY_BROKER_URL = os.environ.get("REDIS_URL
浏览 0提问于2021-02-01得票数 0
2回答
我正在处理一个和弦图表，现在我只能选择文本标签和和弦连接到的灰色边框。
我想选择单独的和弦，但是，当我添加鼠标功能时，它会在图表中随机选择一个和弦。
//works
svg.append("g")
.selectAll("path")
.data(chord.groups)
.enter().append("path")
.style("fill", function(d) {
return fill(d.index);
浏览 0提问于2014-01-07得票数 2
1回答
因此，我试图在Django项目中安装芹菜，并使用Amazon作为代理。然而，由于某些原因，芹菜一直试图在本地主机上找到SQS。
这是我的settings.py
CELERY_BROKER_TRANSPORT = "sqs"
CELERY_BROKER_USER = env.str("DJANGO_AWS_ACCESS_KEY_ID")
CELERY_BROKER_PASSWORD = env.str("DJANGO_AWS_SECRET_ACCESS_KEY")
CELERY_BROKER_TRANSPORT_OPTIONS = {
&#
浏览 9提问于2022-10-27得票数 0
当我从命令行运行芹菜时，我只能看到与芹菜对象位于同一个文件中的任务，而不能看到其他文件中的任务。
该项目的结构如下：
celery_test
celery_tasks
__init__.py
celery_app.py
async
__init__.py
tasks.py
marker
__init__.py
tasks.py
这些文件的内容如下
celery_app.py
from __future__ import abs
浏览 0提问于2018-05-15得票数 13
回答已采纳
如何将使用AMQP后端的芹菜4配置升级到芹菜5，它已经放弃了这种支持，现在要求您使用RPC后端？
升级到芹菜5.1.2之后，我收到了以下错误：
ModuleNotFoundError: No module named 'celery.backends.amqp'
我料到的。但是，尚不清楚rpc后端是如何替换它的。
我的CELERY_BROKER_URL看起来像amqp://guest:guest@127.0.0.1:5672/myvhost，它访问RabbitMQ。
我尝试将其更改为rpc://guest:guest@127.0.0.1:5672/myvhost，并将CELER
浏览 3提问于2021-10-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
