Za pomocą błąd wyjścia w składnik przepływ danych
Specjalne IDTSOutput100 obiekty o nazwie błąd wyjścia mogą być dodawane do składników, aby umożliwić składnika Przekierowanie wiersze, które nie może przetworzyć podczas wykonywania. Składnik może się pojawić problemy są zwykle określane jako błędy lub truncations i są specyficzne dla każdego składnika.Składniki, które dostarczają wyjść błąd dać użytkownikom składnika elastyczność obsługi błędów za pomocą filtrowania wierszy błędów z wynikiem zestaw, przy braku składnika, gdy wystąpi problem lub ignorowanie błędów i kontynuować.
Aby implementują i obsługują wyjść błędu w składniku, musisz najpierw zestaw UsesDispositions() właściwość składnika true. Następnie należy dodać dane wyjściowe do składnika, który ma swój IsErrorOut() Właściwość zestaw do true. Wreszcie składnik musi zawierać kod, który przekierowuje wierszy w wyniku błędu, gdy występują błędy lub truncations.W tym temacie omówiono trzy następujące czynności i wyjaśniono różnice między wyjść synchronicznych i asynchronicznych błędów.
Tworzenie formatu Error
Tworzenie błąd danych wyjściowych, wywołując New() Metoda OutputCollection(), a następnie ustawiając IsErrorOut() Właściwość nowe dane wyjściowe do true. Jeżeli dane wyjściowe są asynchronicznych, nic poza należy przeprowadzić w danych wyjściowych.Jeśli dane wyjściowe są synchroniczne, a nie ma innego wyjścia jest synchroniczna w tych samych danych wejściowych, należy również zestaw ExclusionGroup() i SynchronousInputID() właściwości. Obie właściwości mogą mieć tej samej wartości jak innych danych wyjściowych jest synchroniczna w tych samych danych wejściowych.Jeśli te właściwości nie są zestaw na wartość różną od zera, wiersze, dostarczone przez dane wejściowe są wysyłane do obu dane wyjściowe są synchroniczne w danych wejściowych.
Jeśli składnik napotka błąd lub obcinania podczas wykonywania, przechodzi w zależności od ustawień ErrorRowDisposition() i TruncationRowDisposition() właściwości danych wejściowych lub dane wyjściowe lub wejściowe i wyjściowe kolumna, w którym wystąpił błąd. Wartości tych właściwości powinny być zestaw domyślnie RD_NotUsed(). Dane wyjściowe błąd składnika jest połączony ze składnikiem niższego rzędu, ta właściwość jest zestaw przez użytkowników składnika oraz pozwala użytkownika określa, jak składnik obsługuje błąd lub obcinania.
Podczas wypełniania kolumny błędów
Po utworzeniu wyjścia błąd zadania przepływ danych automatycznie dodaje dwie kolumna do kolekcja kolumn wyjściowych.Te kolumna są używane przez składniki, do określenia IDENTYFIKATORA kolumna, która spowodowała błąd lub obcięcia i podaj kod błędu specyficzny dla składnika.Te kolumny są generowane automatycznie, ale wartości zawarte w kolumnach muszą być zestaw przez składnik.
Metoda używana do zestaw wartości z tych kolumn zależy od tego, czy dane wyjściowe błędu jest synchroniczna lub asynchroniczna.Składniki wywołania synchronicznego wyjść DirectErrorRow(Int32, Int32, Int32) Metoda, szczegółowo w następnej sekcji, a następnie podaj kod błędu i wartości błędów kolumna jako parametry. Składniki z wyjść asynchronicznego ma dwie możliwości dotyczące ustawiania wartości tych kolumn.Mogą one albo wywołanie SetErrorInfo(Int32, Int32, Int32) Metoda danych wyjściowych buforu i podanie wartości lub zlokalizuj kolumn błąd w buforze przy użyciu FindColumnByLineageID(Int32, Int32) i zestaw wartości bezpośrednio w kolumnach. Jednak ponieważ nazwy kolumn, zostały zmienione lub ich lokalizacji w kolekcja kolumn wyjściowych została zmodyfikowana, druga metoda może nie być niezawodne.The SetErrorInfo(Int32, Int32, Int32) metoda automatically sets the values in these error columns without having to locate them manually.
Jeśli trzeba uzyskać opis błędu, który odpowiada kodowi błędu, można użyć GetErrorDescription(Int32) Metoda IDTSComponentMetaData100 Interfejs dostępne za pośrednictwem składnika ComponentMetaData() Właściwość.
W poniższych przykładach kodu Pokaż składnik, który obsługuje dane wejściowe i dwa wyjść, włączając w to błąd wyjścia.Pierwszy przykład przedstawia sposób tworzenia błąd danych wyjściowych jest synchroniczna w danych wejściowych.Drugi przykład przedstawia sposób tworzenia błąd danych wyjściowych jest asynchroniczny.
public override void ProvideComponentProperties()
{
// Specify that the component has an error output.
ComponentMetaData.UsesDispositions = true;
// Create the input.
IDTSInput100 input = ComponentMetaData.InputCollection.New();
input.Name = "Input";
input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed;
input.ErrorOrTruncationOperation = "A string describing the possible error or truncation that may occur during execution.";
// Create the default output.
IDTSOutput100 output = ComponentMetaData.OutputCollection.New();
output.Name = "Output";
output.SynchronousInputID = input.ID;
output.ExclusionGroup = 1;
// Create the error output.
IDTSOutput100 errorOutput = ComponentMetaData.OutputCollection.New();
errorOutput.IsErrorOut = true;
errorOutput.Name = "ErrorOutput";
errorOutput.SynchronousInputID = input.ID;
errorOutput.ExclusionGroup = 1;
}
Public Overrides Sub ProvideComponentProperties()
' Specify that the component has an error output.
ComponentMetaData.UsesDispositions = True
Dim input As IDTSInput100 = ComponentMetaData.InputCollection.New
' Create the input.
input.Name = "Input"
input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed
input.ErrorOrTruncationOperation = "A string describing the possible error or truncation that may occur during execution."
' Create the default output.
Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection.New
output.Name = "Output"
output.SynchronousInputID = input.ID
output.ExclusionGroup = 1
' Create the error output.
Dim errorOutput As IDTSOutput100 = ComponentMetaData.OutputCollection.New
errorOutput.IsErrorOut = True
errorOutput.Name = "ErrorOutput"
errorOutput.SynchronousInputID = input.ID
errorOutput.ExclusionGroup = 1
End Sub
W poniższym przykładzie kodu tworzy dane wyjściowe błędu jest asynchroniczny.
public override void ProvideComponentProperties()
{
// Specify that the component has an error output.
ComponentMetaData.UsesDispositions = true;
// Create the input.
IDTSInput100 input = ComponentMetaData.InputCollection.New();
input.Name = "Input";
input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed;
input.ErrorOrTruncationOperation = "A string describing the possible error or truncation that may occur during execution.";
// Create the default output.
IDTSOutput100 output = ComponentMetaData.OutputCollection.New();
output.Name = "Output";
// Create the error output.
IDTSOutput100 errorOutput = ComponentMetaData.OutputCollection.New();
errorOutput.Name = "ErrorOutput";
errorOutput.IsErrorOut = true;
}
Public Overrides Sub ProvideComponentProperties()
' Specify that the component has an error output.
ComponentMetaData.UsesDispositions = True
' Create the input.
Dim input As IDTSInput100 = ComponentMetaData.InputCollection.New
' Create the default output.
input.Name = "Input"
input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed
input.ErrorOrTruncationOperation = "A string describing the possible error or truncation that may occur during execution."
' Create the error output.
Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection.New
output.Name = "Output"
Dim errorOutput As IDTSOutput100 = ComponentMetaData.OutputCollection.New
errorOutput.Name = "ErrorOutput"
errorOutput.IsErrorOut = True
End Sub
Przekierowywanie wiersza do wyjścia Error
Po dodaniu błąd danych wyjściowych do składnika, należy podać kod, który obsługuje błąd lub obcinania warunków specyficznych dla składnika i przekierowuje błąd lub obcinania wierszy w wyniku błędu.Można to zrobić na dwa sposoby, w zależności od tego, czy dane wyjściowe błędu jest synchroniczna lub asynchroniczna.
Przekierowywanie wiersz wyjścia synchroniczne
Wiersze są wysyłane w celu synchronicznego wyjść przez wywołanie DirectErrorRow(Int32, Int32, Int32) Metoda PipelineBuffer Klasa. Wywołanie metoda jako parametry zawiera identyfikator wyjścia błąd, kod błędu zdefiniowany składnik i indeks kolumna, składnik nie może przetworzyć.
Poniższy przykład kodu demonstruje sposób kierować wiersza w buforze synchronicznego błędu wyjściowy przy użyciu DirectErrorRow(Int32, Int32, Int32) Metoda.
public override void ProcessInput(int inputID, PipelineBuffer buffer)
{
IDTSInput100 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);
// This code sample assumes the component has two outputs, one the default,
// the other the error output. If the errorOutputIndex returned from GetErrorOutputInfo
// is 0, then the default output is the second output in the collection.
int defaultOutputID = -1;
int errorOutputID = -1;
int errorOutputIndex = -1;
GetErrorOutputInfo(ref errorOutputID,ref errorOutputIndex);
if (errorOutputIndex == 0)
defaultOutputID = ComponentMetaData.OutputCollection[1].ID;
else
defaultOutputID = ComponentMetaData.OutputCollection[0].ID;
while (buffer.NextRow())
{
try
{
// TODO: Implement code to process the columns in the buffer row.
// Ideally, your code should detect potential exceptions before they occur, rather
// than having a generic try/catch block such as this.
// However, because the error or truncation implementation is specific to each component,
// this sample focuses on actually directing the row, and not a single error or truncation.
// Unless an exception occurs, direct the row to the default
buffer.DirectRow(defaultOutputID);
}
catch
{
// Yes, has the user specified to redirect the row?
if (input.ErrorRowDisposition == DTSRowDisposition.RD_RedirectRow)
{
// Yes, direct the row to the error output.
// TODO: Add code to include the errorColumnIndex.
buffer.DirectErrorRow(errorOutputID, 0, errorColumnIndex);
}
else if (input.ErrorRowDisposition == DTSRowDisposition.RD_FailComponent || input.ErrorRowDisposition == DTSRowDisposition.RD_NotUsed)
{
// No, the user specified to fail the component, or the error row disposition was not set.
throw new Exception("An error occurred, and the DTSRowDisposition is either not set, or is set to fail component.");
}
else
{
// No, the user specified to ignore the failure so
// direct the row to the default output.
buffer.DirectRow(defaultOutputID);
}
}
}
}
Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer)
Dim input As IDTSInput100 = ComponentMetaData.InputCollection.GetObjectByID(inputID)
' This code sample assumes the component has two outputs, one the default,
' the other the error output. If the errorOutputIndex returned from GetErrorOutputInfo
' is 0, then the default output is the second output in the collection.
Dim defaultOutputID As Integer = -1
Dim errorOutputID As Integer = -1
Dim errorOutputIndex As Integer = -1
GetErrorOutputInfo(errorOutputID, errorOutputIndex)
If errorOutputIndex = 0 Then
defaultOutputID = ComponentMetaData.OutputCollection(1).ID
Else
defaultOutputID = ComponentMetaData.OutputCollection(0).ID
End If
While buffer.NextRow
Try
' TODO: Implement code to process the columns in the buffer row.
' Ideally, your code should detect potential exceptions before they occur, rather
' than having a generic try/catch block such as this.
' However, because the error or truncation implementation is specific to each component,
' this sample focuses on actually directing the row, and not a single error or truncation.
' Unless an exception occurs, direct the row to the default
buffer.DirectRow(defaultOutputID)
Catch
' Yes, has the user specified to redirect the row?
If input.ErrorRowDisposition = DTSRowDisposition.RD_RedirectRow Then
' Yes, direct the row to the error output.
' TODO: Add code to include the errorColumnIndex.
buffer.DirectErrorRow(errorOutputID, 0, errorColumnIndex)
Else
If input.ErrorRowDisposition = DTSRowDisposition.RD_FailComponent OrElse input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed Then
' No, the user specified to fail the component, or the error row disposition was not set.
Throw New Exception("An error occurred, and the DTSRowDisposition is either not set, or is set to fail component.")
Else
' No, the user specified to ignore the failure so
' direct the row to the default output.
buffer.DirectRow(defaultOutputID)
End If
End If
End Try
End While
End Sub
Przekierowywanie wiersz wyjścia asynchroniczne
Zamiast kierowanie wiersze, które mają zostać danych wyjściowych, została wykonana przy wyjść synchroniczne błąd składników z asynchronicznego wyjść wysyła wiersz wyniku błąd jawnie dodanie wiersza w danych wyjściowych PipelineBuffer. Wykonania składnika, który będzie używał wyjść asynchronicznych błędów wymaga Dodawanie kolumn w wyniku błędu, dostarczane ze składnikami niższego rzędu i buforowanie bufor wyjściowy na błąd wyjściowych, dostarczane do składnika podczas PrimeOutput(Int32, array<Int32[], array<PipelineBuffer[]) Metoda. Szczegółowe informacje dotyczące implementowania składnik z asynchronicznego wyjść omówiono szczegółowo w temacie Rozwijanie składnik transformacja niestandardowe z asynchronicznych wyjścia. Jeżeli kolumny nie zostaną wyraźnie dodane w wyniku błędu, wiersz buforu, który jest dodawany do buforu wyjściowego zawiera tylko o dwie kolumny.
Aby wysłać wiersz wyjścia asynchronicznych błędów, należy dodać wiersz do buforu wyjściowego błąd.Czasami wiersz może być już dodany do buforu wyjściowego — błąd i usunąć tego wiersza, używając RemoveRow() Metoda. Następnie zostanie ustawiony bufor wyjściowy wartości kolumna, a na koniec należy wywołać SetErrorInfo(Int32, Int32, Int32) Metoda kod błędu specyficzny dla składnika i wartość kolumna błędu.
W poniższym przykładzie przedstawiono sposób użycia wyjścia błąd składnika o asynchronicznych wyjść.W przypadku wystąpienia błędu symulowanego składnika dodaje wiersz błędu wyjściowych buforu kopie wartości, które wcześniej były dodawane do wyników — Błąd buforu do buforu wyjściowego błąd, usuwa wiersz, który został dodany do buforu wyjściowego — błąd i wreszcie zestawy wartości kolumna błędów i kod błędu, wywołując SetErrorInfo(Int32, Int32, Int32) Metoda.
int []columnIndex;
int errorOutputID = -1;
int errorOutputIndex = -1;
public override void PreExecute()
{
IDTSOutput100 defaultOutput = null;
this.GetErrorOutputInfo(ref errorOutputID, ref errorOutputIndex);
foreach (IDTSOutput100 output in ComponentMetaData.OutputCollection)
{
if (output.ID != errorOutputID)
defaultOutput = output;
}
columnIndex = new int[defaultOutput.OutputColumnCollection.Count];
for(int col =0 ; col < defaultOutput.OutputColumnCollection.Count; col++)
{
IDTSOutputColumn100 column = defaultOutput.OutputColumnCollection[col];
columnIndex[col] = BufferManager.FindColumnByLineageID(defaultOutput.Buffer, column.LineageID);
}
}
public override void PrimeOutput(int outputs, int[] outputIDs, PipelineBuffer[] buffers)
{
for( int x=0; x < outputs; x++ )
{
if (outputIDs[x] == errorOutputID)
this.errorBuffer = buffers[x];
else
this.defaultBuffer = buffers[x];
}
int rows = 100;
Random random = new Random(System.DateTime.Now.Millisecond);
for (int row = 0; row < rows; row++)
{
try
{
defaultBuffer.AddRow();
for (int x = 0; x < columnIndex.Length; x++)
defaultBuffer[columnIndex[x]] = random.Next();
// Simulate an error.
if ((row % 2) == 0)
throw new Exception("A simulated error.");
}
catch
{
// Add a row to the error buffer.
errorBuffer.AddRow();
// Get the values from the default buffer
// and copy them to the error buffer.
for (int x = 0; x < columnIndex.Length; x++)
errorBuffer[columnIndex[x]] = defaultBuffer[columnIndex[x]];
// Set the error information.
errorBuffer.SetErrorInfo(errorOutputID, 1, 0);
// Remove the row that was added to the default buffer.
defaultBuffer.RemoveRow();
}
}
if (defaultBuffer != null)
defaultBuffer.SetEndOfRowset();
if (errorBuffer != null)
errorBuffer.SetEndOfRowset();
}
Private columnIndex As Integer()
Private errorOutputID As Integer = -1
Private errorOutputIndex As Integer = -1
Public Overrides Sub PreExecute()
Dim defaultOutput As IDTSOutput100 = Nothing
Me.GetErrorOutputInfo(errorOutputID, errorOutputIndex)
For Each output As IDTSOutput100 In ComponentMetaData.OutputCollection
If Not (output.ID = errorOutputID) Then
defaultOutput = output
End If
Next
columnIndex = New Integer(defaultOutput.OutputColumnCollection.Count) {}
Dim col As Integer = 0
While col < defaultOutput.OutputColumnCollection.Count
Dim column As IDTSOutputColumn100 = defaultOutput.OutputColumnCollection(col)
columnIndex(col) = BufferManager.FindColumnByLineageID(defaultOutput.Buffer, column.LineageID)
System.Math.Min(System.Threading.Interlocked.Increment(col),col-1)
End While
End Sub
Public Overrides Sub PrimeOutput(ByVal outputs As Integer, ByVal outputIDs As Integer(), ByVal buffers As PipelineBuffer())
Dim x As Integer = 0
While x < outputs
If outputIDs(x) = errorOutputID Then
Me.errorBuffer = buffers(x)
Else
Me.defaultBuffer = buffers(x)
End If
System.Math.Min(System.Threading.Interlocked.Increment(x),x-1)
End While
Dim rows As Integer = 100
Dim random As Random = New Random(System.DateTime.Now.Millisecond)
Dim row As Integer = 0
While row < rows
Try
defaultBuffer.AddRow
Dim x As Integer = 0
While x < columnIndex.Length
defaultBuffer(columnIndex(x)) = random.Next
System.Math.Min(System.Threading.Interlocked.Increment(x),x-1)
End While
' Simulate an error.
If (row Mod 2) = 0 Then
Throw New Exception("A simulated error.")
End If
Catch
' Add a row to the error buffer.
errorBuffer.AddRow
' Get the values from the default buffer
' and copy them to the error buffer.
Dim x As Integer = 0
While x < columnIndex.Length
errorBuffer(columnIndex(x)) = defaultBuffer(columnIndex(x))
System.Math.Min(System.Threading.Interlocked.Increment(x),x-1)
End While
' Set the error information.
errorBuffer.SetErrorInfo(errorOutputID, 1, 0)
' Remove the row that was added to the default buffer.
defaultBuffer.RemoveRow
End Try
System.Math.Min(System.Threading.Interlocked.Increment(row),row-1)
End While
If Not (defaultBuffer Is Nothing) Then
defaultBuffer.SetEndOfRowset
End If
If Not (errorBuffer Is Nothing) Then
errorBuffer.SetEndOfRowset
End If
End Sub
|
.gif "Integration Services icon (small)")
Konfiguracja w aktualizacji z usług integracja Services pobytuSee Also