Dil

Veri Akışı Görevini Program Aracılığıyla Ekleme

Şunlar için geçerlidir:SQL Server Azure Data Factory'de SSIS Tümleştirme Çalışma Zamanı

SQL Server Veri Araçları (SSDT), nesne modelinde isim alanı ile Microsoft.SqlServer.Dts.Pipeline.Wrapper temsil edilen Veri Akışı görevi adı verilen bir görev içerir. Veri Akışı görevi, paket yürütme sırasında veriyi dönüştürmek ve taşımak için ayrılmış, özel ve yüksek performanslı bir görevdir. Diğer görevler gibi, Veri Akışı görevi nesne tarafından sarılır TaskHost ve çalışma zamanı motoru açısından bu görev paketteki başka bir görevdir. Ancak, veri akışında veri akışı bileşenleri adı verilen ek nesneler bulunur. Bu bileşenler, verilerin bir kaynaktan hedefe taşınmasını sağlayan bileşenlerdir, bazen dönüşüm yoluyla. Bileşenler hem hareket yönünü hem de verinin nasıl dönüştürüldüğünü tanımlar. Veri Akışı görevini yapılandırmak, göreve bileşenler eklemeyi ve ardından veri akışını oluşturmak ve amaçlanan dönüşümü gerçekleştirmek için bunları birbirine bağlamayı içerir.

Bir Veri Akışı görevinde üç tür bileşen vardır: Veri Akışı Sources, Veri Akışı Transformations ve Veri Akışı Destinations; bunlar SSIS Designer araç kutusunda bu sırayla gösterilmiştir. Bu türler daha basit olarak kaynaklar, dönüşümler veya hedefler olarak da adlandırılır. İsimlerden anlaşılacağı gibi, veri bir kaynaktan bir dönüşüme ve ardından bir hedefe akar. Bu, kavramı açıklamak için data flow'un basit bir tanımıdır, ancak Veri Akışı görevi esnek ve güçlüdür; birden fazla kaynağı yönetebilir ve birden fazla hedefe çıktı gönderen birçok dönüşümü birbirine bağlayabilir.

Veri Akışı görevi, diğer görevlerin eklendiği gibi pakete eklenir. Görev eklendikten sonra, veri akışı görevine bileşenler eklenerek ve görevdeki bileşenlerin yapılandırılıp bağlanmasıyla yapılandırılır.

Sample

Aşağıdaki kod örneği, bir pakete Veri Akışı görevinin nasıl ekleneceğini gösterir. Bu örnek, Microsoft montajlarına referans gerektirir. SqlServer.PipelineHost, Microsoft. SqlServer.DTSPipelineWrap ve 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

İlgili içerik

  • Last updated on