De gegevensstroomtaak programmatisch toevoegen

Van toepassing op:SQL Server SSIS Integration Runtime in Azure Data Factory

SQL Server Data Tools (SSDT) bevat een taak genaamd de Gegevensstroom-taak, die wordt weergegeven door de Microsoft.SqlServer.Dts.Pipeline.Wrapper naamruimte in het objectmodel. De Gegevensstroom-taak is een gespecialiseerde, hoogpresterende taak, gewijd aan het transformeren en verplaatsen van data tijdens pakketuitvoering. Net als bij andere taken wordt de Gegevensstroom-taak omwikkeld door het TaskHost object, en vanuit het perspectief van de run-time engine is deze taak gewoon een andere taak in het pakket. De datastroom bevat echter extra objecten die dataflowcomponenten worden genoemd. Deze componenten zijn de componenten die ervoor zorgen dat data van een bron naar een bestemming verplaatst, soms via een transformatie. De componenten definiëren zowel de bewegingsrichting als de transformatie van gegevens. Het configureren van de Gegevensstroom-taak houdt in dat componenten aan de taak worden toegevoegd en vervolgens worden gekoppeld om de datastroom tot stand te brengen en de beoogde transformatie te bereiken.

Er zijn drie soorten componenten binnen een Gegevensstroom-taak: Gegevensstroom Sources, Gegevensstroom Transformations en Gegevensstroom Destinations, weergegeven in die volgorde in de SSIS Designer toolbox. Deze typen worden ook eenvoudiger aangeduid als bronnen, transformaties of bestemmingen. Zoals de namen suggereren, stroomt data van een bron naar een transformatie en vervolgens naar een bestemming. Dit is een eenvoudige beschrijving van de data flow om het concept te illustreren, maar de Gegevensstroom-taak is flexibel en krachtig genoeg om meerdere bronnen te verwerken en om vele transformaties met elkaar te verbinden die output naar meerdere bestemmingen sturen.

De Gegevensstroom-taak wordt op dezelfde manier aan een pakket toegevoegd als andere taken. Nadat de taak is toegevoegd, wordt deze geconfigureerd door componenten toe te voegen aan de dataflowtaak en componenten in de taak te configureren en te verbinden.

Sample

Het volgende codevoorbeeld laat zien hoe je een Gegevensstroom-taak aan een pakket kunt toevoegen. Dit voorbeeld vereist een verwijzing naar de assemblies Microsoft. SqlServer.PipelineHost, Microsoft. SqlServer.DTSPipelineWrap, en 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

Verwante onderwerpen

  • Last updated on