معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

A generic interface wrapping multiple backends to provide a consistent pubsub API.

ویژگی	مقدار
سیستم عامل	-
نام فایل	aio-pubsub-0.3.0
نام	aio-pubsub
نسخه کتابخانه	0.3.0
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Bakhtiyor Ruziev
ایمیل نویسنده	bakhtiyor.ruziev@yandex.ru
آدرس صفحه اصلی	http://github.com/bruziev/async_pubsub
آدرس اینترنتی	https://pypi.org/project/aio-pubsub/
مجوز	-

AioPubSub ========= .. image:: https://travis-ci.com/theruziev/aio_pubsub.svg?branch=master :target: https://travis-ci.com/theruziev/aio_pubsub .. image:: https://codecov.io/gh/theruziev/aio_pubsub/branch/master/graph/badge.svg :target: https://codecov.io/gh/theruziev/aio_pubsub/branch/master A generic interface wrapping multiple backends to provide a consistent pubsub API. Installation ------------ .. code-block:: bash pip install aio-pubsub # for redis backend pip install aio-pubsub[aioredis] # for postgresql backend pip install aio-pubsub[aiopg] Usage ------ To use it, you need to implement your pubsub implementation from interfaces or use backends from ``aio_pubsub.backends`` package .. code-block:: python from aio_pubsub.backends.memory import MemoryPubSub pubsub = MemoryPubSub() # Create subscriber subscriber = await pubsub.subscribe("a_chan") # Push message await pubsub.publish("a_chan", "hello world!") await pubsub.publish("a_chan", "hello universe!") # And listening channel try: async for message in subscriber: print(message, flush=True) except KeyboardInterrupt: print("Finish listening") Supported backends --------------------- ``Disclaimer``: I would not advise you to use this backend, because it is shown only for testing purposes. Better develop your own implementation. * memory * redis * postgresql

نیازمندی

مقدار	نام
>=1.0.0	aiopg
>=1.2.0	aioredis

نحوه نصب

نصب پکیج whl aio-pubsub-0.3.0:

pip install aio-pubsub-0.3.0.whl

نصب پکیج tar.gz aio-pubsub-0.3.0:

pip install aio-pubsub-0.3.0.tar.gz