Veri akışı görev programlı olarak ekleme
Business Intelligence Development Studiotarafından temsil edilen veri akışı görev adı verilen bir görev içerir Microsoft.SqlServer.Dts.Pipeline.Wrapper ad alanında nesne modeli.Veri akışı görev paket yürütme sırasında veri taşıma ve dönüştürme için adanmış bir özel, yüksek performanslı, görevdir.Gibi diğer görevler, veri akışı görev tarafından sarılan TaskHost , nesne ve açısından bakıldığında run -saat , bu görevi motorudur başka bir görev paket.Bununla birlikte, veri akışının veri akışı bileşenler olarak adlandırılan ek nesneler içerir.Bu bileşenleri taşımak veri bileşenleri olan bir kaynak bir dönüştürme bazen üzerinden bir hedef için.Yönüyle ve verileri nasıl dönüştürülmüş bileşenlerini tanımlar.Veri akışı görev yapılandırma göreve bileşenleri 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 bir veri akışı görev içinde üç tür vardır: Veri akışı kaynakları, Akış Veri Dönüşümleri, ve Veri akışı hedefleri, o sırada içinde gösterilen SSIS Tasarımcısı araç.Bu türler de için daha kısaca kaynakları, Dönüşümleri ve hedefleri adlandırılır.Örtülü olarak adlarına göre veriler akar dan bir kaynak dönüştürme ve sonra bir hedef.Bu kavram göstermek için veri akışı simplistic açıklaması, ancak esnek ve güçlü yeterince birden çok kaynağı işlemek için ve birden çok hedefe çıktı yollayan birçok dönüştürmeleri birbirine bağlamak için veri akışı görev.
Veri akışı görev bir paket için diğer görevler eklenir aynı şekilde eklenir.Görev eklendikten sonra veri akışı görevi ve 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, paket için veri akışı görev ekleme gösterilmiştir.Bu örnek, Microsoft.SqlServer.PipelineHost, Microsoft.SqlServer.DTSPipelineWrap ve Microsoft.SqlServer.ManagedDTS birleştirmeler için 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
|
.gif "Integration Services simgesi (küçük)")
Integration Services ile güncel kalın