Как отправлять массово 150 асинхронных запросов в минуту через pool, при этом чтобы была задержка в 150 запросов в минуту?

Question

[Володимир]

Всем привет!

Как отправлять массово 150 асинхронных запросов в минуту через pool, при этом чтобы была задержка в 150 запросов в минуту?

Можно сделать так:

->withOptions(['delay' => 450, 'synchronous' => true])

Тогда будет задержка и в минуту уйдет как раз около 150 запросов, но тогда запросы становятся синхронными и выполнение отправки на 50К запросов будет очень длительным, а нужно чтобы было асинхронно все и с задержкой.

Comments

[shurshur]

Что такое "задержка в 150 запросов в минуту"?

[Володимир]

shurshur, то есть в минуту, чтобы отправлялось 150 запросов, а не 1500 запросов!

[Uno]

Володимир, хз за лару и за пул, но ты привел пример синхронности. Найди как сделать асинхронно, и отправляй их в цикле в конце тела которого delay(60000)
https://github.com/spatie/async - не оно?

[Володимир]

Uno, естественно я привел пример синхронности, потому что с синхронностью все получается, а нужно то асинхронно!
Если опцию 'synchronous' => true убрать, то запросы идут асинхронно, но задержка для каждого запроса не работает.

Вот про Pool:
https://laravel.com/docs/10.x/processes#naming-poo...

[shurshur]

Володимир, самый что ни на есть простой способ - делать sleep (1/150) и запускать очередной асинхронный запрос. Тогда в секунду будет делаться 150 асинхронных запросов.

Answer 1

[d'Ivan]

Например, при помощи алгоритмов Sliding Window (скользящее окно) и Leaky Bucket (протекающее ведро).

https://habr.com/ru/articles/448438/
https://www.geeksforgeeks.org/leaky-bucket-algorithm/