asyncio_throttle_rate_limiting_concurrent_tasks_quickstart.py

1import asyncio
2import time
3from asyncio_throttle import Throttler
4
5async def worker(no, throttler):
6    async with throttler:
7        print(f'{time.time()}: Worker #{no} is working...')
8        await asyncio.sleep(0.5)
9
10async def main():
11    throttler = Throttler(5)
12    tasks = [
13        asyncio.create_task(worker(i, throttler))
14        for i in range(10)
15    ]
16    await asyncio.gather(*tasks)
17
18if __name__ == '__main__':
19    asyncio.run(main())