ScriptBuffer генерирует исключение NullReferenceException при вызове из события как часть al oop - Компонент сценария служб SSIS

Question

У меня есть пакет служб SSIS, который вызывает Data Flow Task как часть al oop, который выполняет итерацию различных адресов конечной точки (вне области видимости).

У Data Flow Task есть источник Script Component, отвечающий за вызов REST API и создание строки для каждого результата.

Есть 3 выходных буфера; 1. строка фактических данных 2. строка ошибки 3. мониторинг

Буфер мониторинга, используемый для телеметрии и заполняемый событием (EventHander), которое запускается каждый раз, когда API выполняет запрос.

Во время первой итерации ForEach int * Control Flow l oop все работает как положено, все буферы выдают правильные строки.

Однако, во время следующих итераций буфер мониторинга который заполняется событиями throws;

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();.

Вот весь компонент Script, упрощенный для удобства чтения:

[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();
        }
    }
}