使用Dask read_sql_query报错：AttributeError：Select对象无subquery属性

问题根源 #

你代码里有两个关键错误：

1. wip_entity_id = sql.column("wip_entity_id") 完全错误——sql是普通字符串，不是SQLAlchemy的text对象，根本没有column方法。
2. 嵌套构造Select对象的方式不符合Dask的预期，导致Dask内部调用subquery方法时失败。

两种可行解决方案 #

方案一：直接使用SQLAlchemy text对象（最简单）

既然你已经有现成的SQL语句，直接把它包装成SQLAlchemy的text对象传入Dask即可，无需额外嵌套Select：

from sqlalchemy import text
from dask.dataframe import read_sql_query

sql = """
SELECT t2.wip_entity_id
       , t1.class_code
       , t1.attribute2
  FROM table_1 t1
       , table_2 t2
 WHERE t1.wip_entity_id = t2.wip_entity_id
"""
maria_conn_string = "xxxxx"

# 直接传入text包装后的SQL对象
data = read_sql_query(sql=text(sql), uri=maria_conn_string, index_col="wip_entity_id")

方案二：正确构造嵌套Select对象（适合动态查询场景）

如果需要动态构造查询，要确保列引用和对象结构正确：

from sqlalchemy import select, text, column
from dask.dataframe import read_sql_query

maria_conn_string = "xxxxx"

# 先定义基础查询并明确列信息
base_query = text("""
SELECT t2.wip_entity_id
       , t1.class_code
       , t1.attribute2
  FROM table_1 t1
       , table_2 t2
 WHERE t1.wip_entity_id = t2.wip_entity_id
""").columns(
    column("wip_entity_id"),
    column("class_code"),
    column("attribute2")
).alias('a')

# 基于基础查询构造Select对象
sel = select(base_query.c.wip_entity_id, base_query.c.class_code).select_from(base_query)

# 传入Dask，注意index_col要用正确的列引用
data = read_sql_query(sql=sel, uri=maria_conn_string, index_col=base_query.c.wip_entity_id)

为什么原代码在SQLAlchemy引擎能运行但Dask不行？ #

SQLAlchemy的engine.execute对查询对象的兼容性更广，即使列引用有隐性问题也能正常执行；但Dask的read_sql_query需要查询对象能被正确转换为子查询（内部会调用subquery方法），原代码中错误的列引用导致Select对象结构异常，触发了AttributeError。

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