Come viene applicato rate_limit in Celery?

Question

Gestisco un sito Web Django in cui utilizzo Celery per implementare il caching preventivo, ovvero calcolo e memorizzo i risultati prima ancora che vengano richiesti dall'utente.

Tuttavia, uno dei miei compiti Celery potrebbe, in alcune situazioni, essere chiamato molto (direi a prima vista più velocemente di quanto non sia in media, in realtà). Mi piacerebbe rate_limit in modo che non consuma molte risorse quando in realtà non è così utile.

Tuttavia, vorrei prima capire come viene applicato l'attributo celery.task.base.Task.rate_limit di Celery. I compiti sono rifiutati? Sono ritardati e giustiziati più tardi?

Grazie in anticipo!

Answer 1

Le attività con limite di frequenza non vengono mai eliminate, vengono accodate internamente al worker in modo che vengano eseguite non appena è possibile eseguirle.

L'algoritmo del token bucket non specifica nulla sulla caduta dei pacchetti (è un'opzione, ma Celery non lo fa).