如何使用Dask从SQL<连接字符串>中读取数据？

Question

关于如何从 sqlAlchemy 读取数据到 dask 数据帧的文档中没有足够的示例。

我看到的一些例子是：

   df = dd.read_sql_table(table='my_table_name', uri=my_sqlalchemy_con_url, index_col='id')

但是我的查询不是一次获取整个表，而是只获取 (select * from ....table A where .....) 类型的查询作为参数传递.. 另外，如何传递连接参数是没有提到。

如何从 sqlAlchemy 连接引擎传递连接参数并传递自定义查询而不是获取整个表。

我知道这是基本的，但在 docs/web 中找不到关于此的参考

编辑 ：

     d100 = 'mysql+mysqlconnector://{0}:{1}@{2}:{3}/{4}'.format("xx", "xx", "xxxxx.com", "3306", "xxxx") 
     df = dd.read_sql_table(table='select * from ps_g9 limit 10;', uri=d100, index_col='uuid') 

我得到表不存在错误

Answer 1

这是文档： https: //docs.dask.org/en/stable/dataframe-api.html#dask.dataframe.read_sql_table

它列出了以下内容：

• “table”参数确实可以是表名或任何 SQL 表达式，由 sqlalchemy 实例构造（即不是文本）
• 字典engine_kwargs（如果给定）将在创建数据库查询引擎时传递给 sqlalchemy