Skapa en anpassad dataflödeskomponent

Gäller för:SQL Server SSIS Integration Runtime i Azure Data Factory

I Microsoft služba SSIS exponerar dataflödesuppgiften en objektmodell som låter utvecklare skapa anpassade dataflödeskomponenter – källor, transformationer och destinationer – genom att använda Microsoft .NET Framework och hanterad kod.

En dataflödesuppgift består av komponenter som innehåller ett IDTSComponentMetaData100 gränssnitt och en samling IDTSPath100 objekt som definierar överföringen av data mellan komponenterna.

Designtid och körtid

Innan exekvering sägs dataflödesuppgiften vara i ett designtidsläge, då den genomgår inkrementella förändringar. Ändringar kan inkludera tillägg eller borttagning av komponenter, tillägg eller borttagning av vägobjekt som kopplar samman komponenter, samt ändringar i komponenternas metadata. När metadataförändringar sker kan komponenten övervaka och reagera på förändringarna. Till exempel kan en komponent förbjuda vissa ändringar eller göra ytterligare ändringar som svar på en ändring. Vid designtillfället interagerar designern med en komponent via designtidsgränssnittet IDTSDesigntimeComponent100 .

Vid exekveringstillfället undersöker dataflödesuppgiften sekvensen av komponenter, förbereder en exekveringsplan och hanterar en pool av arbetstrådar som utför arbetsplanen. Även om varje arbetstråd utför arbete som är internt för dataflödesuppgiften, är arbetstrådens huvuduppgift att anropa komponentens metoder via körtidsgränssnittet IDTSRuntimeComponent100 .

Skapa en komponent

För att skapa en dataflödeskomponent härleder du en klass från PipelineComponent basklassen, applicerar klassen DtsPipelineComponentAttribute och åsidosätter sedan lämpliga metoder för basklassen. De PipelineComponent implementerar IDTSDesigntimeComponent100 och IDTSRuntimeComponent100 gränssnitten, och visar deras metoder för att du ska kunna överskriva i din komponent.

Beroende på vilka objekt som används av din komponent kommer ditt projekt att kräva referenser till några eller alla av följande sammansättningar:

Följande kodexempel visar en enkel komponent som härstammar från basklassen, och tillämpar .DtsPipelineComponentAttribute Du behöver lägga till en referens till Microsoft. SqlServer.DTSPipelineWrap-assembly.

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  

Relaterat innehåll

• Utveckling av ett användargränssnitt för en Data Flow-komponent