Veri akışı görev programlı olarak ekleme

Makale
10/29/2012

SQL Server Veri Akışı Araçları (SSDT)tarafından temsil edilen veri akışı görev adı verilen bir görev içerir Microsoft.SqlServer.Dts.Pipeline.Wrappernesne modeli ad. Veri akışı görev paketi yürütme sırasında veri taşıma ve dönüştürme adanmış özel, yüksek performanslı bir görev vardır. Gibi diğer görevler, veri akışı görev tarafından sarılır TaskHostnesnesi ve çalışma zamanı altyapısı açısından, bu görevin başka bir görev paketi. Ancak, veri akışının veri akışı bileşenleri denilen ek nesneleri içerir. Bu bileşenler bir kaynaktan bir hedefe, bazen bir dönüşüm yoluyla taşıma veri bileşenleri vardır. Hem hareket yönünü, hem de nasıl veri dönüştürülmüştür bileşenlerini tanımlar. Veri akışı görev yapılandırma görevine bileşenleri ekleme ve sonra onları veri akışını kurmak ve hedeflenen dönüşümü elde bağlayan içerir.

Veri akışı görev içinde bileşenlerini üç tür vardır: Veri akışı kaynakları, Akış veri dönüşümleri, ve Veri akışı yönlerde, bu sırada içinde gösterilen SSISTasarımcısı araç. Bu tip da daha basitçe kaynakları, dönüşümleri veya hedefleri adlandırılır. Adlarına göre zımni olarak veri bir kaynaktan bir dönüşüm ve sonra hedef akar. Bu kavramı göstermek için veri akışı basit bir açıklaması, ancak birden çok kaynaktan işlemek için ve birden çok hedefe çıkışı göndermek çok dönüşümleri birbirine bağlamak için yeterince güçlü ve esnek veri akışı görev.

Veri akışı görev bir paket diğer görevlere eklenen aynı şekilde eklenir. Görev eklendikten sonra veri akışı görev, yapılandırma ve görev bileşenlerinde bağlanma bileşenleri ekleyerek yapılandırılır.

Örnek

Aşağıdaki kod örneği, bir paket veri akışı görev eklemek gösterilmiştir. Bu örnek, Microsoft.SqlServer.PipelineHost, Microsoft.SqlServer.DTSPipelineWrap ve Microsoft.SqlServer.ManagedDTS derlemeler 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; 
    }
  }
}

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
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