如何对芹菜队列设置速率限制？ [英] How to put a rate limit on a celery queue?

问题描述

我在 <$ c的芹菜文档中阅读了此内容$ c> Task.rate_limit ：

请注意，这是每个工人的实例速率限制，而不是全局速率限制。要实施全局速率限制（例如，对于每秒请求数量最大的API），必须限制为给定队列。

Note that this is a per worker instance rate limit, and not a global rate limit. To enforce a global rate limit (e.g., for an API with a maximum number of requests per second), you must restrict to a given queue.

我如何对芹菜队列设置速率限制？

How do I put a rate limit on a celery queue?

推荐答案

原来，它不能在队列级别上完成多名工人。
IT可以在1位工作人员的队列级别完成。

Turns out it cant be done at queue level for multiple workers. IT can be done at queue level for 1 worker. Or at queue level for each worker.

因此，如果您说每5名工人每分钟10个工作。您的工人每分钟最多可集体处理50个工作。

So if u say 10 jobs/ minute on 5 workers. Your workers will process upto 50 jobs per minute collectively.

因此，一次选择只有一名工人只能运行10个工作。或选择5名工人，每分钟2分钟的限制。

So to have only 10 jobs running at a time you either chose one worker. Or chose 5 workers with a limit of 2/minute.

这篇关于如何对芹菜队列设置速率限制？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！