能否在链接服务器上异步执行UNION ALL操作？

针对你需要在30多台远程服务器上并行执行查询、避免因少数慢连接拖慢整体速度的需求，以下是几种可行的异步/并行处理方案：

1. 利用SQL Server Agent实现并行查询 #

你可以为每台远程服务器创建独立的SQL Agent作业，每个作业负责执行对应服务器的查询并将结果写入统一的中间表，最后汇总中间表的数据。

步骤示例： #

• 首先创建一个用于存储结果的中间表（架构和目标表一致）：

CREATE TABLE dbo.RemoteQueryResults (
    -- 复制目标表的所有字段
    Col1 INT,
    Col2 VARCHAR(50),
    -- ... 其他字段
    ServerSource VARCHAR(100) -- 可选，标记数据来源服务器
)

• 生成动态SQL来批量创建作业（可根据服务器列表循环生成）：

DECLARE @ServerName NVARCHAR(100) = 'server1'
DECLARE @JobName NVARCHAR(128) = N'Query_' + @ServerName
DECLARE @SQL NVARCHAR(MAX) = N'INSERT INTO dbo.RemoteQueryResults SELECT *, ''' + @ServerName + ''' FROM ' + QUOTENAME(@ServerName) + '.dbo.table WITH (NOLOCK)'

-- 创建作业
EXEC msdb.dbo.sp_add_job @job_name = @JobName
EXEC msdb.dbo.sp_add_jobstep @job_name = @JobName,
    @step_name = N'Execute Remote Query',
    @subsystem = N'TSQL',
    @command = @SQL
EXEC msdb.dbo.sp_add_jobserver @job_name = @JobName, @server_name = @@SERVERNAME

• 批量启动所有作业后，通过查询系统视图监控完成状态，待全部完成后汇总结果：

-- 监控作业状态（仅示例，需根据实际场景调整）
SELECT job.name, activity.run_requested_date, activity.stop_execution_date
FROM msdb.dbo.sysjobs job
JOIN msdb.dbo.sysjobactivity activity ON job.job_id = activity.job_id
WHERE job.name LIKE 'Query_%'

-- 汇总结果
SELECT * FROM dbo.RemoteQueryResults

2. 应用层异步并行调用 #

如果有业务应用层（比如C#、Python），可以在应用端开启多个异步任务，同时连接不同的远程服务器执行查询，最后在应用层合并结果。这种方式无需在数据库端配置复杂组件，灵活性更高。

Python示例（用asyncio+aioodbc）： #

import asyncio
import aioodbc

async def fetch_server_data(server_name):
    conn_str = f'DRIVER={{ODBC Driver 17 for SQL Server}};SERVER={server_name};DATABASE=YourDB;Trusted_Connection=yes;'
    async with aioodbc.connect(conn_str) as conn:
        async with conn.cursor() as cur:
            await cur.execute('SELECT * FROM table WITH (NOLOCK)')
            return await cur.fetchall()

async def main():
    servers = ['server1', 'server2', ...] # 替换为你的30+服务器列表
    tasks = [fetch_server_data(srv) for srv in servers]
    # 并行执行，允许个别服务器失败不中断整体
    results = await asyncio.gather(*tasks, return_exceptions=True)
    # 合并有效结果
    all_data = []
    for res in results:
        if not isinstance(res, Exception):
            all_data.extend(res)
    print(f'Total collected records: {len(all_data)}')

if __name__ == '__main__':
    asyncio.run(main())

3. 使用Service Broker实现数据库级异步 #

SQL Server的Service Broker支持异步消息传递，可以将每个远程查询封装成异步任务，执行完成后将结果写入中间表。这种方案适合纯数据库端的异步处理，但需要提前配置Service Broker。

核心步骤： #

• 启用数据库的Service Broker：

ALTER DATABASE YourDB SET ENABLE_BROKER;

• 创建消息类型、契约、队列和服务，编写用于处理远程查询的存储过程，通过发送消息触发异步执行。每个消息对应一台服务器的查询任务，存储过程执行查询并写入结果表。

这种方案配置较复杂，但适合长期运行的自动化场景。

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