Aracılığıyla paylaş

  • Makale

veri akışı görevi programsal olarak ekleme

Business Intelligence Development Studio ile temsil edilen veri akışı görevi adı verilen bir görevi içeren Microsoft.SqlServer.Dts.Pipeline.Wrapper nesne modelindeki bir ad alanı. veri akışı görevi dönüştürme ve veri paket yürütülürken taşıma için ayrılmış bir özelleştirilmiş, yüksek performanslı, görevdir.Diğer görevler gibi veri akışı görevi tarafından alınmış TaskHost Nesne, ve çalışma zamanı altyapısı açısından, bu görev başka bir görev paketindeki. Ancak, veri akışının veri akışı bileşenleri adlı bir başka nesneler içerir.Bu bileşenlerin verileri taşımak bileşenleridir bir kaynak bazen bir dönüştürme aracılığıyla bir hedef.Taşıma yönü ve verileri nasıl dönüştürülür, bileşenleri tanımlar.veri akışı görevi yapılandırma görevi için bileşen ekleme ve bunları veri akışının kurmak ve hedeflenen dönüştürme gerçekleştirmek için bağlanma ile ilgilidir.

Bileşenleri içinde üç tür bir veri akışı görevi: Veri akışı kaynakları, Veri akışı dönüşümleri, and Veri akışı hedefler içinde bu sırayla gösterilen,SSIS Tasarımcı araç. Bu tür da daha çok yalnızca kaynak, dönüştürmeler ve hedefleri adlandırılır.Gelen örtülü olarak adları tarafından veri akışı bir kaynak dönüştürme ve sonra bir hedef.Bu kavramı göstermek üzere veri akışı simplistic açıklamasını, ancak veri akışı görevi esnek ve güçlü yeterli birlikte birden çok hedefe çıktı yollayan birçok dönüştürmeleri bağlanmak için ve birden çok kaynak işlemek için.

veri akışı görevi diğer görevler eklenir aynı şekilde bir pakete eklenecektir.Görev eklendikten sonra veri akışı görevi ve yapılandırma ve görev bileşenleri bağlama bileşenleri ekleyerek yapılandırıldı.

Örnek

Aşağıdaki kod örneği, bir veri akışı için bir paket eklemek gösterilmiştir.Bu örnek, derlemeleri Microsoft.SqlServer.PipelineHost Microsoft.SqlServer.DTSPipelineWrap ve Microsoft.SqlServer.ManagedDTS başvuru gerektirir.

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
Integration Services icon (small) Tümleştirme Hizmetleri ile güncel kalın

Karşıdan yüklemeler, makaleleri, örnekler ve en son Microsoft video yanı sıra, seçili topluluğun çözümleri için ziyaret Integration Services sayfa MSDN veya TechNet:

Bu güncelleştirmelerin otomatik bildirim için kullanılabilir RSS akışlarına abone olmak sayfa.