tomgrin10/pikantic

Python library for easy message broker handling using Pydantic

pikantic

Python library for easy message broker handling using Pydantic

Basic Usage

from pikantic import Pikantic, IncomingMessage
from pydantic import BaseModel

app = Pikantic(AMQP_URI)


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


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


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