Repid framework: simple to use, fast to run and extensible to adopt job scheduler.
pip install repidHere is how the easiest example of producer-consumer application can look like.
Producer:
import asyncio
from repid import Connection, Job, RabbitMessageBroker, Repid
app = Repid(Connection(RabbitMessageBroker("amqp://user:password@localhost:5672")))
async def main() -> None:
async with app.magic():
await Job(name="awesome_job").enqueue()
asyncio.run(main())Consumer:
import asyncio
from repid import Connection, RabbitMessageBroker, Repid, Router, Worker
app = Repid(Connection(RabbitMessageBroker("amqp://user:password@localhost:5672")))
router = Router()
@router.actor
async def awesome_job() -> None:
print("Hello async jobs!")
await asyncio.sleep(1.0)
async def main() -> None:
async with app.magic():
await Worker(routers=[router]).run()
asyncio.run(main())Check out user guide to learn more!
Repid is distributed under the terms of the MIT license. Please see License.md for more information.
Repid's logo is distributed under the terms of the CC BY-NC 4.0 license. It is originally created by ari_the_crow_.