Lägga till dataflödesaktiviteten programmatiskt

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

SQL Server Data Tools (SSDT) inkluderar en uppgift kallad Data Flow-uppgiften, som representeras av Microsoft.SqlServer.Dts.Pipeline.Wrapper namnrymden i objektmodellen. Data Flow-uppgiften är en specialiserad, högpresterande uppgift, dedikerad till att transformera och flytta data under paketexekvering. Liksom andra uppgifter omsluts Data Flow-uppgiften av objektetTaskHost, och ur run-time-motorns perspektiv är denna uppgift bara en annan uppgift i paketet. Dataflödet innehåller dock ytterligare objekt som kallas dataflödeskomponenter. Dessa komponenter är de komponenter som får data att flyttas från en källa till en destination, ibland genom en transformation. Komponenterna definierar både rörelseriktningen och hur data transformeras. Att konfigurera Data Flow-uppgiften innebär att man lägger till komponenter i uppgiften och sedan kopplar ihop dem för att etablera dataflödet och uppnå den avsedda transformationen.

Det finns tre typer av komponenter inom en Data Flow-uppgift: Data Flow Sources, Data Flow Transformations och Data Flow Destinations, visade i den ordningen i SSIS Designer-verktygslådan. Dessa typer kallas också enklare källor, transformationer eller destinationer. Som namnen antyder flödar data från en källa till en transformation och sedan till en destination. Detta är en förenklad beskrivning av data flow för att illustrera konceptet, men Data Flow-uppgiften är flexibel och tillräckligt kraftfull för att hantera flera källor och för att koppla samman många transformationer som skickar output till flera destinationer.

Data Flow-uppgiften läggs till i ett paket på samma sätt som andra uppgifter läggs till. Efter att uppgiften har lagts till konfigureras den genom att lägga till komponenter i dataflödesuppgiften samt konfigurera och koppla samman komponenter i uppgiften.

Sample

Följande kodexempel visar hur man lägger till en Data Flow-uppgift i ett paket. Detta exempel kräver en referens till assemblies Microsoft. SqlServer.PipelineHost, Microsoft. SqlServer.DTSPipelineWrap och Microsoft. SqlServer.ManagedDTS.

using System;  
using Microsoft.SqlServer.Dts.Runtime;  
using Microsoft.SqlServer.Dts.Pipeline;  
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;  
  
namespace Microsoft.SqlServer.Dts.Samples  
{  
  class Program  
  {  
    static void Main(string[] args)  
    {  
      Package p = new Package();  
      Executable e = p.Executables.Add("STOCK:PipelineTask");  
      TaskHost thMainPipe = e as TaskHost;  
      MainPipe dataFlowTask = thMainPipe.InnerObject as MainPipe;   
    }  
  }  
}  

Imports System.IO  
Imports Microsoft.SqlServer.Dts.Runtime  
Imports Microsoft.SqlServer.Dts.Pipeline  
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper  
  
Module Module1  
  
  Sub Main()  
  
    Dim p As Package = New Package()  
    Dim e As Executable = p.Executables.Add("STOCK:PipelineTask")  
    Dim thMainPipe As TaskHost = CType(e, TaskHost)  
    Dim dataFlowTask As MainPipe = CType(thMainPipe.InnerObject, MainPipe)  
  
  End Sub  
  
End Module

Relaterat innehåll

  • Last updated on