معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Object oriented AMQP layer for microservices communication.

ویژگی	مقدار
سیستم عامل	-
نام فایل	amqp-ko-1.0.4
نام	amqp-ko
نسخه کتابخانه	1.0.4
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Michał Budziak
ایمیل نویسنده	michal.mariusz.b@gmail.com
آدرس صفحه اصلی	https://github.com/budziam/amqp-ko-python
آدرس اینترنتی	https://pypi.org/project/amqp-ko/
مجوز	MIT

# AMQP Kø Object oriented AMQP layer for microservices communication. ## Usage The recommended way to use AMQP Kø is to create your own queue object. The simplest way to do this is using `createQueue` function. ### Create queue ```python from amqp_ko import create_queue, AsyncConnection, Message, MessageGate from dataclasses import dataclass @dataclass(frozen=True) class TopicFollow(Message): user_id: int topic_name: str def unmarshal_topic_follow(data: dict) -> TopicFollow: return TopicFollow( user_id=data["user_id"], topic_name=data["topic_name"], ) message_gates = [ MessageGate("topic_follow", TopicFollow, unmarshal_topic_follow), ] async with AsyncConnection("localhost", 5672, "rabbitmq", "rabbitmq") as connection: queue = await create_queue(connection, "exchange-name", message_gates) ``` ### Consume messages ```python from amqp_ko import Consumer, Job class ConnectUserWithTopic(Consumer): async def consume(self, job: Job): # Put here some code to connect user with a topic # using "job.message.userId" and "job.message.topicName" await job.ack() await queue.consume( "queue-name", {TopicFollow: ConnectUserWithTopic()}, ) ``` ### Produce message ```python message = TopicFollow(120, "entertainment") await queue.produce(message) ``` ## Installation ```bash pip install amqp-ko ``` #### Author: [Michał Budziak] [Michał Budziak]: http://github.com/budziam

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

مقدار	نام
>=3.7	Python

نحوه نصب

نصب پکیج whl amqp-ko-1.0.4:

pip install amqp-ko-1.0.4.whl

نصب پکیج tar.gz amqp-ko-1.0.4:

pip install amqp-ko-1.0.4.tar.gz