Programové přidání úlohy toku dat

Platí pro:SQL Server SSIS Integration Runtime v rámci Azure Data Factory

SQL Server Data Tools (SSDT) obsahuje úlohu nazvanou Tok dat task, která je reprezentována jmenným prostorem Microsoft.SqlServer.Dts.Pipeline.Wrapper v objektovém modelu. Úkol Tok dat je specializovaný, vysoce výkonný úkol, věnovaný transformaci a přesunu dat během vykonávání balíčku. Stejně jako u jiných úloh je úkol Tok dat obalen objektem TaskHost a z pohledu run-time enginu je tato úloha jen další úlohou v balíčku. Datový tok však obsahuje další objekty nazývané komponenty datového toku. Tyto komponenty jsou ty, které umožňují přesun dat ze zdroje na místo, někdy prostřednictvím transformace. Komponenty definují jak směr pohybu, tak způsob, jakým jsou data transformována. Konfigurace úlohy Tok dat zahrnuje přidání komponent do úkolu a jejich následné propojení za účelem stanovení toku dat a dosažení zamýšlené transformace.

V rámci úlohy Tok dat existují tři typy komponent: Data Flow Sources, Tok dat Transformations a Data Flow Destinations, které jsou v tomto pořadí zobrazeny v nástrojovém balíčku SSIS Designer. Tyto typy se také jednodušeji označují jako zdroje, transformace nebo cíle. Jak napovídají názvy, data proudí ze zdroje do transformace a poté do cíle. Toto je zjednodušený popis data flow, který ilustruje koncept, ale úloha Tok dat je dostatečně flexibilní a výkonná, aby zvládla více zdrojů a propojila mnoho transformací, které posílají výstup na více destinací.

Úkol Tok dat se přidává do balíčku stejným způsobem jako ostatní úkoly. Po přidání úkolu se konfiguruje přidáním komponent do úlohy datového toku a konfigurací a propojením komponent v této úlohě.

Sample

Následující ukázka kódu ukazuje, jak přidat Tok dat úkol do balíčku. Tento příklad vyžaduje odkaz na assemblery Microsoft. SqlServer.PipelineHost, Microsoft. SqlServer.DTSPipelineWrap a 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

Související obsah

  • Last updated on