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.