aiojobs
Job scheduler for managing background tasks (asyncio)
The library gives a controlled way for scheduling background tasks for
asyncio applications.
Installation
$ pip3 install aiojobs
Usage example
import asyncio
import aiojobs
async def coro(timeout):
await asyncio.sleep(timeout)
async def main():
scheduler = aiojobs.Scheduler()
for i in range(100):
# spawn jobs
await scheduler.spawn(coro(i/10))
await asyncio.sleep(5.0)
# not all scheduled jobs are finished at the moment
# gracefully close spawned jobs
await scheduler.close()
asyncio.get_event_loop().run_until_complete(main())
Integration with aiohttp.web
from aiohttp import web
from aiojobs.aiohttp import setup, spawn
async def handler(request):
await spawn(request, coro())
return web.Response()
app = web.Application()
app.router.add_get('/', handler)
setup(app)
or just
from aiojobs.aiohttp import atomic
@atomic
async def handler(request):
return web.Response()
For more information read documentation:
https://aiojobs.readthedocs.io
Communication channels
aio-libs google group:
https://groups.google.com/forum/#!forum/aio-libs
Feel free to post your questions and ideas here.
Gitter Chat https://gitter.im/aio-libs/Lobby
We support Stack Overflow. Please add
python-asyncio or aiohttp tag to your question there.
Author and License
The aiojobs package is written by Andrew Svetlov.
It's Apache 2 licensed and freely available.