使用 sqlalchemy 的 pandas.read_sql 中的使用错误

Question

假设您有以下代码：

import pandas as pd
pd.read_sql("SELECT * FROM foo_schema.run_info WHERE id=:param order by run_id desc", s.bind, **{'param':5})

而s.bind 是sqlchemy 的引擎对象。

我收到以下错误：

{TypeError}read_sql() got an unexpected argument 'param'

我的函数调用有什么问题？

Answer 1

来自docs，

pd.read_sql?
...
params : list, tuple or dict, optional, default: None

您正在做的是解压缩字典，因此它作为关键字参数传递。请参阅Understanding kwargs in Python 了解更多信息。

正确的传参方式是：

pd.read_sql(... params={'param':5})

---

正如@Ilja Everilä 专业提到的，您应该将查询包装在对text 的调用中，以便正确解析参数语法。

from sqlalchemy import text
pd.read_sql(text(query), s.bind, params={'param':5})