Dil

Özel Veri Akışı Bileşeni Oluşturma

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

Microsoft SQL Server Integration Services yılında, veri akışı görevi, geliştiricilerin Microsoft .NET Framework ve yönetilen kod kullanarak özel veri akışı bileşenleri—kaynaklar, dönüşümler ve hedefler—oluşturmasına olanak tanıyan bir nesne modelini ortaya çıkarır.

Bir veri akışı görevi, bileşenler IDTSComponentMetaData100 arasında veri hareketini tanımlayan bir arayüz ve nesne koleksiyonunu IDTSPath100 içeren bileşenlerden oluşur.

Note

Özel bir sağlayıcı oluşturduğunuzda, ProviderDescriptors.xml dosyasını meta veri sütunu değerleriyle güncellemeniz gerekir.

Tasarım Süresi ve Çalışma Süresi

Yürütülmeden önce, veri akışı görevi tasarım zamanı durumunda olduğu ve kademeli değişiklikler geçirdiği söylenir. Değişiklikler, bileşenlerin eklenmesi veya çıkarılması, bileşenleri bağlayan yol nesnelerinin eklenmesi veya çıkarılması ve bileşenlerin meta verilerindeki değişiklikleri içerebilir. Meta veri değişiklikleri gerçekleştiğinde, bileşen değişiklikleri izleyebilir ve tepki verebilir. Örneğin, bir bileşen belirli değişiklikleri yasaklayabilir veya bir değişikliğe yanıt olarak ek değişiklikler yapabilir. Tasarım zamanında, tasarımcı bir bileşenle tasarım zamanı IDTSDesigntimeComponent100 arayüzü aracılığıyla etkileşime girer.

Yürütme zamanında, veri akışı görevi bileşenlerin sırasını inceler, bir yürütme planı hazırlar ve iş planını yürüten bir işçi iş parçacıkları havuzunu yönetir. Her işçi iş parçacığı veri akışı görevinin içinde bazı işleri yapsa da, işçi iş parçacığının temel görevi, bileşenin yöntemlerini çalışma IDTSRuntimeComponent100 zamanı arayüzü üzerinden çağırmaktır.

Bir Bileşen Oluşturmak

Bir veri akışı bileşeni oluşturmak için, temel sınıftan PipelineComponent bir sınıf türetirsiniz, sınıfı DtsPipelineComponentAttribute uygularsınız ve ardından temel sınıfın uygun yöntemlerini geçersiz kılarsınız. Arayüzleri PipelineComponentIDTSDesigntimeComponent100 uygular IDTSRuntimeComponent100 ve bileşenlerinizde geçersiz kılmanız için yöntemlerini sunar.

Bileşeninizin kullandığı nesnelere bağlı olarak, projeniz aşağıdaki montajların bazılarına veya tamamına referans gerektirecektir:

Özellik Referans olarak montaj İçe aktarılacak isim alanı
Veri akışı Microsoft. SqlServer.PipelineHost Microsoft.SqlServer.Dts.Pipeline
Veri akışı sargısı Microsoft. SqlServer.DTSPipelineWrap Microsoft.SqlServer.Dts.Pipeline.Wrapper
Runtime Microsoft. SQLServer.ManagedDTS Microsoft.SqlServer.Dts.Runtime
Çalışma zamanı wrapperi Microsoft. SqlServer.DTSRuntimeWrap Microsoft.SqlServer.Dts.Runtime.Wrapper

Aşağıdaki kod örneği, temel sınıftan türeden basit bir bileşeni gösterir ve .DtsPipelineComponentAttribute Microsoft'a bir referans eklemeniz gerekiyor. SqlServer.DTSPipelineWrap assembly.

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

İlgili içerik

  • Last updated on