使用Discord.py异步SQLAlchemy时，查询返回ChunkedIteratorResult而非ORM对象求助

在SQLAlchemy异步模式下，db.execute()返回的ChunkedIteratorResult是结果集的迭代器包装，并非直接的ORM实例。要获取可直接操作的ORM对象，需要通过结果集的方法提取数据。

核心原因 #

异步API的execute()方法不会自动返回ORM对象，而是返回一个结果迭代器，你需要显式调用方法从中提取目标数据。

解决方案 #

根据查询返回的记录数量，选择对应的提取方法：

• 若查询仅返回单条记录（如按user_id查询单个用户）：使用result.scalar()获取单个ORM对象
• 若查询返回多条记录：使用result.scalars().all()获取ORM对象列表

修正后的代码示例 #

同时注意你的代码存在其他优化点：

• 不要在函数内重复创建engine，建议全局初始化一次
• async with AsyncSession会自动管理会话关闭，无需手动调用await db.close()
• 条件判断逻辑需调整，避免分支覆盖问题

# 全局初始化engine，不要在函数内重复创建
engine = create_async_engine("sqlite+aiosqlite:///BD.sqlite", echo=True)

async def legit(ctx):
    print(ctx.message.author.global_name, ctx.message.author.id, ctx.message.author.guild.name.lower(),
          "---legit check---")
    async with AsyncSession(engine) as db:
        query = sqlalchemy.select(users).where(users.user_id == ctx.message.author.id)
        result = await db.execute(query)
        # 提取单个用户对象
        user = result.scalar()
        
        if user:
            access = user.block == 0
            print(f"Access granted: {access}")
        else:
            print("用户未找到")

补充说明 #

如果使用engine.begin()的方式，同样需要通过结果方法提取数据：

async with engine.begin() as conn:
    result = await conn.execute(query)
    user = result.scalar()

内容的提问来源于stack exchange，提问作者Krepachek