python - Celery 中如何执行 rate_limit？

Question

我正在运行一个 Django 网站，我在其中使用 Celery 实现预防性缓存 - 也就是说，我什至在用户请求结果之前就计算并缓存结果。

但是，在某些情况下，我的一个 Celery 任务可能会被多次调用(我会说比平均完成速度快得多，实际上)。我想对它进行 rate_limit，这样它就不会在实际上没那么有用的情况下消耗大量资源。

但是，我想首先了解 Celery 的 celery.task.base.Task.rate_limit 属性是如何强制执行的。任务被拒绝了吗？他们是否被延迟并稍后执行？

提前致谢!

Answer 1

速率受限的任务永远不会被丢弃，它们在 worker 内部排队，以便它们在被允许运行时立即执行。

token 桶算法没有指定任何关于丢弃数据包的信息(这是一个选项，但 Celery 没有这样做)。