咨询：如何将SSIS中OLE DB查询结果每日自动通过API发送

1. 直接在SQL查询中生成JSON（解决字段多的问题） #

不用在SSIS里逐个处理字段，直接在你的OLE DB源查询末尾加上FOR JSON PATH语句，就能把查询结果直接转换成JSON格式。示例：

SELECT 
    Column1, Column2, Column3 -- 你的所有查询字段
FROM YourTable
WHERE -- 你的过滤条件
FOR JSON PATH, ROOT('data') -- ROOT可选，用来给JSON加顶层节点

执行这个查询后，OLE DB源会返回一个单行单列的JSON字符串，直接把这个结果映射到SSIS的字符串类型变量（比如@User::JsonPayload）即可。

2. 用Script Task替代Web Service Task发送API #

Web Service Task字段多确实难维护，改用Script Task写代码调用API更灵活：

• 在SSIS包中添加一个Script Task，勾选读取刚才创建的JsonPayload变量。
• 打开Script编辑器（选C#），编写发送POST请求的代码：

using System;
using System.Net.Http;
using System.Text;

public void Main()
{
    string jsonPayload = Dts.Variables["User::JsonPayload"].Value.ToString();
    string apiUrl = "你的同事提供的API地址";

    using (HttpClient client = new HttpClient())
    {
        var content = new StringContent(jsonPayload, Encoding.UTF8, "application/json");
        HttpResponseMessage response = client.PostAsync(apiUrl, content).Result;
        
        // 可选：验证响应状态
        if (response.IsSuccessStatusCode)
        {
            Dts.TaskResult = (int)ScriptResults.Success;
        }
        else
        {
            // 记录错误日志，比如写入SSIS日志或本地文件
            Dts.Events.FireError(0, "API发送失败", response.ReasonPhrase, string.Empty, 0);
            Dts.TaskResult = (int)ScriptResults.Failure;
        }
    }
}

3. 配置每日自动执行 #

用SQL Server Agent Job来调度SSIS包：

• 打开SQL Server Management Studio，创建新的Job。
• 添加一个“SSIS包执行”步骤，选择你的SSIS包路径。
• 设置Job的执行计划为每日指定时间运行。

额外提示 #

• 如果你的SQL Server版本低于2016，不支持FOR JSON，可以在Script Task中读取数据流的结果集，用代码拼接成JSON（比如用Newtonsoft.Json库，需要把DLL放到SSIS运行目录）。
• 记得给SSIS包设置错误处理，比如发送失败时触发邮件通知。

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