Application Flow Stuck Unless Connection is Explicitly Closed
还没有人认领这个 Issue。
评估
- 难度
- 3/5
- 预计耗时
- 1-2 天
- 新手友好度
- 25/100
调研方向
从提供的 asyncpg 0.30.0 示例开始,在 Python 3.11、PostgreSQL 16 和 Windows 上复现该示例,首先确认使用本地 PostgreSQL 安装时是否会出现此问题。调查 self.get_connection() 周围的异步上下文管理器行为,并将其与显式调用 conn.close() 的情况进行比较;当流程无需显式关闭即可完成时,即视为完成。
由索引模型根据 Issue 内容生成。
描述
- asyncpg version: 0.30.0
- PostgreSQL version: 16
- Do you use a PostgreSQL SaaS? If so, which?: Yes, I am using NeonDB
- Can you reproduce the issue with a local PostgreSQL install?: Didn't attempt it.
- Python version: 3.11.0
- Platform: Windows
- Do you use pgbouncer?: No
- Did you install asyncpg with pip?: Yes
- If you built asyncpg locally, which version of Cython did you use?: [Your Cython version if applicable]
- Can the issue be reproduced under both asyncio and
uvloop?: [Yes/No] I did not try uvloop
I'm encountering an issue where the flow of my application gets stuck unless the database connection is explicitly closed after a query, even though it should be managed automatically by the context manager.
Code Example:
async def read_record(self, request_details: dict):
"""
Retrieve records based on conditions and request_type.
Args:
request_details (dict): The conditions including request_type.
Returns:
list: The records that match the conditions.
"""
table = self.get_table_name(request_details['request_type'])
conditions = {key: request_details[key] for key in request_details if key != 'request_type'}
condition_str = " AND ".join(f"{key} = ${i+1}" for i, key in enumerate(conditions.keys()))
query = f"SELECT * FROM {table} WHERE {condition_str};"
async with self.get_connection() as conn:
conn.add_log_listener(lambda connection, message: logger.info("PostgreSQL log message: %s", message))
result = await conn.fetch(query, *conditions.values())
logger.info("Fetched records: %s", result)
# await conn.close() # get's stuck without this line
return result
- 主要语言
- Python
- 星标
- 8.1k
- 派生
- 469
- 平均合并
- 4 小时 42 分钟
- 30 天内合并 PR
- 6
贡献指南
这个仓库没有索引到贡献指南
从这里开始
- 先读完整个 Issue,再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库,在一个分支上完成修改。
- 提交 Pull Request,并在描述里引用这个 Issue 编号。
MagicStack/asyncpg 的其他 Issue
-
难度 2/5 1-3 小时 新手友好度 78/100
MagicStack/asyncpg#1357 ·
-
难度 2/5 1-3 小时 新手友好度 65/100
MagicStack/asyncpg#997 ·
-
Connection.close(timeout=) waits forever on a pending cancel when the server never acknowledges it 未关闭
难度 4/5 3-5 天 新手友好度 68/100
MagicStack/asyncpg#1356 ·
-
难度 4/5 3-5 天 新手友好度 48/100
MagicStack/asyncpg#1354 ·
-
难度 3/5 1-2 天 新手友好度 72/100
MagicStack/asyncpg#1342 ·
查看 MagicStack/asyncpg 的全部 Issue
相似的 Issue
-
bug
难度 2/5 1-3 小时 新手友好度 82/100
-
难度 2/5 1-3 小时 新手友好度 88/100
use-agent-os/agent-os#3314 ·
-
难度 2/5 1-3 小时 新手友好度 75/100
BasedHardware/omi#15662 · 1 条评论 ·
-
documentation help wanted
难度 2/5 1-3 小时 新手友好度 90/100
-
难度 2/5 1-3 小时 新手友好度 62/100
AiursoftWeb/AnduinOS-2#19 ·