asyncpg-listen

此库简化了与asyncpg一起使用listen/notify的操作

1. 处理连接丢失
2. 简化了来自多个通道的通知处理
3. 为接收通知设置超时
4. 根据ListenPolicy允许接收所有通知/仅接收最后一条通知。

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.7 (2024-09-07)

• 支持python 3.12并结束对3.8的支持
• 结束对python 3.9和3.10的支持
• 在Python 3.12+上急切地开始通知处理
• 切换到asyncio.TaskGroup

v0.0.6 (2022-11-02)

• 添加对python 3.11的支持

v0.0.5 (2022-05-23)

• 等待任务取消

v0.0.4 (2022-01-24)

• 在成功连接后重置失败尝试计数器

v0.0.3 (2022-01-23)

• 支持python 3.8

v0.0.2 (2021-11-02)

• 支持async-timeout 4.0+

v0.0.1 (2021-10-27)

• 第一个版本