aiothrottler 0.0.1

Throttler for asyncio Python

aiothrottler

Throttler for asyncio Python

Installation

pip install aiothrottler

Example: multiple tasks throttled

import asyncio
import time

from aiothrottler import Throttler

async def main():
    # Allows one resolve every 0.5 seoncds
    throttler = Throttler(0.5)
    await asyncio.gather(*[
        worker(throttler) for _ in range(10)
    ])

async def worker(throttler):
    await throttler()
    # Will call print 0.5 seconds after the previous call
    print(time.time())

loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()