Creating a Custom Data Flow Component
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 składa się z elementów, które zawierają IDTSComponentMetaData100 interfejs i kolekcja IDTSPath100 obiekty, które definiują ruch danych między składnikami.
Czas projektowania i czas uruchamiania
Przed wykonaniem zadanie przepływ danych jest nazywany jest w stanie czas projektowania, co podlega on zmian przyrostowych.Zmiany mogą obejmować dodawaniem i usuwaniem składników, dodawania lub usuwania obiektów ścieżka, które składniki i zmiany połączyć metadane składników.Gdy zmiany metadane, składnika można monitorować i reagowanie na zmiany.Na przykład składnikiem może uniemożliwić pewnych zmian lub, aby wprowadzić dodatkowe zmiany w odpowiedzi na zmiany.W czasie projektowania Projektant komunikuje się z części do czas projektowania IDTSDesigntimeComponent100 interfejs.
W czasie wykonywania zadanie przepływ danych sprawdza kolejność składników, przygotowuje plan wykonać i zarządza puli wątków roboczych, które są wykonać planu pracy.Chociaż każdy wątek roboczy wykonuje niektóre pracy, który jest wewnętrzna zadania przepływ danych, głównym zadaniem wątek roboczy jest wywołanie metody składnika do czas wykonania IDTSRuntimeComponent100 interfejs.
Tworzenie składnika
Aby utworzyć składnik przepływ danych, określenia klasy z PipelineComponent utworzyć klasę, stosowanie DtsPipelineComponentAttribute klasy, a następnie zastąpić odpowiednich metod klasy podstawowej. The PipelineComponent implements the IDTSDesigntimeComponent100 and IDTSRuntimeComponent100 interfaces, and exposes their methods for you to override in your component.
W zależności od obiektów, używany przez składnik projektu wymaga odwołania do niektórych lub wszystkich następujących zestawów:
Funkcja |
wirtualny plik dziennika do odwołania |
Obszar nazw do zaimportowania |
---|---|---|
Przepływ danych |
Microsoft.SqlServer.PipelineHost |
Microsoft.SqlServer.Dts.Pipeline |
Otoka przepływ danych |
Microsoft.SqlServer.DTSPipelineWrap |
Microsoft.SqlServer.Dts.Pipeline.Wrapper |
Runtime |
Microsoft.SQLServer.ManagedDTS |
Microsoft.SqlServer.Dts.Runtime |
Otoka Runtime |
Microsoft.SqlServer.DTSRuntimeWrap |
Microsoft.SqlServer.Dts.Runtime.Wrapper |
W poniższym przykładzie kodu pokazano proste składnik, 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
|