معرفی شرکت ها

asyncpg-listen-0.0.6

Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
0.0.6
0.0.5
0.0.4
0.0.3a1
0.0.3
0.0.2
0.0.1
0.0.6
0.0.5
0.0.4
0.0.3a1
0.0.3
0.0.2
0.0.1

توضیحات

Helps to use PostgreSQL listen/notify with asyncpg
ویژگی مقدار
سیستم عامل -
نام فایل asyncpg-listen-0.0.6
نام asyncpg-listen
نسخه کتابخانه 0.0.6
نگهدارنده []
ایمیل نگهدارنده []
نویسنده Yury Pliner
ایمیل نویسنده yury.pliner@gmail.com
آدرس صفحه اصلی https://github.com/Pliner/asyncpg-listen
آدرس اینترنتی https://pypi.org/project/asyncpg-listen/
مجوز MIT
# asyncpg-listen This library simplifies usage of listen/notify with [asyncpg](https://github.com/MagicStack/asyncpg): 1. Handles loss of a connection 2. Simplifies notifications processing from multiple channels 3. Setups a timeout for receiving a notification 4. Allows to receive all notifications/only last notification depending on ListenPolicy. ```python import asyncio import asyncpg import asyncpg_listen async def handle_notifications(notification: asyncpg_listen.NotificationOrTimeout) -> None: print(f"{notification} has been received") async def main(): listener = asyncpg_listen.NotificationListener(asyncpg_listen.connect_func(user="postgres")) listener_task = asyncio.create_task( listener.run( {"simple": handle_notifications}, policy=asyncpg_listen.ListenPolicy.LAST, notification_timeout=5 ) ) await asyncio.sleep(1) connection = await asyncpg.connect(user="postgres") try: for i in range(42): await connection.execute(f"NOTIFY simple, '{i}'") finally: await connection.close() await asyncio.sleep(1) listener_task.cancel() asyncio.run(main()) ``` ## v0.0.6 (2022-11-02) * [Add support of python 3.11](https://github.com/anna-money/asyncpg-listen/pull/135) ## v0.0.5 (2022-05-23) * [Wait for tasks cancellation](https://github.com/anna-money/asyncpg-listen/pull/96) ## v0.0.4 (2022-01-24) * [Reset failed attempts counter on successful connection](https://github.com/anna-money/asyncpg-listen/pull/58) ## v0.0.3 (2022-01-23) * [Support python 3.8](https://github.com/anna-money/asyncpg-listen/pull/55) ## v0.0.2 (2021-11-02) * [Support async-timeout 4.0+](https://github.com/Pliner/asyncpg-listen/pull/10) ## v0.0.1 (2021-10-27) * A first version


نیازمندی

مقدار نام
>=0.27.0 asyncpg
<5.0,>=3.0 async-timeout


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

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


نحوه نصب


نصب پکیج whl asyncpg-listen-0.0.6:

    pip install asyncpg-listen-0.0.6.whl


نصب پکیج tar.gz asyncpg-listen-0.0.6:

    pip install asyncpg-listen-0.0.6.tar.gz