pikantic 0.1.2

Python library for easy message broker handling using Pydantic

pikantic

Python library for easy message broker handling using Pydantic

Basic Usage

import pikantic
from pydantic import BaseModel

app = pikantic.Pikantic(AMQP_URI)


class PersonModel(BaseModel):
    name: str
    age: int


@app.on_rabbit('test_queue')
async def handle_message(msg: aio_pika.Message, person: PersonModel):
    print(msg.body)
    print(person.age)


if __name__ == '__main__':
    app.run()