如何基于SQL Server配置表时间调度SSIS包执行并实现文件校验通知

需求可行性说明 #

你描述的调度、文件校验、通知需求完全可以在SSIS原生功能体系内实现，不需要额外引入第三方工具，具体实现步骤如下：

实现步骤 #

1. 新增包级公共变量 #

先在SSIS包的变量面板创建以下变量，用于流程参数传递：

• ExecutionTime：DateTime类型，存储从配置表查询得到的执行起始时间
• TargetFilePath：String类型，存储文件共享路径下的目标文件完整地址，例如\\file-share\import\business_data.csv
• FileExistsFlag：Boolean类型，默认值为False，存储文件校验结果
• NotifyEmail：String类型，存储接收通知的邮箱别名

2. 读取配置表执行时间 #

在现有包的流程最前端新增执行SQL任务，配置规则：

• 连接管理器选择存储配置表的SQL Server实例
• SQL语句填写对应查询逻辑，例如：SELECT exec_start_time FROM dbo.import_config WHERE config_id = 'flat_file_import'，结果集选择「单行」
• 在「结果集」映射页，将查询得到的时间字段赋值给变量@[User::ExecutionTime]

3. 定时触发逻辑实现 #

推荐两种适配不同场景的方案，生产环境优先选第二种：

方案A：包内等待触发（适合测试/轻量场景）

在执行SQL任务后新增脚本任务，设置ExecutionTime为只读变量，用C#实现等待逻辑：

using System.Threading;
public void Main()
{
    DateTime execTime = Convert.ToDateTime(Dts.Variables["User::ExecutionTime"].Value);
    while(DateTime.Now < execTime)
    {
        // 没到执行时间就休眠1分钟，可自行调整粒度
        Thread.Sleep(60 * 1000);
    }
    Dts.TaskResult = (int)ScriptResults.Success;
}

方案B：SQL Server代理调度（生产环境推荐）

• 先编写一个SQL校验脚本，判断当前时间是否到达配置的执行时间，符合条件返回1，不符合返回0
• 新建SQL Server代理作业：
  • 步骤1运行上述校验脚本，如果返回值为0，设置作业1分钟后重试，重试上限设置为执行时间延后的最大阈值
  • 步骤2配置为调用SSIS包，仅步骤1执行成功（到达执行时间）时触发
    该方案无需包内驻留等待，稳定性更高，也方便排查调度日志。

4. 文件存在性校验 #

定时触发逻辑后新增脚本任务，设置TargetFilePath为只读变量、FileExistsFlag为可读写变量，核心校验逻辑：

using System.IO;
public void Main()
{
    string filePath = Dts.Variables["User::TargetFilePath"].Value.ToString();
    Dts.Variables["User::FileExistsFlag"].Value = File.Exists(filePath);
    Dts.TaskResult = (int)ScriptResults.Success;
}

5. 分支流程配置 #

从文件校验脚本任务引出两条优先约束（流程箭头）：

• 第一条指向你已经开发完成的Flat File导入数据流任务，约束类型选「表达式和约束」，表达式填写 @[User::FileExistsFlag] == True
• 第二条指向发送邮件任务，约束表达式填写 @[User::FileExistsFlag] == False，发送邮件任务提前配置SMTP连接管理器，收件人填写@[User::NotifyEmail]变量，自定义邮件主题和内容即可。

可选优化建议 #

• 可以把文件路径、SMTP配置、通知邮箱等参数都存入现有配置表，通过执行SQL任务读取赋值，后续修改配置无需重新部署SSIS包
• 可新增错误捕获容器，导入过程出现异常时也触发邮件通知，附上错误日志信息

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