控制芹菜工人的消耗速度

Question

我正在尝试使用我的 Django 应用程序设置 Celery。这个应用程序将让用户调用一些 API 并获得响应。然而，这个 API 有限制，只允许用户每秒调用不超过一次。

所以我打算用芹菜来控制调用频率。多个用户可能同时使用这个应用程序，所以我认为我应该将调用部分设置为工作人员。每个人都可以提交调用 API 的请求到队列中，worker 会消费它们。

这里的问题是：我怎样才能将消耗任务（即发送 api 请求）的工作限制为每秒 1 个？

谢谢！

Answer 1

celery 任务有一个 rate_limit 选项，应该可以满足您的需求。这是针对每个工作人员的，因此您需要使用专用队列来确保此任务的所有请求都获得了一个工作人员。