SSIS并行数据流审计与错误处理：动态获取源表名及任务名方案问询

没问题，我帮你梳理下在SSIS里实现这个需求的具体方案——既能精准捕获错误时的源表名和任务名，还能把表名动态存储到变量里，完美适配你7个并行数据流的场景：

因为是7个并行执行的数据流，每个对应独立的源表，我们需要给每个数据流绑定专属的源表标识，再利用SSIS的事件处理程序捕获错误事件，同时提取任务名和对应源表名，最后把这些信息记录下来（或存储到变量中）。重点要避免并行任务的变量冲突问题，所以要注意变量的作用域。

1. 配置专属变量（避免并行冲突） #

不要用全局共享的变量来存源表名，而是给每个数据流任务创建任务级作用域的变量：

• 选中任意一个数据流任务，右键点击「变量」，创建一个字符串类型的变量，命名比如@User::LocalSourceTableName，把作用域设置为当前数据流任务（不要选包级别）
• 给这个变量设置默认值为当前数据流对应的源表名（比如CustomerTable），或者后续通过脚本赋值
• 给剩下的6个数据流任务重复这个操作，每个任务的LocalSourceTableName对应自己的源表名

另外，你可以创建几个包级变量用来临时存储错误信息（方便后续写入审计表）：

• @User::FailedTaskName（字符串）：存出错的任务名称
• @User::FailedSourceTable（字符串）：存出错的源表名
• @User::ErrorDetails（字符串）：存错误代码和描述

2. 给每个数据流绑定源表名（可选，若默认值已设置可跳过） #

如果不想手动设置变量默认值，可以给每个数据流任务添加PreExecute事件处理程序，用脚本任务动态赋值：

1. 选中数据流任务，切换到「事件处理程序」标签页
2. 选择事件为PreExecute，点击「新建」创建事件流程
3. 添加一个脚本任务，在脚本编辑器里写入：

   // 替换成当前数据流对应的源表名
   Dts.Variables["User::LocalSourceTableName"].Value = "CustomerTable";
   Dts.TaskResult = (int)ScriptResults.Success;
   

4. 对所有7个数据流重复这个操作，修改对应的表名字符串即可

3. 配置错误捕获与信息记录 #

接下来给每个数据流任务配置OnError事件处理程序，用来捕获错误并提取所需信息：

1. 选中数据流任务，切换到「事件处理程序」标签页
2. 选择事件为OnError，点击「新建」创建事件流程
3. 在这个事件流程里添加两个组件：

   a. 脚本任务：提取错误相关信息 #

   脚本任务里读取任务级变量、系统错误变量，赋值到包级变量：

   // 获取当前任务名
   string taskName = Dts.Container.Name;
   // 获取当前任务对应的源表名
   string sourceTable = Dts.Variables["User::LocalSourceTableName"].Value.ToString();
   // 获取系统错误信息
   int errorCode = (int)Dts.Variables["System::ErrorCode"].Value;
   string errorDesc = Dts.Variables["System::ErrorDescription"].Value.ToString();
   
   // 赋值到包级变量，方便后续记录
   Dts.Variables["User::FailedTaskName"].Value = taskName;
   Dts.Variables["User::FailedSourceTable"].Value = sourceTable;
   Dts.Variables["User::ErrorDetails"].Value = $"错误代码：{errorCode}，描述：{errorDesc}";
   
   Dts.TaskResult = (int)ScriptResults.Success;
   

   b. 执行SQL任务：写入审计表 #

   添加一个执行SQL任务，连接到你的审计数据库，编写插入语句：

   INSERT INTO SSIS_Audit_ErrorLog (
       SourceTableName, 
       FailedTaskName, 
       ErrorDetails, 
       ErrorOccurredTime
   )
   VALUES (?, ?, ?, GETDATE())
   

   然后在「参数映射」里把对应的包级变量映射到SQL参数上，完成错误信息的持久化。

4. 关于“动态存储表名到单个变量”的说明 #

完全可以实现，但要注意：

• 如果用全局包级变量，并行任务同时执行时会出现变量值被覆盖的问题（比如任务A刚把表名写入变量，任务B马上覆盖，此时任务A出错的话，变量里已经是任务B的表名了）
• 所以更稳妥的方式是用任务级作用域的变量，每个数据流任务拥有自己的源表名变量，互不干扰，在错误事件里直接读取这个专属变量即可

因为有7个并行数据流，不用逐个手动配置事件处理：

1. 先配置好第一个数据流的所有事件处理流程
2. 选中这个数据流任务，右键点击「复制」
3. 右键包设计器空白处，点击「粘贴」，生成副本后修改LocalSourceTableName的值和对应的源表连接即可

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