CREATE PROCEDURE my_procedure
    @Param INT
AS
    SELECT Col1,Col2
    FROM Table
    WHERE Col2 = @Param

我希望能够将其用作：

import pandas as pd
import pyodbc
 
query = 'EXEC my_procedure @Param = {0}'.format(my_param)
conn = pyodbc.connect(my_connection_string)
 
df = pd.read_sql(query,conn)

但这会引发错误：

ValueError: Reading a table with read_sql is not supported for a DBAPI2 connection. Use an sqlAlchemy engine or specify an sql query

sqlAlchemy也不起作用：

import sqlalchemy
engine = sqlalchemy.create_engine(my_connection_string)
df = pd.read_sql(query,engine)

抛出：

ValueError: Could not init table 'my_procedure'

事实上,我可以直接使用pyodbc执行语句：

cursor = conn.cursor()
cursor.execute(query)
results = cursor.fetchall()
df = pd.DataFrame.from_records(results)

有没有办法将这些过程结果直接发送到DataFrame？