c# - ScriptBuffer 在作为循环的一部分从事件调用时抛出 NullReferenceException - SSIS 脚本组件
问题描述
我有一个 SSIS 包,它调用 aData Flow Task
作为循环的一部分,该循环迭代不同的端点地址(超出范围)。
有Data Flow Task
一个源Script Component
负责调用 REST API 并为每个结果创建一行。
有3个输出缓冲区;1.实际数据行 2.错误行 3.监控
用于遥测的监控缓冲区,通过EventHander
每次 API 发出请求时触发的事件 ( ) 填充。
在ForEach
intControl Flow
循环的第一次迭代期间,一切都按预期运行,所有缓冲区都生成正确的行。
但是,在下一次迭代期间,事件中填充的监视缓冲区会抛出;
System.NullReferenceException: Object reference not set to an instance of an object.
at Microsoft.SqlServer.Dts.Pipeline.ScriptComponentHost.HandleUserException(Exception e)
at Microsoft.SqlServer.Dts.Pipeline.ScriptComponentHost.PrimeOutput(Int32 outputs, Int32[] outputIDs, PipelineBuffer[] buffers)
at Microsoft.SqlServer.Dts.Pipeline.ManagedComponentHost.HostPrimeOutput(IDTSManagedComponentWrapper100 wrapper, Int32 outputs, Int32[] outputIDs, IDTSBuffer100[] buffers, IntPtr ppBufferWirePacket)
我不明白为什么MonitoringBuffer
在接下来的迭代中没有初始化。
调用时发生异常MonitoringBuffer.AddRow();
。
以下是为便于阅读而简化的整个脚本组件:
[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{
private string ClientCode { get { return Variables.ErplyClientCode; } }
private string Username { get { return Variables.ErplyUsername; } }
private string Password { get { return Variables.ErplyPassword; } }
private bool IsTest { get { return Variables.IsTest; } }
private int ErplyRecordsPerPage { get { return Variables.ErplyRecordsPerPage; } }
private string ErplyDebugOutputPath { get { return Variables.ErplyDebugOutputPath; } }
private DateTime ChangeSince { get { return Variables.ChangeSince; } }
private int records { get; set; }
private int errors { get; set; }
private string rawFolder { get; set; }
public override void PreExecute()
{
base.PreExecute();
}
public override void PostExecute()
{
base.PostExecute();
}
public override void CreateNewOutputRows()
{
ErplyAPI.OnPreRequestEvent += new EventHandler<EAPIEvent>(ErplyAPI_OnPreRequestEvent);
var staff = ErplyAPI.getStaff(ClientCode, Username, Password, ChangeSince, ErplyRecordsPerPage, IsTest);
foreach (var p in staff.List)
{
try
{
if (!p.IsError)
{
EmployeeBuffer.AddRow();
EmployeeBuffer.employeeID = p.employeeID;
}
else
{
ErrorBuffer.AddRow();
ErrorBuffer.employeeID = p.employeeID;
ErrorBuffer.Error = p.Error.Message.Trim() + "\n" + p.Error.StackTrace;
errors++;
}
records++;
}
catch (Exception ex)
{
this.ComponentMetaData.FireWarning(0, "Script", ex.Message + "\n" + ex.StackTrace, string.Empty, 0);
}
}
EmployeeBuffer.SetEndOfRowset();
ErrorBuffer.SetEndOfRowset();
}
private void ErplyAPI_OnPreRequestEvent(object sender, EAPIEvent e)
{
var request = string.Empty;
var sessionKey = string.Empty;
bool fireAgain = true;
if (e == null)
{
ComponentMetaData.FireWarning(0, "SC_ERPLY_API", string.Format("EAPIEvent is NULL in ErplyAPI_OnPreRequestEvent. Amonit did not log the Erply request."), string.Empty, 0);
return;
}
if (e.eAPI == null)
{
ComponentMetaData.FireWarning(0, "SC_ERPLY_API", string.Format("EAPIEvent.eAPI is NULL in ErplyAPI_OnPreRequestEvent. Amonit did not log the Erply request."), string.Empty, 0);
return;
}
try
{
if (e.Parameters != null && e.Parameters.ContainsKey("request"))
request = e.Parameters["request"].ToString();
if (request != "verifyUser" && e.Parameters != null && e.Parameters.ContainsKey("sessionKey"))
sessionKey = e.Parameters["sessionKey"].ToString();
}
catch (Exception ex)
{
ComponentMetaData.FireWarning(0, "SC_ERPLY_API", string.Format("Error occurred assigning variables from EAPIEvent parameters in ErplyAPI_OnPreRequestEvent. {0} {1}", ex.Message, ex.StackTrace), string.Empty, 0);
}
try
{
MonitoringBuffer.AddRow(); // Exception occurs here
MonitoringBuffer.Request = ResizeString(request, 255);
MonitoringBuffer.SessionKey = ResizeString(sessionKey, 128);
}
catch (Exception ex)
{
var message = string.Format("Error occurred outputting Erply request in ErplyAPI_OnPreRequestEvent. {0} {1}", ex.Message, ex.StackTrace);
MonitoringBuffer.ErrorMessage = ResizeString(message, 8000);
ComponentMetaData.FireWarning(0, "SC_ERPLY_API", message, string.Empty, 0);
}
finally
{
MonitoringBuffer.EndOfRowset();
}
}
}
解决方案
我把问题解决了。
从事件访问变量分配器时引发异常。由于某种原因,GetValueWithContext(ScriptComponent.EvaluatorContext)
在第二次通话期间被丢弃。为什么会发生这种情况超出了我的理解。
解决方案很简单,将变量分配器中的变量分配给OnPreExecute
函数中的局部属性或变量。
最好不要调用变量分配器,CreateNewOutputRows
因为它会导致变量锁定。
推荐阅读
- parsing - 删除 S -> S(S)S 的左递归 | e
- socket.io - EJS 中的无限滚动
- windows - 如何在 Windows 上更改命令行的 git login?
- sql - 如何使用 like 语句检查 where 子句中 json 数组的每个项目
- amazon-ses - 批量发送时如何在 AWS SES 电子邮件中包含唯一变量?
- loopbackjs - Loopback4 DefaultTransactionalRepository 不起作用
- .net-core - 相当于 Tag Helper .NET Core 中的 Telerik Html.Kendo().Grid(Model)?
- javascript - 如何在不破坏任何功能的情况下使用 barba.js 运行其他 JS 文件
- azure - Azure Function 混合连接到共享文件夹
- mysql - 如何使用 COUNT(*) 在 GROUP BY 中包含不存在的值?