我正在尝试实现一个简单的队列，它一次执行一个任务。使用Celery卸载主线程上的任务并在Celery配置中设置concurrency=1可以很好地工作，但我可能希望为其他任务使用更多并发工作线程。有没有办法告诉Celery或RabbitMQ不要对一个任务使用多个并发工作进程(除非强制执行concurrency=1)？我在文档中找不到任何东西，但也
浏览 2提问于2010-11-11得票数 3
回答已采纳
对于多处理池，我可以使用参数'-c‘来指定工作进程的数量。就像复写显示的那样。celery worker -A celerytasks.celery_worker_init -c 5 --loglevel=info或者，如果我必须启动多个唤醒程序，而不是一个具有多个进程的工作人员，那么我
浏览 2提问于2016-05-24得票数 3
回答已采纳
1回答
假设我异步启动了1000个任务，并且只有一个celeryd进程在运行以执行任务。celery将创建多少线程来处理这些任务？如果有多个线程由celery自动启动来处理任务队列，我如何限制celery在给定的时间点仅执行100个线程。
谢谢。
浏览 4提问于2013-03-28得票数 0
2回答
我已经覆盖了芹菜默认队列。下面是提到的设置。设置CELERY_DEFAULT_QUEUE = 'project.env.default'
CELERY_ROUTES根据配置，我期望除了app1.tasks.push_api_task之外的所有任务都应该进入队列project.env.default。但一个奇怪的问题正在发生，例如，任务将进入pro
浏览 0提问于2015-08-15得票数 2
1回答
我想知道芹菜是如何执行芹菜任务的？无论是为每个任务产生一个新线程，还是为task.How产生一个新工作线程，我们都可以知道任务是否完成并从我正在使用RabbitMQ的message broker队列中删除。
浏览 1提问于2017-10-30得票数 1
1回答
为了实现这种扩展(在ACI中生成新的芹菜容器)，我们需要知道等待执行的任务的数量，并相应地在ACI上生成这些容器。 任何建议都将不胜感激。
浏览 11提问于2020-07-25得票数 0
1回答
一个非常直接的问题，也许是--我经常看到一个芹菜任务进程在我的系统上运行，当我使用celery.task.control.inspect()的active()方法时，我找不到它。通常这个进程会运行几个小时，我担心它是某种僵尸。通常它也会占用很多内存。当active()告诉我在一个特定的机器上没有任务在运行，但是机器的内存已被完全使用，并且htop显示这些工作池线程正在使用它，但同时
浏览 0提问于2013-01-22得票数 2
回答已采纳
2回答
我的Python文件有以下两行代码：celery_app.send_task('tasks.test2', args=[self.id], kwargs={})
看着控制台输出，他们似乎一个接一个地执行。如何同时执行两个任务？.> celery exchange=celery(direct) ke
浏览 1提问于2014-08-29得票数 11
回答已采纳
1回答
我有一个用例，我需要启动一个芹菜工人，让他们使用独特的队列，我已经尝试实现如下所示。
def afunction(for循环的第一次迭代，但随后它就停在那里，不再继续执行for循环。我相信这是因为worker没有运行分离的脚本，或者没有作为脚本的子进程</e
浏览 6提问于2018-02-08得票数 1
回答已采纳
我需要通过Django web界面执行PERL脚本。我想知道是否可以使用Celery/RabbitMQ将这些脚本作为Celery任务执行？或者，我应该只执行Celery任务并等待脚本完成处理吗？我想让脚本更新Django用户/芹菜。
浏览 1提问于2013-11-05得票数 0
我基本上是在芹菜中使用rabbitmq队列作为穷人的同步。例如，当某些对象被更新(并且成本很高)时，我根据它们的对象ID将它们轮询到一组10个队列中。首先，这是一种常见的模式，还是有更好的方法。其次，使用celeryd时，并发级别选项(CELERY_CONCURRENCY)似乎设置了所有队列中的工作进程数。这种情况违背了使用队列进行同步的目的，因为队列可以由多个工作</em
浏览 7提问于2011-07-07得票数 4
我在一台AWS c3.xlarge (4核机器)上运行多个celery工作进程。有一个“批处理”工作进程，其--concurrency参数设置为2，还有一个“优先级”进程，其--concurrency参数设置为1。这两个工作进程从相同的优先级队列中提取。我使用Mongo作为我的经纪人。当我将多个作业提交到优先级队列时，即使有多个工作</e
浏览 2提问于2014-09-30得票数 0
2回答
我正在尝试将具有不同任务和工作进程的多个芹菜队列保存在同一个redis数据库中。在我的机器上只需要一个redis服务器，而不是两个，这真的是一个方便的问题。我一字不差地遵循了芹菜教程文档，因为这是让它为我工作的唯一方法。现在，当我尝试复制名称/队列稍有调整的所有内容时，它总是出错。
注意--我是Python和芹菜的新手，这显然是问题的一部分。我的文档的精简版本是:运行celery -A tasks worker来派生工作<e
浏览 0提问于2013-11-08得票数 40
回答已采纳
1回答
我正在使用Django、Celery和RabbitMQ编写一个邮件列表管理器。当消息传入时，将为每个接收者执行一个任务。所有任务都转到一个队列中，一个或多个工作进程使用队列中的任务，构造电子邮件并发送它们。单个队列会导致公平性问题:如果一条消息进入大型邮件列表，则会向队列中添加大量任务，而其他消息则无法到达其他较小的邮件列表，直到发送完该大型列表中的所有消息。我怎么才能找到解决这个问题的方法呢？从概
浏览 2提问于2011-10-26得票数 4
1回答
我有下面的芹菜配置 broker=os.environ.get('CELERY_BROKER_URL', 'redis://'),
celery.config_from_object(APP_SETTING
浏览 7提问于2019-11-07得票数 0
3回答
Jython的/Python通信
、、、、
我有一个django应用程序和python脚本，用于前端并执行系统管理/自动化任务。我在WebLogic9/10上使用jython，我想做的就是让jython系统发出一个请求。我一直使用的方法是使用pickle对象。通过获取所有数据，将其分解为一个文件，然后将该文件加载回python应用程序/脚本。
浏览 0提问于2011-09-08得票数 3
回答已采纳
1回答
动态创建不同交换类型的队列
、、、、
我正在尝试编写一个方法，该方法使用现有的exchange名称、新的队列名称和路由键的参数创建新的队列。交换可能是不同的类型(直接、扇出、主题)。有没有一种方法可以在不知道交换类型的情况下创建和绑定队列？
浏览 11提问于2019-11-26得票数 0
1回答
在我的应用程序中，我有连接到rest API的python celery任务。很简单。有没有办法让这些api任务在队列中阻塞？也就是说，如果同时发出多个请求，我可以让任务在队列中一个接一个地执行，等待队列中的第一个任务完成吗？
目前，在rabbitmq消息队列(只有一个工作进程)中，我看到任务正在执行(派生)，而不是等待。
浏览 0提问于2017-11-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
