Udostępnij za pośrednictwem


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
Integration Services icon (small) Konfiguracja w aktualizacji z usług integracja Services pobytu

Najnowsze pliki do pobrania, artykuły, próbki, i pliki wideo firmy Microsoft, jak również wybranego rozwiązania od Wspólnoty, odwiedź witrynę Integration Services strona w witrynie MSDN lub TechNet:

Automatycznego powiadomienie tych aktualizacji należy subskrybować źródła danych RSS, które jest dostępne strona.