非列格式主机报表导入SQL的SSIS入门技术求助

阿华AIGC实验室

2026-5-6

Hey there! 作为SSIS新手，处理这种主机导出的非结构化报表确实是个挺有挑战的入门场景——但正好是你深入理解SSIS文本处理逻辑的好机会。我来一步步给你拆解实现思路，完全是教你方法，不是代做，放心~

针对主机非结构化报表的SSIS入门实现指南

1. 先搞定核心前提：摸透报表的结构规律

非列格式的报表不像CSV/Excel有固定分隔符，所以第一步必须手动分析样本报表的重复模式，把规则明确下来：

标记日期行的特征：比如是不是固定以Report Date: 开头，或者在报表的第X行
定位数据块的边界：每个服务条目从哪行开始（比如出现Service Code:的行），到哪行结束（比如下一个服务条目开始前，或者出现特定分隔符的行）
明确每个字段的提取规则：比如服务代码是跟着Service Code:后面的字符串，CURR IP的数量是某一行第N到M个字符，或者按空格分割后的第几个元素

建议拿一份样本报表，用Notepad++打开，开启「显示所有字符」功能，把这些规则一条条记下来——这是后续写SSIS逻辑的基础。

2. SSIS处理非结构化文本的核心组合：Flat File Source + 脚本组件

这两个组件是处理这类场景的黄金搭档，比现成的解析组件灵活得多，也是你学习SSIS自定义逻辑的关键：

步骤1：用Flat File Source读取原始文本

新建SSIS包，拖一个Data Flow Task到控制流面板
双击打开Data Flow，拖入Flat File Source，右键配置：
- 选择你的主机导出文件，格式选Ragged Right（因为每行长度可能不一致，适合零散行的情况）
- 确认行分隔符：主机文件可能用\r\n、\n甚至主机特定的换行符（用Notepad++看显示所有字符就能找到）
- 配置完成后，每一行会被读取成一个单独的字段，建议命名为RawLine，数据类型选DT_WSTR（支持中文等特殊字符）

步骤2：用脚本组件（Transformation）过滤+提取数据

这是最核心的部分，也是你学习SSIS脚本编程的重点：

把Flat File Source的输出箭头连到Script Component，选择「Transformation」类型
双击脚本组件，在「输入列」里选中RawLine；在「输出列」里定义你要提取的所有字段，比如：
- ReportDate（类型DT_DATE）
- ServiceCode（类型DT_STR，长度根据实际需求设）
- Description（类型DT_WSTR，长度设长一点）
- CURR_IP_Qty（类型DT_I4，整数）
- YTD_OP_Amt（类型DT_CY，货币）
打开脚本编辑器（推荐选C#，资料更丰富），在脚本里实现逐行判断和提取逻辑：
- 先定义几个缓存变量：用来存储报表日期（因为日期在头部，所有数据行都要用）、当前服务的代码和描述等
- 在Input0_ProcessInputRow方法里，对每一行RawLine做判断：
  - 如果是日期行，提取日期并存到缓存变量
  - 如果是服务代码行，提取代码，重置当前服务的缓存
  - 如果是描述行，把内容存入缓存
  - 如果是CURR/YTD数据行，提取对应的数量和金额，然后把所有缓存的字段值赋值给输出行，调用Output0Buffer.AddRow()输出完整的一条数据

给你一个简化的C#代码示例（你要根据自己的报表规则修改）：

// 脚本内部的缓存变量，用来存储报表日期和当前服务的信息
private DateTime? _reportDate;
private string _currentServiceCode;
private string _currentDescription;

public override void Input0_ProcessInputRow(Input0Buffer Row)
{
    string rawLine = Row.RawLine?.Trim() ?? string.Empty;
    
    // 处理报表日期行（假设行开头是"Report Date: "）
    if (rawLine.StartsWith("Report Date: "))
    {
        string dateText = rawLine.Substring("Report Date: ".Length).Trim();
        if (DateTime.TryParse(dateText, out DateTime parsedDate))
        {
            _reportDate = parsedDate;
        }
        return;
    }
    
    // 处理服务代码行（假设行开头是"Service Code: "）
    if (rawLine.StartsWith("Service Code: "))
    {
        _currentServiceCode = rawLine.Substring("Service Code: ".Length).Trim();
        _currentDescription = string.Empty;
        return;
    }
    
    // 处理描述行（假设描述在服务代码行的下一行）
    if (!string.IsNullOrEmpty(_currentServiceCode) && string.IsNullOrEmpty(_currentDescription))
    {
        _currentDescription = rawLine;
        return;
    }
    
    // 处理CURR IP数据行（假设行包含"CURR IP"）
    if (rawLine.Contains("CURR IP"))
    {
        // 这里要根据你的报表格式提取数量和金额，比如按空格分割
        string[] parts = rawLine.Split(new[] {' '}, StringSplitOptions.RemoveEmptyEntries);
        // 假设第3个元素是数量，第5个是金额（请根据实际调整）
        if (int.TryParse(parts[2], out int currIpQty) && decimal.TryParse(parts[4], out decimal currIpAmt))
        {
            // 输出一行完整数据
            Output0Buffer.AddRow();
            Output0Buffer.ReportDate = _reportDate.Value;
            Output0Buffer.ServiceCode = _currentServiceCode;
            Output0Buffer.Description = _currentDescription;
            Output0Buffer.CURRIPQty = currIpQty;
            Output0Buffer.CURRIPAmt = currIpAmt;
        }
        
        // 重置当前服务缓存，准备处理下一个条目
        _currentServiceCode = null;
        _currentDescription = null;
    }
}

步骤3：输出到SQL Server表

把脚本组件的输出箭头连到OLE DB Destination（兼容性更好，推荐用这个）
配置OLE DB Destination：选择你的SQL Server连接，然后选择目标表
在「映射」页面，把脚本组件输出的字段和SQL表的字段一一对应，确保数据类型匹配（比如日期对应DATE，金额对应DECIMAL）

3. 进阶技巧和避坑指南

处理异常行：在脚本里加入try-catch块，把无法解析的行转到错误输出（脚本组件可以配置错误输出），方便后续排查问题
批量处理多个文件：如果要处理多个报表文件，可以用Foreach Loop Container遍历文件夹，把文件路径存在包级变量里，让Flat File Source动态读取变量里的文件路径
调试技巧：脚本组件可以加断点调试，或者用MessageBox.Show(rawLine)输出当前行内容（生产环境一定要去掉）
参考Monarch的规则：你现在用Monarch处理报表，可以参考Monarch里定义的模板规则（比如哪些行是数据行、字段的位置），把这些规则直接转换成SSIS脚本里的判断逻辑，能少走很多弯路