Membuat Komponen Aliran Data Kustom

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

Di Microsoft SQL Server Integration Services, tugas aliran data mengekspos model objek yang memungkinkan pengembang membuat sumber komponen aliran data kustom, transformasi, dan tujuan-dengan menggunakan Microsoft .NET Framework dan kode terkelola.

Tugas aliran data terdiri dari komponen yang berisi IDTSComponentMetaData100 antarmuka dan kumpulan IDTSPath100 objek yang menentukan pergerakan data antar komponen.

Catatan

Saat membuat penyedia kustom, Anda perlu memperbarui file ProviderDescriptors.xml dengan nilai kolom metadata.

Waktu Desain dan Waktu Proses

Sebelum eksekusi, tugas aliran data dikatakan dalam status waktu desain, karena mengalami perubahan bertahas. Perubahan dapat mencakup penambahan atau penghapusan komponen, penambahan atau penghapusan objek jalur yang menghubungkan komponen, dan perubahan pada metadata komponen. Ketika perubahan metadata terjadi, komponen dapat memantau dan bereaksi terhadap perubahan. Misalnya, komponen dapat melarang perubahan tertentu atau membuat perubahan tambahan sebagai respons terhadap perubahan. Pada waktu desain, perancang berinteraksi dengan komponen melalui antarmuka waktu IDTSDesigntimeComponent100 desain.

Pada waktu eksekusi, tugas aliran data memeriksa urutan komponen, menyiapkan rencana eksekusi, dan mengelola kumpulan utas pekerja yang menjalankan rencana kerja. Meskipun setiap utas pekerja melakukan beberapa pekerjaan yang bersifat internal untuk tugas aliran data, tugas utama utas pekerja adalah memanggil metode komponen melalui antarmuka run-time IDTSRuntimeComponent100 .

Membuat Komponen

Untuk membuat komponen aliran data, Anda mendapatkan kelas dari PipelineComponent kelas dasar, menerapkan DtsPipelineComponentAttribute kelas, lalu mengambil alih metode kelas dasar yang sesuai. Mengimplementasikan PipelineComponent IDTSDesigntimeComponent100 antarmuka dan IDTSRuntimeComponent100 , dan mengekspos metodenya untuk Anda ambil alih dalam komponen Anda.

Bergantung pada objek yang digunakan oleh komponen Anda, proyek Anda akan memerlukan referensi ke beberapa atau semua rakitan berikut:

Fitur	Rakitan ke referensi	Namespace untuk diimpor
Aliran Data	Microsoft.SqlServer.PipelineHost	Microsoft.SqlServer.Dts.Pipeline
Pembungkus aliran data	Microsoft.SqlServer.DTSPipelineWrap	Microsoft.SqlServer.Dts.Pipeline.Wrapper
Runtime	Microsoft.SQLServer.ManagedDTS	Microsoft.SqlServer.Dts.Runtime
Pembungkus runtime	Microsoft.SqlServer.DTSRuntimeWrap	Microsoft.SqlServer.Dts.Runtime.Wrapper

Contoh kode berikut menunjukkan komponen sederhana yang berasal dari kelas dasar, dan menerapkan DtsPipelineComponentAttribute. Anda perlu menambahkan referensi ke rakitan Microsoft.SqlServer.DTSPipelineWrap.

using System;  
using Microsoft.SqlServer.Dts.Pipeline;  
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;  
  
namespace Microsoft.Samples.SqlServer.Dts  
{  
    [DtsPipelineComponent(DisplayName = "SampleComponent", ComponentType = ComponentType.Transform )]  
    public class BasicComponent: PipelineComponent  
    {  
        // TODO: Override the base class methods.  
    }  
}  

Imports Microsoft.SqlServer.Dts.Pipeline  
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper  
  
<DtsPipelineComponent(DisplayName:="SampleComponent", ComponentType:=ComponentType.Transform)> _  
Public Class BasicComponent  
  
    Inherits PipelineComponent  
  
    ' TODO: Override the base class methods.  
  
End Class  

Lihat Juga

Mengembangkan Antarmuka Pengguna untuk Komponen Aliran Data