打印到Celery worker中的标准输出显示为basic.qos:预取计数->X
是指在使用Celery分布式任务队列时，将任务的标准输出打印到Celery worker中，并显示为basic.qos:预取计数->X的信息。
Celery是一个基于Python的分布式任务队列，用于实现异步任务和任务调度。它可以将任务分发给多个工作节点（Celery worker）并进行并行处理。当任务在Celery worker中执行时，可以通过标准输出打印一些调试信息或结果。
basic.qos:预取计数->X中的"预取计数"是指Celery worker在从任务队列中获取任务时一次性获取的任务数量。这个数量可以通过配置进行调整，影响到任务的并发执行能力和资源占用情况。"X"表示具体的预取计数值。
Celery的标准输出可以通过配置Celery worker的日志级别来控制是否显示以及显示的详细程度。可以通过设置日志级别为DEBUG来打印更详细的调试信息，或者设置为INFO来打印一般的运行信息。
Celery提供了丰富的功能和扩展性，适用于各种异步任务和任务调度的场景。它可以与其他技术和工具结合使用，如Django、Flask、RabbitMQ等，来构建复杂的分布式应用系统。
在腾讯云的产品中，可以使用腾讯云的Serverless Cloud Function（SCF）来实现类似的分布式任务队列功能。SCF是一种无服务器计算服务，可以实现按需运行代码的功能。通过配置SCF的触发器和函数代码，可以实现类似Celery的任务分发和执行功能。具体的产品介绍和使用方法可以参考腾讯云SCF的官方文档：腾讯云SCF产品介绍。
相关·内容
我有一个用芹菜做的Django项目
由于RAM的限制，我只能运行两个工作进程。
我有“慢”和“快”的混合任务。应尽快执行快速任务。在短时间内(0.1s-3s)可以有许多快速任务，所以理想情况下，两个CPU都应该处理它们。
缓慢的任务可能会运行几分钟，但结果可能会延迟。
慢任务发生的频率较低，但可能同时出现2或3次排队。
我的想法是有一个：
1个芹菜工人W1，并发1，只处理快速任务
1芹菜工人W2与并发1，可以处理快速和缓慢的任务。
芹菜的任务预取乘法器( )默认为4，这意味着4个快速任务可以排在一个慢任务的后面，并且可以延迟几分钟。因此，我想禁用工作者W2的预取功能。医生说：
浏览 5提问于2019-10-08得票数 1
回答已采纳
1回答
芹菜不能同时执行任务。
、、、
我是芹菜新手，如果需要更多的信息，请在评论中告诉我。
我有大约3000个任务在redis中排队，我希望通过多个线程并发执行这些任务，经过一些研究，我最终使用了用于线程池的事件，并将并发设置为500，如下所示
celery worker -A <app_name> -P eventlet -c 500
但是，当我检查芹菜花时，有许多免费的线程可用，而芹菜是不使用的。
对于如何更快地利用这些空闲线程和使任务变得更快，有什么想法吗？另外，如果可能的话，请推荐一本与芹菜一起工作的好书。
浏览 1提问于2019-06-22得票数 3
回答已采纳
1回答
我刚接触芹菜和红菜。
我使用redis-server启动了我的redis服务器。
Celery是使用此参数运行的
celery -A proj worker
没有其他配置。然而，我意识到当我在celery中有一个长时间运行的作业时，它不会处理队列中的另一个任务，直到长时间运行的任务完成。我的理解是，由于我的CPU上有8个核心，我应该能够同时处理8个任务，因为-c的默认参数是核心的数量？
我是不是漏掉了什么？
浏览 4提问于2017-02-24得票数 7
回答已采纳
我经历了芹菜工人过程之间的一种奇怪的互动，我认为这是独立的。你能提出一个可能的原因吗？
我有一个芹菜工人，有多个工序：
PPID PID
5892 5919 \_ /bin/bash -c sleep 10 && python manage.py makemigrations --noinput; python manage.py migrate --noinput; python manage.py initservice; celery -B -A workflows --workdir=/srv/workflows -l info --autoscale=2,
浏览 5提问于2016-10-17得票数 0
回答已采纳
1回答
正如我在celery中看到的，它可以为一个worker获取多个任务，这些任务可以同时运行。
我需要运行一个任务，并设置多个任务可以与此任务同时运行。
因此，如果我将这个数字设置为2，并将此任务发送给具有10个线程的worker，worker只能运行另一个任务。
浏览 3提问于2015-07-15得票数 0
是否可以使用auto=false禁用预取？我只想避免每次确认消息时从队列中读取消息(预取)。我只想在调用“when _ message”时才阅读一条消息。设置prefetch_count=0似乎不起作用，它被视为“无特定限制”。
更新：
据我所知，'prefetch_count‘是缓存在客户端的消息的数量(将本地读入缓冲区)。例如，有一个用例：
(让我们假设有一个队列连接到并且它有消息)
建立一个连接。
Set Basic.Qos (prefetch_count=1)
开始消费Basic.Consume
由于prefetch_count=1，一条消息已经被传输到客户端，
浏览 2提问于2017-09-07得票数 3
回答已采纳
1回答
我有一个系统，有重要的长期运行的任务，由芹菜工人执行。假设我们已经使用k8s或docker部署了应用程序。如何在不丢失当前正在执行的任务的情况下更改生产中的芹菜工人代码？换句话说，我想要一种优雅的自动化方式来执行新员工所有未完成的任务。
我用Redis 4.3.3做经纪人，我的芹菜版本是5.2.7。
我已经添加了result_backend并尝试了下面的设置，但是芹菜在运行“docker worker_service_name”之后并没有重新安排运行任务。
CELERY_ACKS_LATE = True
CELERY_TASK_REJECT_ON_WORKER_LOST = True
浏览 6提问于2022-08-07得票数 1
回答已采纳
1回答
对于服务器自动化，我们正在开发一个工具，它可以在不同的服务器上处理和执行许多任务。我们将任务和服务器主机名发送到队列中。然后从请求者中使用队列，请求者将信息提供给ansible api。为了实现这一点，我们可以同时执行多个任务，我们使用线程。
现在我们只能接受这条信息.
我们迄今所做的工作：
requester.py消耗队列，然后启动一个线程，其中ansible任务正在运行。然后将结果发送到另一个队列中。因此，每一条新消息都会创建一个新线程。任务完成后，线程就会死掉。
但现在是困难的部分。我们必须使消息持久，以防服务器死掉。因此，每条消息都应该在发送回ansible的结果后被确认为。
我们现在
浏览 4提问于2016-06-16得票数 4
回答已采纳
我的代码中的一些任务的执行时间越来越长。
经过检查，我注意到虽然我的工作节点设置为并发6，并且存在6个进程来“做工作”，但在“运行任务”下只显示了一个任务。这是一个小的视觉证明：
以下是worker选项：
下面是该worker的任务选项卡，其中只有一个正在运行的进程：
我发现如果我重启celery，并发性将再次受到重视，我将看到>1个正在运行的任务，但在一段时间/任务之后，它将恢复到此行为。
有什么办法来解决这个间歇性的问题吗？
浏览 0提问于2014-07-02得票数 17
回答已采纳
1回答
我在python中有两个任务想要用芹菜在后台运行。我使用以下函数来定义芹菜。
from celery import Celery
def make_celery(app):
celery = Celery(
app.import_name,
backend=app.config['CELERY_RESULT_BACKEND'],
broker=app.config['CELERY_BROKER_URL']
)
celery.conf.update(app.config)
class
浏览 1提问于2020-02-01得票数 1
我脑海中有一种印象，如果芹菜工人得到了一项任务，并且被重新尝试了--它仍然留在工人的记忆中(与eta一起)--并且不会回到队列中。结果是，如果一个芹菜任务被重试，而工人忙于处理不同的任务，那么这个任务eta就会到来--它必须等到完成其他任务时才能完成。
我试着在文档中寻找与我记忆一致的东西，但什么也找不到。
我尝试并检查它时所做的是创建两个任务。
@app.task(bind=True, name='task_that_holds_worker', rate_limit='4/m',
default_retry_delay=5 * 60,
浏览 1提问于2019-01-27得票数 1
回答已采纳
1回答
有单一的芹菜节拍跑过：
celery -A app:celery beat --loglevel=DEBUG
三名工人经过：
celery -A app:celery worker -E --loglevel=ERROR -n n1
celery -A app:celery worker -E --loglevel=ERROR -n n2
celery -A app:celery worker -E --loglevel=ERROR -n n3
相同的Redis用作所有工作人员的消息代理和beat。所有工人都为了开发目的在同一台机器上开始工作，而他们将在生产中使用不同的Kubernetes吊舱
浏览 3提问于2021-08-23得票数 2
回答已采纳
1回答
目前，我遇到了一个使用芹菜的项目的问题。当将任务路由到队列时，以及当任务数量超过并发数时，员工会脱机。在此状态下，它仍在处理任务，但工作人员将出现脱机，无法进行检查。单击工作人员或执行检查active_queues会给出消息“错误:没有节点在时间约束范围内作出答复”。在任务数等于或小于工作人员的并发数之后，工作人员将返回联机。
当工作人员脱机时，运行带有“-l调试”的工作人员时不会显示任何错误。当工人似乎离线时，原木仍在继续，尽管无法检查。
芹菜的版本为3.1.11，代理程序为RabbitMQ 3.3.0。
我的芹菜配置：
from celery.schedules import cronta
浏览 3提问于2014-05-05得票数 0
回答已采纳
1回答
我用的是Django 1.6，RabbitMQ 3.5.6，celery 3.1.19。
有一个周期性任务，每30秒运行一次，并使用给定的eta参数创建200个任务。在我运行芹菜工人之后，队列慢慢地在RabbitMQ中创建，我看到大约1200个计划好的任务等待被触发。然后，我重新启动芹菜工人，所有等待的1200个预定任务都从RabbitMQ中删除。
如何创建任务：my_task.apply_async((arg1, arg2), eta=my_object.time_in_future)
我这样管理员工：python manage.py celery worker -Q my_tasks_1
浏览 5提问于2015-12-28得票数 9
我从我的芹菜工人开始
celery -A workerTasks worker --concurrency 1
在django的settings.py中，我还有：
CELERYD_PREFETCH_MULTIPLIER = 1
CELERY_worker_prefetch_multiplier = 1
但是，一旦连接到芹菜代理，工作人员仍然会消耗5个任务。
我遗漏了什么？
浏览 0提问于2019-07-11得票数 3
我跑去发芹菜工人与Rabbitmq的连接，在Gevent模式下遇到了管道断裂的错误。当芹菜工人在过程池模式下工作时没有问题(没有gevent，没有猴子补丁)。
在此之后，芹菜工人将不再从Rabbitmq获得任务信息，直到重新启动。
这个问题总是发生在芹菜工人使用任务消息的速度比Django应用程序生成消息的速度慢时，以及在Rabbitmq中堆积的大约3大串消息时。
Gevent版本1.1.0
芹菜版本3.1.22
======芹菜原木======
[2016-08-08 13:52:06,913: CRITICAL/MainProcess] Couldn't ack 293, reas
浏览 8提问于2016-08-09得票数 3
1回答
在有8个核心的环境中，芹菜应该能够在默认情况下并行处理8个传入任务。但有时，当收到新的任务时，芹菜把它们放在一个长期运行的过程中。
我使用默认配置，让一个工作人员从一个队列中消费。
celery -A proj worker --loglevel=INFO --concurrency=8
我的理解是错误的，一个并发性为8的工作人员能够并行地处理一个队列中的8个任务吗？
如何更好地设置芹菜以防止上述行为？
浏览 1提问于2015-05-13得票数 3
回答已采纳
1回答
我不知道是还是配置问题。
目标:每次进行小更改时，调试/修改芹菜任务时无需手动重新启动工作人员
所以我已经配置了Celery+RabbitMQ。一切都正常。
将--autoreload选项添加到celery -A proj worker --loglevel=debug命令中，并就此停止日志记录：
[2014-09-11 19:22:00,447: DEBUG/MainProcess] | Worker: Hub.register Autoreloader...
没有它：
[2014-09-11 19:37:34,316: DEBUG/MainProcess] | Worker
浏览 1提问于2014-09-11得票数 5
我已经看了好几个问题，但仍然没有找到解决方案，我已经花了好几天的时间来解决这个问题，所以任何帮助都会很感激！
我使用芹菜4.4.0、SQS作为代理和Django 2.2，我的大部分任务都很长(1到4个小时)。
这是启动工人的命令：
celery worker -A config.celeryconfig:app -Ofair --prefetch-multiplier=1 --max-tasks-per-child=2
在Django配置文件中的这个配置：
CELERYD_PREFETCH_MULTIPLIER = 1
CELERY_ACKS_LATE = True
task_acks_lat
浏览 6提问于2020-10-27得票数 1
我有一个FastApi 应用程序，它使用Beanie作为我的odm，并为<code>E 110</code>异步<代码>E 211</代码>任务<代码>E 112</代码>在<code>E 213</code><code>E 114</code>芹菜工作人员<code>E 215</code>内创建一个运行事件循环<code>E 29</code>的新线程。
问题是，我在@worker_ready.connect信号中放置的任何
浏览 18提问于2022-10-20得票数 0
回答已采纳
1回答
django芹菜延迟函数
、、、
你好，我想在我的Django项目中使用芹菜任务，我试着遵循来自Mr.Vitor Freitas的这个非常好的Mr.Vitor。
但是在我的例子中，如果尝试运行这个教程，我就得不到结果--函数不执行，在我的例子中和教程中(我接收消息等待和刷新，刷新后什么也不做)。
知道为什么吗？
我认为问题可能是在RABBITQM服务器上?某种配置？
只需安装Erlang(otp_win64_20.1.exe)和RabbitMQ(rabbitmq-server-3.6.12.exe)之后
下面是示例代码：
settings.py
CELERY_BROKER_URL = 'amqp://localhost
浏览 6提问于2017-10-29得票数 1
回答已采纳
使用消息、处理消息、然后发布消息的正确方法是什么？我遇到了很多未被确认的信息，我相信会有一些阻塞发生。试着理解这类事情的最佳实践。
我正在开发一组服务，每天处理大约50k个请求。我决定使用RabbitMQ和用DOTNetCore3.1编写的三个。
我绘制了这个过程的图表，但实际上它的工作方式如下：
外部服务将消息发布到队列#1。
服务A正在队列#1上“监听”，并使用到达队列的任何消息。进行数据库调用，然后Service将消息传递给队列#2
服务B正在队列#2上“监听”，并使用到达队列的任何消息。完成了一些内部处理，然后Service将消息传递给队列#3
服务C正在队列#2上“监
浏览 4提问于2020-05-28得票数 1
我使用的是一个RabbitMQ代理，有一个芹菜工人订阅了这个代理。根据我的测试，RabbitMQ似乎是按照先进先出的顺序来处理消息的。因为已经填充了一个队列，然后是另一个队列，然后是另一个队列，依此类推，我的worker将使用队列1中的所有消息，并且只有在队列1完成后才会移动到队列2。
有可能改变这种行为吗？我希望Celery worker以循环方式使用，即先使用队列1中的消息，然后使用队列2中的消息，依此类推，只有在其他每个队列都使用完消息后才返回到队列1。
浏览 0提问于2017-06-30得票数 6
我有一个关于如何以默认格式将芹菜日志发送到控制台(stdout)和日志文件的问题。
log default format: "[%(asctime)s: %(levelname)s/%(processName)s] %(message)s"
task log default format: "[%(asctime)s: %(levelname)s/%(processName)s]
[%(task_name)s(%(task_id)s)] %(message)s"
我启动芹菜应用程序时使用：
celery_ap
浏览 5提问于2021-04-07得票数 1
1回答
我有一个最简单的芹菜任务(case.py)例子：
import time
import celery
app = celery.Celery('case', broker='redis://localhost')
@app.task
def do_sth():
time.sleep(5)
我创建了几个任务实例：
>>> import case
>>> tasks_list = [case.do_sth.delay() for i in range(4)]
然后，我希望有带有--concurrency=1参数的动态
浏览 2提问于2017-02-21得票数 4
回答已采纳
2回答
从多工序启动芹菜工人
、、、、
我对芹菜很陌生。我看到的所有例子都是从命令行开始使用芹菜工人的。例如：
$ celery -A proj worker -l info
我正在启动一个关于弹性豆茎的项目，我认为让这个工人成为我的网络应用程序的一个子过程会很好。我试着使用多重处理，这似乎是可行的。我想知道这是一个好主意，还是可能有一些缺点。
import celery
import multiprocessing
class WorkerProcess(multiprocessing.Process):
def __init__(self):
super().__init__(name='ce
浏览 4提问于2015-04-26得票数 1
回答已采纳
1回答
这是否可能将django-celery作为虚拟环境中的项目的系统服务？
这是我的配置：
/etc/system/system/celery.service
[Unit]
Description=Celery Service
After=network.target
[Service]
Type=forking
User=vagrant
Group=vagrant
Restart=no
WorkingDirectory=/vagrant/myproj/
ExecStart=/bin/sh -c '/var/www/vhost/myproj_env/bin/python \
/v
浏览 0提问于2017-07-07得票数 2
2回答
我们使用Apache (2.24)从RabbitMQ服务器使用Spring (2.1)应用程序(3.7.15)。
应用程序似乎正在正确地消费(消息逐条消息，因为它们被放置在队列中)，但是在RabbitMQ监视器中，这些消息似乎是“批量地”被消耗的(请参见急剧下降，然后是平行线，尽管我们在日志中看到了应用程序正在处理的消息)。
我们还没有设置任何我能看到的“预取”行为。有人能解释一下发生了什么吗？为什么队列数量不平稳地下降？
浏览 2提问于2019-08-23得票数 3
回答已采纳
from time import sleep
from celery import Celery
backend = 'db+sqlite:///db.sqlite3'
app = Celery('tasks', broker='amqp********************', backend=backend)
@app.task()
def reverse(text):
sleep(5)
return text[::-1]
所以我有上面的代码，当我运行这个代码的时候，它不工作，只是接收到任务，什么也不做，检查我得到的
浏览 0提问于2021-07-04得票数 0
回答已采纳
2回答
我想为我的Celery任务设置一个路径并监视它们。
这是我在flask应用程序中运行在localhost:5000上的代码
background.py
任务
@celery.task(queue='cache')
def cache_user_tracks_with_features():
return {'status': 'Task completed!'}
路由
@task_bp.route('/filter', methods=['GET', 'POST'])
def ca
浏览 0提问于2019-04-01得票数 2
回答已采纳
6回答
我有一个使用celery==4.2.1，redis==2.10.6，redis-server=4.0.9的django 2.0.5应用程序。当我启动celery worker时，我得到以下输出：
-------------- celery@octopus v4.2.1 (windowlicker)
---- **** -----
--- * *** * -- Linux-4.18.16-surface-linux-surface-x86_64-with-Ubuntu-18.04-bionic 2018-10-31 17:33:50
-- * - **** ---
- ** -------
浏览 1提问于2018-11-01得票数 3
1回答
我想用芹菜来管理任务。我希望有一个任务队列(具有并发性1)，并且能够将任务推到具有不同优先级的队列上，这样更高优先级的任务将抢先其他任务。
我在队列中添加了三个任务，如下所示：
add_tasks.py
from tasks import example_task
example_task.apply_async((1), priority=1)
example_task.apply_async((2), priority=3)
example_task.apply_async((3), priority=2)
我有以下配置：
tasks.py
from __future__ import
浏览 2提问于2017-04-25得票数 15
回答已采纳
1回答
如何在任务结束后删除队列中的所有任务？
我想要像这样的东西()，但要芹菜3.0。
谢谢
编辑：
来自芹菜文档：
我的代码看起来是：
从芹菜进口current_app作为芹菜
@task
def task_a():
celery.control.purge()
我原以为，如果我发布了5个任务，那么只有第一个任务会运行。不知怎么的，我没有那么做。
谢谢
浏览 1提问于2013-11-08得票数 1
回答已采纳
3回答
在看了很多关于chord回调无法执行的文章，并尝试了他们的解决方案后，我仍然无法让它工作。事实上，由于某些原因，chord_unlock方法也无法执行。
celery.py
from __future__ import absolute_import
from celery import Celery
app = Celery('sophie',
broker='redis://localhost:6379/2',
backend='redis://localhost:6379/2',
浏览 3提问于2013-12-12得票数 4
对于gevent池，我们可以使用参数'-c‘来指定绿灯号。如下所示。
celery worker -A celerytasks.celery_worker_init -P gevent -c 1000 --loglevel=info
但它的固有价值是什么呢？
这对“绿号”到底意味着什么呢？如果我指定1000美元，如果它们被用完了，会发生什么情况？
浏览 2提问于2016-05-24得票数 4
回答已采纳
下面的代码是与
# For flask
gunicorn --bind 0.0.0.0:5000 project:app --access-logfile -
# For celery worker
celery -A project.celery worker --loglevel=info
同时引用同一个文件(下面)
import os
import time
import threading
from flask import (
Flask,
jsonify,
)
from flask_sqlalchemy import SQLAlchemy
from greenle
浏览 4提问于2022-08-15得票数 0
1回答
在我的Django项目中，我在两个不同的应用程序中有两个任务，我想定期与芹菜一起运行。
工人似乎收集任务，节拍似乎收集调度。然而，节拍停留在开始(它没有同步的时间表)，从来没有交付任务给工人。
celery --app=bozonaro worker --loglevel=debug --beat (bozonaro是my项目的名称)命令提示我如下：
[2021-02-04 18:23:48,080: DEBUG/MainProcess] | Worker: Preparing bootsteps.
[2021-02-04 18:23:48,103: DEBUG/MainProcess] |
浏览 3提问于2021-02-04得票数 2
当在Docker容器中运行时，Celery似乎不会写入任何日志文件。当在Docker之外运行时，同样的命令也可以正常工作。
在我的docker-compose.yml文件中：
celery_main:
build:
context: .
dockerfile: Dockerfile
command: bash -c "sleep 20 && celery -A my_project worker -n 1 -Q celery -c 10 -l info -E --logfile=celery_main.log"
浏览 19提问于2020-02-14得票数 0
我正在尝试将Amazon设置为Django应用程序中芹菜的默认消息代理。芹菜工人正在启动，但代理设置为默认RabbitMQ。在下面你可以找到我的工人的输出。
以下是我在这个项目中的一些心声。我的celery.py看起来像：
from __future__ import absolute_import
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SET
浏览 5提问于2016-12-02得票数 1
回答已采纳
2回答
当我在Redis后端运行Celery时，有没有办法限制队列大小？ 类似于rabbitmq的队列预声明中的x-max-length
浏览 27提问于2019-10-09得票数 4
我在一台AWS c3.xlarge (4核机器)上运行多个celery工作进程。有一个“批处理”工作进程，其--concurrency参数设置为2，还有一个“优先级”进程，其--concurrency参数设置为1。这两个工作进程从相同的优先级队列中提取。我使用Mongo作为我的经纪人。当我将多个作业提交到优先级队列时，即使有多个工作进程可用，它们也会一个接一个地按顺序处理。所有项目都由“优先级”进程处理，但如果我停止“优先级”进程，“批处理”进程将处理所有内容(仍然是串行的)。我有哪些配置不正确，从而阻止了celery异步处理作业？
编辑:原来同步瓶颈是在提交作业的服务器中，而不是在芹菜中。
浏览 2提问于2014-09-30得票数 0
1回答
我的问题和这个一样，但答案并不适用于我。
我的celery.py
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
app = Celery('project', broker='amqp://<user>:<user_pass>@remoteserver:5672/<vho
浏览 0提问于2018-10-30得票数 1
回答已采纳
如何解决Rebus从0.71.4升级到0.75.2后的RabbitMq连接问题？
我们有一个分布式处理器设置，其中N个仪表板用于监视活动，一个管理器用于控制工作流，N个工作器用于执行工作。每个组件之间的通信使用RabbitMq进行管理。在我们升级到Rebus 0.75.2 (包括将RabbitMq.Client升级到3.4.0.0)之前，Rebus 0.71.4上的一切都运行得很好。
管理器是最复杂的组件，因为它发送多种形式的通信，包括发布给工作人员的心跳、发布到仪表板的请求/响应审计消息，以及包括工作人员要执行的工作的消息。所有这些消息都是并发完成的。
我们使用预取1，以防止工作因在工作进程
浏览 3提问于2015-01-08得票数 1
0回答
from celery import Celery
app = Celery('tasks', backend='amqp://guest@192.168.99.100', broker='amqp://guest@192.168.99.100//')
@app.task()
def add(x, y):
return x + y
我可以成功地发送芹菜任务，但当我尝试获取任务的结果时，它不会将它们发回。我认为这是由于后台ip被设置为外部ip造成的，而芹菜并不尊重这一点。
- ** ---------- .> transport
浏览 6提问于2016-07-09得票数 0
回答已采纳
1回答
我的芹菜工人是这样开始的：
celery -A workerTasks worker --concurrency 1 --loglevel=info
但我看到它正在接收多个任务：
[2019-05-08 10:33:07,371: INFO/MainProcess] celery@2aaf46abfaed ready.
[2019-05-08 10:33:07,372: INFO/MainProcess] Received task: workerTasks.do_processing_task[a3c19e7a-6b04-4236-8afc-0884547d3f39]
[2019-05-
浏览 0提问于2019-05-08得票数 3
回答已采纳
我在运行定期任务时遇到问题？当我运行代码celery worker -A任务时--loglevel=debug。看起来不错，但是在终端中出现以下消息后，它会停止，不做任何事情: 2019-07-10 22:29:21,149: DEBUG/MainProcess basic.qos: prefetch_count->16
from celery import Celery
from celery.schedules import crontab
from datetime import date, timedelta
from config import *
from email imp
浏览 7提问于2019-07-11得票数 0
1回答
事件循环在芹菜工人中关闭。
、、、、
我正面临多个问题，使用异步ODM在我的芹菜工人，首先，我无法插入我的数据库模型使用芹菜工人信号，我使用beanie的db连接。
第一实现
from asyncer import syncify
from asgiref.sync import async_to_sync
client = AsyncIOMotorClient(
DATABASE_URL, uuidRepresentation="standard" )
db = client[DB_NAME]
async def db_session():
await init_beanie(
浏览 16提问于2022-10-13得票数 3
回答已采纳
我想知道是否可以为队列设置不同的预取乘法器。
我有两个队列，一个有非常短的运行任务，另一个稍微长一些。较短任务的队列需要优先于其他任务。
为了确保排序工作可靠，必须在芹菜配置中设置：
task_acks_late = True
worker_prefetch_multiplier = 1
然而，这确实损害了快速任务队列的性能。如果工作人员从快速任务队列中获取，那么worker_prefetch_multiplier是4，如果工人是从慢任务队列中获取的，那么是否可以进行配置？worker_prefetch_multiplier是1吗？
浏览 3提问于2021-03-08得票数 3
回答已采纳
当我运行celery -A tasks2.celery worker -B时，我希望看到每秒打印一次"celery task“。当前未打印任何内容。为什么这不起作用？
from app import app
from celery import Celery
from datetime import timedelta
celery = Celery(app.name, broker='amqp://guest:@localhost/', backend='amqp://guest:@localhost/')
celery.conf.update(CE
浏览 0提问于2015-07-15得票数 21
回答已采纳
我想用芹菜配金字塔。尝试使用包。А所有的尝试都失败了。
我的development.ini有：
BROKER_URL = amqp://dev:dev@192.168.1.50:5672//test
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json', 'application/json']
CELERY_RESULT_BACKEND = amqp://dev:dev@192.168.1.
浏览 2提问于2015-03-04得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
