Użycie wyjść błąd w składniku przepływu danych
Specjalne IDTSOutput100 obiektów o nazwie wyjść błędu można dodawać do składników, aby umożliwić składnika Przekierowanie wiersze, których nie można przetworzyć podczas wykonywania.Problemy mogą wystąpić składnik ogólnie są klasyfikowane jako błędy lub truncations i są specyficzne dla każdego składnika.Składniki, które dostarczają wyjść błąd daje użytkownikom składnika elastyczność niezbędną do obsługi błędów przez filtrowanie wierszy błędu z zestaw wyników, awarii składnika, gdy wystąpi problem lub ignorowanie błędów i kontynuować.
Aby implementują i obsługują wyjść błąd składnika, musisz najpierw zestaw UsesDispositions właściwość składnika do true.Następnie należy dodać dane wyjściowe do składnika, który jej 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.Ten temat obejmuje następujące trzy kroki i wyjaśniono różnice między wyjść błąd synchroniczne i asynchroniczne.
Tworzenie wyjściowe błąd
Utwórz komunikaty o błędach wyświetlane przez wywołanie New metoda OutputCollection, a następnie ustawiając IsErrorOut właściwość nowe dane wyjściowe do true.Jeśli produkcja jest asynchroniczne, nic musi odbywać się w danych wyjściowych.Jeśli produkcja jest synchroniczna, a nie ma innego wyjścia jest synchroniczna tym samym wprowadzania, należy również zestaw ExclusionGroup i SynchronousInputID Właściwości.Obie właściwości powinien mieć te same wartości, jak produkcja, który jest synchroniczna tym samym wprowadzania.Jeśli te właściwości nie są zestaw na wartość zera wierszy dostarczone przez dane wejściowe są wysyłane do obu wyjść, które są synchroniczne dane wejściowe.
Jeśli składnik napotka błąd lub obcinania podczas wykonywania, przychody w zależności od ustawień ErrorRowDisposition i TruncationRowDisposition Właściwości danych wejściowych lub wyjściowych lub kolumna wejściowego lub wyjściowego, w którym wystąpił błąd.Wartość właściwości te powinny być zestaw domyślnie RD_NotUsed.Wyjście Błąd składnika jest połączony ze składnikiem niższego rzędu, ta właściwość jest zestaw przez użytkownika w części i pozwala sterować jak składnik obsługuje błąd lub obcinania.
Wypełnianie kolumny błędów
Po utworzeniu wyjście błędu zadanie przepływ danych automatycznie dodaje dwie kolumna do kolekcja kolumn wyjściowych.kolumna te są używane przez składniki Określ identyfikator kolumna, który spowodował błąd lub obcięcia i podaj kod błędu określonego 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 tych kolumn zależy od tego, czy wyjście błędu jest synchroniczna lub asynchroniczna.Składniki wywołania synchronicznego wyjść DirectErrorRow metoda szczegółowo w następnej sekcji i podaj kod błędu i wartości błędów kolumna jako parametry.Składniki z wyjść asynchroniczny ma dwie możliwości ustawienia wartości tych kolumn.Mogą one albo wywołanie SetErrorInfo metoda produkcji buforu i podać wartości lub Znajdź kolumny błędów w buforze za pomocą FindColumnByLineageID i zestaw wartości dla kolumn bezpośrednio.Jednakże ponieważ nazwy kolumnas mogą być zmienione, lub ich lokalizacji w wyniku kolumna Kolekcja została zmodyfikowana, druga metoda może nie być wiarygodne.SetErrorInfo metoda automatycznie ustawia wartości w tych kolumnach błąd bez konieczności ręcznego je zlokalizować.
Jeśli trzeba uzyskać opis błędu, który odpowiada kodowi błędu, można użyć GetErrorDescription metoda IDTSComponentMetaData100 interfejs dostępne za pośrednictwem składnika ComponentMetaData właściwość.
Następujące przykłady kodu przedstawiają składnika, który wejściowego i dwóch wyjść, w tym wyjście błędu.Pierwszy przykład przedstawia sposób tworzenia danych wyjściowych błędów synchronicznych w danych wejściowych.Drugi przykład przedstawia sposób tworzenia danych wyjściowych błędów asynchronicznych.
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
Poniższy przykład kodu tworzy dane wyjściowe błędów asynchronicznych.
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 danych wyjściowych błąd wiersza
Po dodaniu do wyjścia błąd składnika, należy podać kod, który obsługuje błąd lub obcinania warunki specyficzne 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 wyjście błędu jest synchroniczna lub asynchroniczna.
Przekierowywanie wiersz z wyjść synchroniczne
Wiersze są wysyłane do wyjść synchroniczne, wywołując DirectErrorRow metoda PipelineBuffer klasyWywołanie metoda jako parametry zawiera identyfikator wyjścia błąd, kod błędu zdefiniowany składnik i indeks kolumna, że składnik nie może przetworzyć.
Poniższy przykład kodu ilustruje sposób bezpośrednich wiersza w buforze synchronicznego błędu wyjściowe przy użyciu DirectErrorRow 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ście asynchroniczne
Zamiast kierowanie wierszy do wyjścia, jak wykonywane z błędów synchronicznych wyjść, składniki z asynchronicznego wyjść wysłać wiersz do wyjścia błąd jawnie dodając wiersz produkcji PipelineBuffer.Wykonania składnika, który używa wyjść błędów asynchronicznych wymaga dodawania kolumn w wyniku błędu, dostarczonego do niższego rzędu składników i bufor wyjściowy dla błędu buforowanie wyjściowe dostarczanym do składnika podczas PrimeOutput metoda.Szczegóły wykonawczych składnika asynchronicznego wyjść opisano szczegółowo w temacie Rozwijanie składnika przekształcenie niestandardowe wyjście asynchroniczne.Jeśli kolumny nie są jawnie dodany do wyjścia błąd, wiersz buforu, który jest dodawany do buforu wyjściowego zawiera tylko dwie kolumny.
Aby wysłać wiersz do wyjściowej błędów asynchronicznych, należy dodać wiersz do buforu wyjściowego błąd.Czasami wiersza może już zostały dodane do bufora wyjściowego bez błędów i usunąć tego wiersza, za pomocą RemoveRow metoda.Następny zestaw bufor wyjściowy wartości kolumna i wreszcie wywołania SetErrorInfo metoda kod błędu składnika i wartość kolumna błąd.
Poniższy przykład ilustruje sposób używania wyjścia błąd składnika z asynchronicznego wyjść.Po wystąpieniu błędu symulowane składnika dodaje wiersz błędu wyjściowych buforu kopie wartości, które zostały poprzednio dodane w wyniku braku błędów buforu do buforu wyjściowego błąd usuwa wiersz, który został dodany do buforu wyjściowego bez błędui wreszcie, to ustawia błąd kodu i błąd wartości kolumna, wywołując SetErrorInfo 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 "Ikona usług Integration Services (mała)")
Bieżąco z usług integracjiZobacz także