根据文档,第一个参数是字符串(表名)或SQLAlchemy
Selectable(
select或
text对象)。换句话说
pd.read_sql(),委派
pd.read_sql_table()整个查询字符串并将其视为表标识符。
首先将查询字符串包装在
text()构造中:
stmt = text('select max(run_ts) from product_analytics.xlations_topic_update_status')pd.read_sql(stmt, con = db_engine).values[0][0]
这种方式
pd.read_sql()将委托给
pd.read_sql_query()。另一种选择是直接调用它。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)