能否通过SQL Alchemy获取MS SQL Server Management Studio消息栏的消息？

SQLAlchemy本身并未设计用于返回非表格类的消息输出，但可以通过直接操作其底层的pyodbc连接对象来实现捕获SSMS消息选项卡内容的需求，以下是具体实现方法：

核心思路 #

利用SQLAlchemy连接可以获取到原生的pyodbc连接，借助pyodbc的消息捕获机制（消息处理函数或游标消息属性）来获取执行SQL时产生的非表格输出。

实现步骤与代码示例 #

方法1：实时捕获消息（通过消息处理函数） #

import sqlalchemy as sa
import pyodbc

# 定义消息处理函数，用于实时接收消息
def message_handler(state, severity, message, info):
    print(f"捕获到消息: {message}")

# 创建SQLAlchemy引擎（使用pyodbc驱动）
engine = sa.create_engine("mssql+pyodbc://用户名:密码@数据源名称")

with engine.connect() as conn:
    # 获取底层原生pyodbc连接
    pyodbc_conn = conn.connection
    # 注册消息处理函数
    pyodbc_conn.set_attr(pyodbc.SQL_ATTR_INFO_MESSAGE_HANDLER, message_handler)
    
    # 执行会产生消息的SQL语句（示例为PRINT语句）
    cursor = pyodbc_conn.cursor()
    cursor.execute("PRINT '这是来自SSMS消息选项卡的内容';")
    cursor.commit()

方法2：执行后批量获取消息（通过游标messages属性） #

import sqlalchemy as sa
import pyodbc

engine = sa.create_engine("mssql+pyodbc://用户名:密码@数据源名称")

with engine.connect() as conn:
    pyodbc_conn = conn.connection
    cursor = pyodbc_conn.cursor()
    
    # 执行目标SQL
    cursor.execute("PRINT '测试消息1'; PRINT '测试消息2';")
    # 获取所有执行产生的消息
    messages = cursor.messages
    # 遍历输出消息
    for msg in messages:
        print(f"[{msg[0]}] {msg[1]}")
    cursor.commit()

注意事项 #

• 必须使用mssql+pyodbc作为SQLAlchemy的连接驱动，该方案依赖pyodbc的消息捕获能力
• 直接操作底层连接时，需手动管理事务（调用cursor.commit()或cursor.rollback()）
• 若使用SQLAlchemy原生的conn.execute()方法，由于其会自动关闭游标，无法获取messages属性，因此必须使用底层pyodbc游标执行SQL
• 对于BACKUP DATABASE、RESTORE DATABASE等会产生大量输出的操作，两种方法均能完整捕获所有消息

内容的提问来源于stack exchange，提问作者Herman Autore