Tworzenie składnika przepływu danych niestandardowych
In Microsoft SQL Server Integration Services, the data flow task exposes an object model that lets developers create custom data flow components—sources, transformations, and destinations—by using the Microsoft .NET Framework and managed code.
A zadanie przepływ danych zawiera składniki, które zawierają IDTSComponentMetaData100 interfejs i zbiór IDTSPath100 obiektów, które definiują ruch danych między składnikami.
Czas projektowania i wykonywania
Przed wykonaniem zadania przepływ danych jest nazywany w projekt -czas Państwo, jak go przyrostowe zmianom.Zmiany mogą obejmować, dodawania lub usuwania składników, dodawania lub usuwania obiektów ścieżka, które łączą składniki i zmiany do metadane składników.Kiedy wystąpią zmiany metadane, składnik można monitorować i reagowania na zmiany.Na przykład składnik może uniemożliwić niektórych zmian lub wprowadzić dodatkowe zmiany w odpowiedzi na zmiany.W projekcie czas, Projektant współdziała ze składnikiem za pośrednictwem projektu -czas IDTSDesigntimeComponent100 interfejs.
Na wykonać czas, zadania przepływ danych sprawdza sekwencji składników, przygotuje plan wykonać i zarządza puli wątków, których wykonać planu pracy.Chociaż każdy wątek roboczy wykonuje pracy jest wewnętrzna zadanie przepływ danych, głównym zadaniem wątku roboczego jest wywołanie metody składnika poprzez run-czas IDTSRuntimeComponent100 interfejs.
Tworzenie składnika
Aby utworzyć składnik przepływ danych, pochodzić od klasy PipelineComponent Klasa podstawowa, stosowanie DtsPipelineComponentAttribute klasy, a następnie zastąpić odpowiednie metody klasy podstawowejPipelineComponent Implementuje IDTSDesigntimeComponent100 i IDTSRuntimeComponent100 interfejsy i udostępnia metody ich pominięcia w składniku.
W zależności od obiektów wykorzystywanych przez składnik projektu będzie wymagać odniesienia do niektórych lub wszystkich następujących zespołów:
Funkcja |
Zestaw do odwołania |
Obszar nazw, importowanie |
---|---|---|
Przepływ danych |
Microsoft.SqlServer.PipelineHost |
[ N:Microsoft.SqlServer.Dts.Pipeline ] |
Otoka przepływu danych |
Microsoft.SqlServer.DTSPipelineWrap |
[ N:Microsoft.SqlServer.Dts.Pipeline.Wrapper ] |
Runtime |
Microsoft.SQLServer.ManagedDTS |
[ N:Microsoft.SqlServer.Dts.Runtime ] |
Otoka Runtime |
Microsoft.SqlServer.DTSRuntimeWrap |
[ N:Microsoft.SqlServer.Dts.Runtime.Wrapper ] |
Poniższy przykład kodu pokazuje prostego składnika, który pochodzi od klasy podstawowej i zastosowanie DtsPipelineComponentAttribute.
using System;
using Microsoft.SqlServer.Dts.Pipeline;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
namespace Microsoft.Samples.SqlServer.Dts
{
[DtsPipelineComponent(DisplayName = "SampleComponent", ComponentType = ComponentType.Transform )]
public class BasicComponent: PipelineComponent
{
// TODO: Override the base class methods.
}
}
Imports Microsoft.SqlServer.Dts.Pipeline
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
<DtsPipelineComponent(DisplayName:="SampleComponent", ComponentType:=ComponentType.Transform)> _
Public Class BasicComponent
Inherits PipelineComponent
' TODO: Override the base class methods.
End Class
|