gpt4 book ai didi

c# - 如何从 C# 中加载的 SSIS 包捕获事件?

转载 作者:搜寻专家 更新时间:2023-10-30 20:13:50 25 4
gpt4 key购买 nike

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

我的问题是,如何在 C# 中为该事件添加处理程序?我已经按照指示加载了包 here我还创建了一个继承自 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# 中处理这些事件?

谢谢。

最佳答案

好吧,我没有找到任何东西,所以我想出了一个变通办法,所以我会自动回复我:

由于无法直接捕获 SSIS 包生成的事件,因此我在 listener 中实现了自己的事件。 :

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 方法的“Listener”对象添加一个委托(delegate),这样,我们就可以访问监听器中的“OnError”重写并引发事件。如您所见,我实现了自己的 EventArguments 类,这样我们就可以将重要数据传递给我们的处理程序代码,并查看正在运行的包或从 DefaultEvents 继承时可以通过覆盖方法获得的任何其他信息。

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

这样我就可以创建我的 SqlPackageEventListener 对象并使用 sqlListener_OnPackageError 方法处理它的“OnPackageError”事件,并在执行 SSIS 包导致的任何错误时执行我需要的任何操作。

关于c# - 如何从 C# 中加载的 SSIS 包捕获事件?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/358273/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com