프로그래밍 방식으로 데이터 흐름 태스크 추가
적용 대상: Azure Data Factory의 
SQL Server SSIS Integration Runtime
SSDT(SQL Server Data Tools)에는 개체 모델에서 Microsoft.SqlServer.Dts.Pipeline.Wrapper 네임스페이스로 표현되는 데이터 흐름 태스크라는 태스크가 포함되어 있습니다. 데이터 흐름 태스크는 패키지 실행 중에 데이터를 변환하고 이동하는 데 전념하는 특수한 고성능 작업입니다. 다른 작업과 마찬가지로 데이터 흐름 태스크는 개체에 의해 TaskHost 래핑되고 런타임 엔진의 관점에서 이 작업은 패키지의 또 다른 작업일 뿐입니다. 그러나 데이터 흐름에는 데이터 흐름 구성 요소라는 추가 개체가 포함됩니다. 이러한 구성 요소는 데이터를 원본에서 대상으로 이동하게 하고 때로는 변환을 통해 이동하게 하는 구성 요소입니다. 이 구성 요소는 이동 방향과 데이터 변환 방식을 모두 정의합니다. 데이터 흐름 태스크를 구성하려면 태스크에 구성 요소를 추가한 다음 연결하여 데이터 흐름을 설정하고 의도한 변환을 달성해야 합니다.
데이터 흐름 태스크 내에는 3가지 유형의 구성 요소가 있습니다. 데이터 흐름 원본, 데이터 흐름 변환 및 데이터 흐름 대상이 이에 해당하며 이러한 구성 요소는 SSIS 디자이너 도구 상자에 이 순서대로 표시됩니다. 이러한 형식을 더 간단하게 원본, 변환 또는 대상으로 지칭합니다. 이름에서 알 수 있듯이 데이터는 원본에서 변환으로, 그리고 대상으로 흐릅니다. 이는 개념을 설명하기 위한 데이터 흐름에 대한 간단한 설명이지만 데이터 흐름 태스크는 여러 원본을 처리하고 여러 대상으로 출력을 보내는 많은 변환을 함께 연결할 수 있을 만큼 유연하고 강력합니다.
데이터 흐름 태스크는 다른 작업이 추가되는 것과 동일한 방식으로 패키지에 추가됩니다. 태스크를 추가한 후에는 데이터 흐름 태스크에 구성 요소를 추가하고 태스크의 구성 요소를 구성 및 연결하여 태스크를 구성합니다.
Sample
다음 코드 샘플에서는 패키지에 데이터 흐름 태스크를 추가하는 방법을 보여줍니다. 이 예제에서는 Microsoft.SqlServer.PipelineHost, Microsoft.SqlServer.DTSPipelineWrap 및 Microsoft.SqlServer.ManagedDTS 어셈블리에 대한 참조가 필요합니다.
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
외부 리소스
블로그 항목인 EzAPI - blogs.msdn.com SQL Server 2012용으로 업데이트되었습니다.