معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

Library for writting simple AMQP handlers with type hints and pydantic support

ویژگی	مقدار
سیستم عامل	-
نام فایل	cornflower-0.1.0
نام	cornflower
نسخه کتابخانه	0.1.0
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	jakub-figat
ایمیل نویسنده	-
آدرس صفحه اصلی	https://github.com/jakub-figat/cornflower
آدرس اینترنتی	https://pypi.org/project/cornflower/
مجوز	MIT

## Cornflower ### Library for writing RabbitMQ message handlers with [pydantic](https://github.com/samuelcolvin/pydantic) validation. ## Example use: Handler callback can accept zero or one argument of `pydantic.BaseModel` type. Message body will be validated automatically against specified schema. ```python from cornflower import MessageQueue, OutputMessage, MessageDeliveryMode from pydantic import BaseModel class UserMessage(BaseModel): username: str message: str queue = MessageQueue(url="amqp://user:password@host:port") @queue.listen(routing_key="user.registered") def handle_user_register(message: UserMessage) -> None: # do something with validated message ... @queue.listen(routing_key="user.login") def handle_user_login() -> None: # callback with no arguments, handle message without # validating its body # sending message user_message = UserMessage(username="example", message="this is example") queue.dispatch( message=OutputMessage( body=user_message.dict(), routing_key="user.logout", delivery_mode=MessageDeliveryMode.PERSISTENT, ) ) if __name__ == "__main__": queue.run() ``` ## Optional configuration ```python from cornflower import MessageQueue from cornflower.options import QueueOptions, TransportOptions, ConsumerOptions queue = MessageQueue( queue_options=QueueOptions( durable=True, exclusive=False, auto_delete=False, ), consumer_options=ConsumerOptions( prefetch_count=10 ), transport_options=TransportOptions( confirm_publish=True, ) ) ```

نیازمندی

مقدار	نام
>=5.2.3,<6.0.0	kombu
>=1.9.0,<2.0.0	pydantic
>=1.2.0,<2.0.0	pika

زبان مورد نیاز

مقدار	نام
>=3.9,<4.0	Python

نحوه نصب

نصب پکیج whl cornflower-0.1.0:

pip install cornflower-0.1.0.whl

نصب پکیج tar.gz cornflower-0.1.0:

pip install cornflower-0.1.0.tar.gz