如何从SSIS包提取数据仓库相关元数据及数据血缘关系？

你之前用的微软文档完全找错了——那个是用来运行SSIS包的，根本不涉及元数据或血缘关系提取，拿不到结果很正常。下面是能直接解决问题的方法：

一、用SSISDB系统视图直接查询（适用于已部署的包） #

如果你的包已经部署到SSISDB目录，直接查系统视图就能拿到所需信息：

1. 获取包关联的数据库/数据源 #

SELECT 
    ex.execution_id,
    pkg.package_name,
    src.data_source_name,
    src.connection_string
FROM 
    catalog.executions ex
JOIN 
    catalog.packages pkg ON ex.package_id = pkg.package_id
JOIN 
    catalog.data_sources src ON pkg.project_id = src.project_id
WHERE 
    ex.status = 7 -- 筛选已完成的执行记录

2. 提取列级血缘关系 #

SELECT 
    cm.source_column_name,
    cm.destination_column_name,
    t.destination_table_name
FROM 
    catalog.column_mappings cm
JOIN 
    catalog.execution_data_statistics eds ON cm.execution_id = eds.execution_id
JOIN 
    catalog.tables t ON eds.table_id = t.table_id

二、无需编码的可视化工具 #

1. SSDT直接查看 #

打开你的SSIS包项目，在「包资源管理器」里展开「数据源」「目标」节点：

• 右键目标组件→「显示高级编辑器」→「输入和输出属性」，能看到完整的列映射关系；
• 数据源节点直接显示关联的数据库和表名。

2. SSMS内置报表 #

在SSMS里连接到Integration Services，进入「目录」→「SSISDB」，右键选「报表」→「标准报表」→「所有执行的详细信息」，报表里会列出数据流动的源表、目标表以及列映射。

3. 第三方工具 #

像ApexSQL Data Diff、Redgate SQL Compare的SSIS专用版本，能自动解析整个包的血缘关系，生成可视化报表。

三、正确的C#解析方案（针对本地.dtsx包） #

如果一定要用代码解析未部署的.dtsx文件，别用官方的运行代码，用下面的逻辑：

using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;

// 加载本地SSIS包
Package pkg = new Package();
pkg.LoadFromFile(@"C:\YourPackagePath\YourPackage.dtsx", null);

// 遍历所有数据流任务
foreach (Executable exec in pkg.Executables)
{
    if (exec is TaskHost taskHost && taskHost.InnerObject is MainPipe dataFlow)
    {
        // 遍历数据流中的所有组件
        foreach (IDTSComponentMetaData100 comp in dataFlow.ComponentMetaDataCollection)
        {
            // 处理OLE DB数据源组件
            if (comp.ComponentClassID == "DTSAdapter.OleDbSource")
            {
                var conn = pkg.Connections[comp.RuntimeConnectionCollection[0].ConnectionManagerID];
                Console.WriteLine($"数据源连接串: {conn.ConnectionString}");
                // 获取关联的表名
                string tableName = comp.CustomPropertyCollection["OpenRowset"].Value.ToString();
                Console.WriteLine($"关联源表: {tableName}");
            }
            // 处理OLE DB目标组件
            if (comp.ComponentClassID == "DTSAdapter.OleDbDestination")
            {
                string destTable = comp.CustomPropertyCollection["OpenRowset"].Value.ToString();
                Console.WriteLine($"目标表: {destTable}");
                // 遍历列映射
                foreach (IDTSInput100 input in comp.InputCollection)
                {
                    foreach (IDTSInputColumn100 destCol in input.InputColumnCollection)
                    {
                        // 通过LineageID关联到源列
                        var sourceComp = dataFlow.ComponentMetaDataCollection.GetObjectByID(destCol.SourceComponentID);
                        foreach (IDTSOutputColumn100 srcCol in sourceComp.OutputCollection[0].OutputColumnCollection)
                        {
                            if (srcCol.LineageID == destCol.LineageID)
                            {
                                Console.WriteLine($"列映射: {srcCol.Name} → {destCol.Name}");
                                break;
                            }
                        }
                    }
                }
            }
        }
    }
}

注意：需要引用Microsoft.SqlServer.ManagedDTS.dll和Microsoft.SqlServer.DTSPipelineWrap.dll，这两个文件在SQL Server安装目录的对应版本号\SDK\Assemblies路径下（比如SQL Server 2019对应150\SDK\Assemblies）。

四、你提到的微软文档翻译（核心内容） #

你贴的文档是《SSIS快速入门：使用.NET运行SSIS包》，核心内容翻译：

本快速入门演示如何通过C#代码运行部署到SSIS目录（SSISDB）的SQL Server Integration Services (SSIS)包。
主要步骤：

1. 配置开发环境：安装Visual Studio、SSIS项目模板及SQL Server数据工具；
2. 编写代码：引用Microsoft.SqlServer.ManagedDTS.dll，通过Catalog类连接SSISDB，调用StartExecution方法启动包执行；
3. 运行代码并验证包执行结果。

这个文档的用途仅为运行包，和你要提取元数据/血缘的需求完全不相关。

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