因'dask_expr.io'模块缺失无法使用dask-sql的问题求助

• 从Parquet文件读取数据
• 将每个DataFrame注册为表
• 使用dask-sql对表进行关联与查询

安装步骤 #

• pip install --force-reinstall --no-cache-dir "dask[complete]" dask-sql
• pip install dask-expr

已安装版本 #

import dask
import dask_sql

print(dask.__version__)
print(dask_sql.__version__)
# 输出： 
> 2025.5.1
> 2024.5.0

错误复现步骤 #

使用示例CSV文件复现错误的代码：

import dask.dataframe as dd
from dask_sql import Context

tmp_df = dd.read_csv("./tmp.csv")

c = Context()
c.create_table("tmp", tmp_df)

报错信息：

---------------------------------------------------------------------------
ModuleNotFoundError                       Traceback (most recent call last)
Cell In[2], line 2
      1 c = Context()
----> 2 c.create_table("tmp", tmp_df)

File ~\AppData\Roaming\Python\Python312\site-packages\dask_sql\context.py:266, in Context.create_table(self, table_name, input_table, format, persist, schema_name, statistics, gpu, **kwargs)
    264 try:
    265     if dd._dask_expr_enabled():
--> 266         from dask_expr.io.parquet import ReadParquet
    268         dask_filepath = None
    269         operations = input_table.find_operations(ReadParquet)

ModuleNotFoundError: No module named 'dask_expr.io'

注意： 即使执行pip install dask-expr后，仍出现相同错误。

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