dask_expr.read_sql
dask_expr.read_sql¶
- dask_expr.read_sql(sql, con, index_col, **kwargs)[源代码]¶
将 SQL 查询或数据库表读取到 DataFrame 中。
此函数是
read_sql_table和read_sql_query的便捷包装器。它将根据提供的输入委托给特定函数。SQL 查询将被路由到read_sql_query，而数据库表名将被路由到read_sql_table。请注意，委托的函数可能会有此处未列出的关于其功能的更具体说明。- 参数
- sqlstr 或 SQLAlchemy 可选择对象
数据库中的SQL表名称或要执行的SQL查询。不支持TextClause。
- constr
数据库连接的完整 sqlalchemy URI
- index_colstr
成为索引并定义分区的列。应在 SQL 服务器中为索引列，并且为任何可排序类型。如果类型为数字或时间，则可以从
npartitions或bytes_per_chunk推断分区边界；否则必须提供明确的divisions。
- 返回
- dask.dataframe
参见
read_sql_table将 SQL 数据库表读取到 DataFrame 中。
read_sql_query将 SQL 查询读取到 DataFrame 中。