Udostępnij za pośrednictwem


Podnoszenie i definiowanie zdarzeń w niestandardowego zadania

Integration Services Zawiera czas uruchomienia silnika kolekcja zdarzeń, zapewniające stan postępu zadania podczas sprawdzania poprawności i wykonywane zadania.IDTSComponentEvents Interfejs definiuje te zdarzenia i dostarczanych do zadań jako parametr Validate i Execute metody.

Istnieje inny zestaw zdarzeń, które są zdefiniowane w IDTSEvents interfejs, które są wywoływane w imieniu zadań przez TaskHost.TaskHost Informuje o zdarzeniach, które występują przed i po zakończeniu sprawdzania poprawności i wykonanie, zadanie stwarza zdarzenia, które występują podczas realizacji i sprawdzania poprawności.

Tworzenie niestandardowych zdarzeń

Deweloperzy zadanie niestandardowe można zdefiniować nowe, niestandardowych zdarzeń, tworząc nowy EventInfo w celu ich wykonania zastąpiona InitializeTask metoda.Po EventInfo jest tworzone, jest dodawany do EventInfos kolekcja za pomocą Add metoda.Podpis metody Add Metoda jest następująca:

public void Add(string eventName, string description, bool allowEventHandlers, string[] parameterNames, TypeCode[] parameterTypes, string[] parameterDescriptions);

Następujący kod przykładowy pokazuje InitializeTask metoda niestandardowego zadania, gdzie tworzone są dwa zdarzenia niestandardowego i ich właściwości są zestaw.Nowe zdarzenia są następnie dodany do EventInfos kolekcja.

Pierwszy niestandardowe zdarzenie ma eventName z "OnBeforeIncrement" i description z "Fires po zaktualizowaniu wartości początkowe." Następny parametr true wartość, wskazuje, że to zdarzenie powinno umożliwić kontener programu obsługa zdarzeń utworzony do obsługa zdarzeń.obsługa zdarzeń Jest kontener, który zawiera strukturę w pakiecie i usługi do zadania, podobnie jak inne kontenery takich jak pakiet, sekwencja, ForLoop i ForEachLoop.Gdy allowEventHandlers parametr jest true, DtsEventHandler obiekty są tworzone dla zdarzenie.Parametry, które zostały zdefiniowane dla zdarzenie są teraz dostępne do DtsEventHandler w zmiennych kolekcja z DtsEventHandler.

public override void InitializeTask(Connections connections,
   VariableDispenser variables, IDTSInfoEvents events,
   IDTSLogging log, EventInfos eventInfos,
   LogEntryInfos logEntryInfos, ObjectReferenceTracker refTracker)
{
    this.eventInfos = eventInfos;
    string[] paramNames = new string[1];
    TypeCode[] paramTypes = new TypeCode[1]{TypeCode.Int32};
    string[] paramDescriptions = new string[1];

    paramNames[0] = "InitialValue";
    paramDescriptions[0] = "The value before it is incremented.";

    this.eventInfos.Add("OnBeforeIncrement", 
      "Fires before the task increments the value.",
      true,paramNames,paramTypes,paramDescriptions);
    this.onBeforeIncrement = this.eventInfos["OnBeforeIncrement"];

    paramDescriptions[0] = "The value after it has been incremented.";
    this.eventInfos.Add("OnAfterIncrement",
      "Fires after the initial value is updated.",
      true,paramNames, paramTypes,paramDescriptions);
    this.onAfterIncrement = this.eventInfos["OnAfterIncrement"];
}
Public Overrides Sub InitializeTask(ByVal connections As Connections, _
ByVal variables As VariableDispenser, ByVal events As IDTSInfoEvents, _
ByVal log As IDTSLogging, ByVal eventInfos As EventInfos, _
ByVal logEntryInfos As LogEntryInfos, ByVal refTracker As ObjectReferenceTracker) 

    Dim paramNames(0) As String
    Dim paramTypes(0) As TypeCode = {TypeCode.Int32}
    Dim paramDescriptions(0) As String

    Me.eventInfos = eventInfos

    paramNames(0) = "InitialValue"
    paramDescriptions(0) = "The value before it is incremented."

    Me.eventInfos.Add("OnBeforeIncrement", _
      "Fires before the task increments the value.", _
      True, paramNames, paramTypes, paramDescriptions)
    Me.onBeforeIncrement = Me.eventInfos("OnBeforeIncrement")

    paramDescriptions(0) = "The value after it has been incremented."
    Me.eventInfos.Add("OnAfterIncrement", _
      "Fires after the initial value is updated.", True, _
      paramNames, paramTypes, paramDescriptions)
    Me.onAfterIncrement = Me.eventInfos("OnAfterIncrement")

End Sub

Podnoszenie zdarzenia niestandardowego

Zdarzenia niestandardowe są wywoływane przez wywołanie FireCustomEvent metoda.Poniższy wiersz kodu wywołuje zdarzenie niestandardowego.

componentEvents.FireCustomEvent(this.onBeforeIncrement.Name,
   this.onBeforeIncrement.Description, ref arguments,
   null, ref bFireOnBeforeIncrement);
componentEvents.FireCustomEvent(Me.onBeforeIncrement.Name, _
Me.onBeforeIncrement.Description, arguments, _
Nothing,  bFireOnBeforeIncrement)

Przykład

W poniższym przykładzie przedstawiono zadania, który definiuje zdarzenia niestandardowego w InitializeTask metoda dodaje niestandardowe zdarzenie, aby EventInfos kolekcja i następnie wywołuje zdarzenia niestandardowego podczas jego Execute metoda wywołując FireCustomEvent metoda.

[DtsTask(DisplayName = "CustomEventTask")]
    public class CustomEventTask : Task
    {
        public override DTSExecResult Execute(Connections connections, 
          VariableDispenser variableDispenser, IDTSComponentEvents componentEvents,
           IDTSLogging log, object transaction)
        {
            bool fireAgain;
            object[] args = new object[1] { "The value of the parameter." };
            componentEvents.FireCustomEvent( "MyCustomEvent", 
              "Firing the custom event.", ref args,
              "CustomEventTask" , ref fireAgain );
            return DTSExecResult.Success;
        }

        public override void InitializeTask(Connections connections,
          VariableDispenser variableDispenser, IDTSInfoEvents events,
          IDTSLogging log, EventInfos eventInfos,
          LogEntryInfos logEntryInfos, ObjectReferenceTracker refTracker)
        {
            string[] names = new string[1] {"Parameter1"};
            TypeCode[] types = new TypeCode[1] {TypeCode.String};
            string[] descriptions = new string[1] {"Parameter description." };

            eventInfos.Add("MyCustomEvent",
             "Fires when my interesting event happens.",
             true, names, types, descriptions);

        }
   }
<DtsTask(DisplayName = "CustomEventTask")> _ 
    Public Class CustomEventTask
     Inherits Task
        Public Overrides Function Execute(ByVal connections As Connections, _
          ByVal variableDispenser As VariableDispenser, _
          ByVal componentEvents As IDTSComponentEvents, _
          ByVal log As IDTSLogging, ByVal transaction As Object) _
          As DTSExecResult

            Dim fireAgain As Boolean
            Dim args() As Object =  New Object(1) {"The value of the parameter."}

            componentEvents.FireCustomEvent("MyCustomEvent", _
              "Firing the custom event.", args, _
              "CustomEventTask" ,  fireAgain)
            Return DTSExecResult.Success
        End Function
 
        Public Overrides  Sub InitializeTask(ByVal connections As Connections, _
          ByVal variableDispenser As VariableDispenser,
          ByVal events As IDTSInfoEvents,
          ByVal log As IDTSLogging, ByVal eventInfos As EventInfos, ByVal logEnTryInfos As LogEnTryInfos, ByVal refTracker As ObjectReferenceTracker)

            Dim names() As String =  New String(1) {"Parameter1"}
            Dim types() As TypeCode =  New TypeCode(1) {TypeCode.String}
            Dim descriptions() As String =  New String(1) {"Parameter description."}

            eventInfos.Add("MyCustomEvent", _
              "Fires when my interesting event happens.", _
              True, names, types, descriptions)

        End Sub

    End Class
Ikona usług Integration Services (mała)Bieżąco z usług integracji

Najnowsze pliki do pobrania, artykuły, próbki i wideo firmy Microsoft, jak również wybranych rozwiązań ze Wspólnoty, odwiedź witrynę Integration Services strona na MSDN i TechNet:

Aby otrzymywać automatyczne powiadomienia dotyczące tych aktualizacji, zasubskrybuj źródła danych RSS dostępne na tej stronie.