SSIS自定义日志提供程序：如何访问DTS运行时项目参数？

我刚好处理过类似的场景，要在自定义日志提供程序里拿到项目参数并区分构建模式操作，核心是通过IDtsLogProviderHost接口获取到SSIS运行时的容器对象，进而访问参数集合。下面是具体的实现步骤和代码示例：

核心思路 #

自定义日志提供程序需要依赖IDtsLogProviderHost接口的Host属性，它能返回当前的DtsContainer实例，通过这个实例就能访问项目参数、包变量等运行时信息。你的FilePath项目参数在发布时会自动替换为对应环境的值，所以直接读取参数值就能区分调试/发布模式。

代码实现示例 #

首先确保你的自定义日志提供类实现了IDtsLogProviderHost接口（通常默认模板已经包含），然后在重写的Log方法中添加参数读取逻辑：

using Microsoft.SqlServer.Dts.Runtime;
using System;

public class CustomWebApiLogProvider : LogProviderBase, IDtsLogProviderHost
{
    // 实现IDtsLogProviderHost的Host属性
    public DtsContainer Host { get; set; }

    public override void Log(string eventName, string computerName, string operatorName, string sourceName, string sourceID, string executionID, string messageText, DateTime startTime, DateTime endTime, int dataCode, byte[] dataBytes)
    {
        // 先获取DtsContainer实例
        if (Host == null)
        {
            // 处理宿主未初始化的情况，比如记录警告
            Console.WriteLine("Host container not initialized, cannot access project parameters.");
            return;
        }

        string filePath = string.Empty;
        try
        {
            // 访问项目参数，格式为「Project::参数名」
            Parameter projectParam = Host.Parameters["Project::FilePath"];
            filePath = projectParam.Value.ToString();
        }
        catch (Exception ex)
        {
            // 容错：如果参数不存在，使用默认值
            filePath = @"C:\default.txt";
            // 可以把异常信息也追加到日志内容里
            messageText += $"\nWarning: Failed to get FilePath parameter - {ex.Message}";
        }

        // 根据参数值区分操作逻辑
        if (filePath.IndexOf("debug", StringComparison.OrdinalIgnoreCase) >= 0)
        {
            // 调试模式：调用对应Web API端点
            SendLogToWebApi("https://your-api/debug-log", eventName, messageText, filePath);
        }
        else
        {
            // 发布模式：调用生产端点
            SendLogToWebApi("https://your-api/release-log", eventName, messageText, filePath);
        }
    }

    // 封装Web API调用的方法（根据你的实际实现调整）
    private void SendLogToWebApi(string apiUrl, string eventName, string message, string filePath)
    {
        // 这里写你的HTTP请求逻辑，比如使用HttpClient发送日志数据
        // ...
    }

    // 其他接口实现方法（比如InitializeLogProvider等，按你的现有代码保留）
    public override void InitializeLogProvider(Connections connections, string events, string refTracker)
    {
        // 你的初始化逻辑
    }
}

关键注意事项 #

• 参数命名格式：项目参数必须用Project::参数名的格式访问，包级参数则用Package::参数名，不要写错前缀，否则会抛出参数不存在的异常。
• 发布配置验证：确保发布SSIS项目时，已经为不同环境（调试/发布）配置了正确的FilePath参数值，比如通过SSIS目录的环境变量映射，或者发布向导中的参数替换。
• 异常处理：一定要添加参数读取的异常捕获，避免因为参数配置错误导致整个日志提供程序失效，进而影响SSIS包的运行。
• 接口实现：必须确保类实现了IDtsLogProviderHost接口，否则Host属性无法获取到DtsContainer实例，也就无法访问参数。

这样就能根据FilePath参数的不同值，在自定义日志提供程序中执行对应的Web API调用了。

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