2

我有一个执行多个任务的 SSIS 包。我在 Business Intelligence Studio 2005 中为 OnExecStatusChanged 事件在包级别手动添加了一个事件处理程序。

我的问题是，如何在 C# 中为此事件添加处理程序？我已经加载了这里指出的包，我还创建了一个继承自 Microsoft.SqlServer.Dts.Runtime.DefaultEvents 的自定义类，这是我的“监听器”：

    Microsoft.SqlServer.Dts.Runtime.SqlPackageEventListener sqlListener = new SqlPackageEventListener();
    Microsoft.SqlServer.Dts.Runtime.Application sqlPackageLoader = new Application();
    Microsoft.SqlServer.Dts.Runtime.Package sqlPackage = sqlPackageLoader.LoadPackage(@"path\MigrateData.dtsx", sqlListener);
    sqlPackage.Execute(null, null, sqlListener, null, null);

如果我检查 sqlPackage.EventHandlers.Count 属性，我会得到在 Business Intelligence Studio 中添加的处理程序的正确编号。

有没有办法在 C# 中处理这些事件？

谢谢。

4

1 回答 1

4

好吧，我没有找到任何东西，所以我想出了一个解决方法，所以我会自动回复我：

由于无法直接捕获 SSIS 包产生的事件，因此我在侦听器中实现了自己的事件：

public class SqlPackageEventListener : DefaultEvents
{
    public SqlPackageChangedHandler OnPackageError;

    public override bool OnError(DtsObject source, int errorCode, string subComponent, string description, string helpFile, int helpContext, string idofInterfaceWithError) {
        OnPackageError(this, new PackageErrorEventArgs(source, subComponent, description));
        return base.OnError(source, errorCode, subComponent, description, helpFile, helpContext, idofInterfaceWithError);
    }

    public delegate void SqlPackageChangedHandler(
        object sqlPackage,
        EventArgs packageInfo
        );
}

public class PackageErrorEventArgs : EventArgs 
{
    private DtsObject source;
    public DtsObject Source {
        get { return source; }
        set { source = value; }
    }

    private string subcomponent;
    public string Subcomponent {
        get { return subcomponent; }
        set { subcomponent = value; }
    }

    private string description;
    public string Description {
        get { return description; }
        set { description = value; }
    }

    public PackageErrorEventArgs(DtsObject source, string subcomponent, string description) {
        this.description = description;
        this.source = source;
        this.subcomponent = subcomponent;
    }
}

public class Test 
{
    SqlPackageEventListener sqlListener = new SqlPackageEventListener();
    sqlListener.OnPackageError += new SqlPackageEventListener.SqlPackageChangedHandler(sqlListener_OnPackageError);
    Microsoft.SqlServer.Dts.Runtime.Application sqlPackageLoader = new Microsoft.SqlServer.Dts.Runtime.Application();
    Microsoft.SqlServer.Dts.Runtime.Package sqlPackage = Microsoft.SqlServer.Dts.Runtime.sqlPackageLoader.LoadPackage(@"path_to\file.dtsx", sqlListener);
    sqlPackage.Execute(null, null, sqlListener, null, null)

    public void sqlListener_OnPackageError(object sender, EventArgs args) {
        //code to handle the event
    }
}

因此，“技巧”是将委托添加到您传递给 Package 对象的 LoadPackage 方法的“侦听器”对象，这样，我们可以访问侦听器内部的“OnError”覆盖并引发事件。如您所见，我实现了自己的 EventArguments 类，因此我们可以将重要数据传递给我们的处理程序代码，并查看正在运行的包或从 DefaultEvents 继承时通过覆盖方法可以获得的任何其他信息。

当然，我在这里只实现了 OnError，您可以实现 SQL Server 支持的任何其他您喜欢的处理程序，并且可以覆盖，因为这是我们引发事件的范围。

这样，我可以创建我的 SqlPackageEventListener 对象并使用 sqlListener_OnPackageError 方法处理它的“OnPackageError”事件，并在 SSIS 包的执行导致任何错误的情况下做任何我需要的事情。

于 2008-12-12T00:35:29.070 回答