Menambahkan Tugas Aliran Data Secara Terprogram

Berlaku untuk: SQL Server SSIS Integration Runtime di Azure Data Factory

SQL Server Data Tools (SSDT) menyertakan tugas yang disebut tugas Aliran Data, yang diwakili oleh Microsoft.SqlServer.Dts.Pipeline.Wrapper namespace dalam model objek. Tugas Aliran Data adalah tugas khusus berperforma tinggi, didedikasikan untuk mengubah dan memindahkan data selama eksekusi paket. Seperti tugas lain, tugas Aliran Data dibungkus oleh TaskHost objek, dan dari perspektif mesin run-time, tugas ini hanyalah tugas lain dalam paket. Namun, aliran data berisi objek tambahan yang disebut komponen aliran data. Komponen-komponen ini adalah komponen yang membuat data berpindah dari sumber ke tujuan, terkadang melalui transformasi. Komponen menentukan arah pergerakan dan bagaimana data diubah. Mengonfigurasi tugas Aliran Data melibatkan penambahan komponen ke tugas, lalu menyambungkannya untuk membangun aliran data dan mencapai transformasi yang dimaksudkan.

Ada tiga jenis komponen dalam tugas Aliran Data: Sumber Aliran Data, Transformasi Aliran Data, dan Tujuan Aliran Data, yang ditunjukkan dalam urutan tersebut dalam kotak alat SSIS Designer. Jenis-jenis ini juga disebut lebih sederhana sebagai sumber, transformasi, atau tujuan. Seperti yang disiratkan oleh nama, data mengalir dari sumber ke transformasi, lalu ke tujuan. Ini adalah deskripsi sederhana dari aliran data untuk mengilustrasikan konsep, tetapi tugas Aliran Data cukup fleksibel dan cukup kuat untuk menangani beberapa sumber, dan untuk menyambungkan banyak transformasi yang mengirim output ke beberapa tujuan.

Tugas Aliran Data ditambahkan ke paket dengan cara yang sama seperti tugas lain ditambahkan. Setelah tugas ditambahkan, tugas dikonfigurasi dengan menambahkan komponen ke tugas aliran data, dan mengonfigurasi dan menyambungkan komponen dalam tugas.

Sampel

Sampel kode berikut menunjukkan cara menambahkan tugas Aliran Data ke paket. Contoh ini memerlukan referensi ke rakitan Microsoft.SqlServer.PipelineHost, Microsoft.SqlServer.DTSPipelineWrap, dan 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  

Sumber Daya Eksternal

Entri blog, EzAPI - Diperbarui untuk SQL Server 2012, pada blogs.msdn.com.

Lihat Juga

Menemukan Komponen Aliran Data Secara Terprogram