스크립트 구성 요소를 사용하여 대상 만들기

아티클
05/23/2023

적용 대상: Azure Data Factory SSIS Integration Runtime SQL Server

Integration Services 패키지의 데이터 흐름에서 대상 구성 요소를 사용하여 업스트림 원본 및 변환에서 받은 데이터를 데이터 원본에 저장할 수 있습니다. 일반적으로 대상 구성 요소는 기존 연결 관리자를 통해 데이터 원본에 연결합니다.

스크립트 구성 요소에 대한 개요는 스크립트 구성 요소를 사용하여 데이터 흐름 확장을 참조하세요.

스크립트 구성 요소 및 해당 구성 요소가 생성하는 인프라 코드를 사용하면 사용자 지정 데이터 흐름 구성 요소를 개발하는 과정이 훨씬 간단해집니다. 그러나 스크립트 구성 요소의 작동 방식을 이해하려면 사용자 지정 데이터 흐름 구성 요소 개발 섹션, 특히 사용자 지정 대상 구성 요소 개발에서 사용자 지정 데이터 흐름 구성 요소를 개발하는 단계를 파악하는 것이 유용할 수 있습니다.

대상 구성 요소 시작

SSIS 디자이너의 [데이터 흐름] 탭에 스크립트 구성 요소를 추가하면, 스크립트 구성 요소 유형 선택 대화 상자가 열려 원본, 대상 또는 변환 스크립트를 선택하도록 요구합니다. 이 대화 상자에서 대상을 선택합니다.

그런 다음 SSIS 디자이너에서 변환의 출력을 대상 구성 요소에 연결합니다. 테스트를 위해 변환하지 않고 원본을 대상에 직접 연결할 수 있습니다.

메타데이터 디자인 모드에서 대상 구성 요소 구성

대상 구성 요소를 만드는 옵션을 선택한 후 스크립트 변환 편집기를 사용하여 구성 요소를 구성합니다. 자세한 내용은 스크립트 구성 요소 편집기에서 스크립트 구성 요소 구성을 참조하세요.

스크립트 대상에서 사용할 스크립트 언어를 선택하려면 스크립트 변환 편집기 대화 상자의 스크립트 페이지에서 ScriptLanguage 속성을 설정합니다.

참고

스크립트 구성 요소에 대한 기본 스크립트 언어를 설정하려면 옵션 대화 상자의 일반 페이지에서 스크립트 언어 옵션을 사용합니다. 자세한 내용은 General Page을 참조하세요.

데이터 흐름 대상 구성 요소에는 하나의 입력이 포함되며 출력은 포함되지 않습니다. 구성 요소에 대한 입력 구성은 사용자 지정 스크립트를 작성하기 전에 스크립트 변환 편집기를 사용하여 메타데이터 디자인 모드에서 완료해야 하는 단계 중 하나입니다.

연결 관리자 추가

일반적으로 대상 구성 요소는 기존 연결 관리자를 사용하여 데이터 흐름에서 받은 데이터를 저장할 데이터 원본에 연결합니다. 스크립트 변환 편집기의 연결 관리자 페이지에서 추가를 클릭하여 적절한 연결 관리자를 추가합니다.

그러나 연결 관리자는 단지 특정 유형의 데이터 원본에 연결하는 데 필요한 정보를 캡슐화하고 저장하는 편리한 단위일 뿐입니다. 데이터를 로드하거나 저장하고 데이터 원본에 대한 연결을 열고 닫는 사용자 지정 코드는 사용자가 직접 작성해야 합니다.

스크립트 구성 요소에서 연결 관리자를 사용하는 방법에 대한 일반적은 내용은 스크립트 구성 요소에서 데이터 원본에 연결을 참조하세요.

스크립트 변환 편집기의 연결 관리자 페이지에 대한 자세한 내용은 스크립트 변환 편집기(연결 관리자 페이지)를 참조하세요.

입력 및 입력 열 구성

대상 구성 요소에는 하나의 입력이 포함되며 출력은 포함되지 않습니다.

스크립트 변환 편집기의 입력 열 페이지에서 열 목록에는 데이터 흐름에 있는 업스트림 구성 요소의 출력에서 사용 가능한 열이 표시됩니다. 이 목록에서 저장할 열을 선택합니다.

스크립트 변환 편집기의 입력 열 페이지에 대한 자세한 내용은 스크립트 변환 편집기(입력 열 페이지)를 참조하세요.

스크립트 변환 편집기의 입/출력 페이지에는 이름을 바꿀 수 있는 단일 입력이 표시됩니다. 스크립트에서는 자동 생성 코드에서 만들어진 접근자 속성을 사용하여 입력을 이름으로 참조합니다.

스크립트 변환 편집기의 입력 및 출력 페이지에 대한 자세한 내용은 스크립트 변환 편집기(입력 및 출력 페이지)를 참조하세요.

변수 추가

스크립트에서 기존 변수를 사용하려는 경우 스크립트 변환 편집기의 스크립트 페이지에 있는 ReadOnlyVariables 및 ReadWriteVariables 속성 필드에서 해당 변수를 추가할 수 있습니다.

속성 필드에 여러 변수를 추가하는 경우 변수 이름을 쉼표로 구분하십시오. 또한 ReadOnlyVariables 및 ReadWriteVariables 속성 필드 옆에 있는 줄임표( ... ) 단추를 클릭한 다음, 변수 선택 대화 상자에서 변수를 선택하면 여러 개의 변수를 선택할 수 있습니다.

스크립트 구성 요소에서 변수를 사용하는 방법에 대한 일반적인 내용은 스크립트 구성 요소에서 변수 사용을 참조하세요.

스크립트 변환 편집기의 스크립트 페이지에 대한 자세한 내용은 스크립트 변환 편집기(스크립트 페이지)를 참조하세요.

코드 디자인 모드에서 대상 구성 요소 스크립팅

구성 요소에 대한 메타데이터를 구성한 후에는 사용자 지정 스크립트를 작성할 수 있습니다. 스크립트 변환 편집기의 스크립트 페이지에서 스크립트 편집을 클릭하여 사용자 지정 스크립트를 추가할 수 있는 Microsoft VSTA(Visual Studio Tools for Applications) IDE를 엽니다. 사용하는 스크립트 언어는 스크립트 페이지에서 ScriptLanguage 속성에 대한 스크립트 언어로 Microsoft Visual Basic 또는 Microsoft Visual C# 중에서 선택한 언어에 따라 달라집니다.

스크립트 구성 요소를 사용하여 만든 모든 종류의 구성 요소에 적용되는 중요한 정보는 스크립트 구성 요소 코딩 및 디버깅을 참조하세요.

자동 생성 코드 이해

대상 구성 요소를 만들고 구성한 후 VSTA IDE를 열면, 편집 가능한 ScriptMain 클래스가 ProcessInputRow 메서드에 대한 스텁과 함께 코드 편집기에 표시됩니다. ScriptMain 클래스는 사용자 지정 코드를 작성하는 위치이며, ProcessInputRow는 대상 구성 요소에서 가장 중요한 메서드입니다.

VSTA에서 프로젝트 탐색기 창을 열면 스크립트 구성 요소에서 읽기 전용 BufferWrapper 및 ComponentWrapper 프로젝트 항목도 생성했음을 확인할 수 있습니다. ScriptMain 클래스는 ComponentWrapper 프로젝트 항목의 UserComponent 클래스에서 상속됩니다.

런타임에 데이터 흐름 엔진에서 ScriptComponent 부모 클래스의 ProcessInput 메서드를 재정의하는 UserComponent 클래스의 ProcessInput 메서드를 호출합니다. 그러면 ProcessInput 메서드에서 입력 버퍼의 행을 반복하고 각 행에 대해 ProcessInputRow 메서드를 한 번씩 호출합니다.

사용자 지정 코드 작성

사용자 지정 대상 구성 요소 만들기를 완료하려면 ScriptMain 클래스에서 사용할 수 있는 다음 메서드에 스크립트를 작성해야 합니다.

외부 데이터 원본에 연결하도록 AcquireConnections 메서드를 재정의합니다. 연결 관리자에서 연결 개체나 필요한 연결 정보를 추출합니다.
데이터 저장을 준비하도록 PreExecute 메서드를 재정의합니다. 예를 들어 이 메서드에 SqlCommand 및 해당 매개 변수를 만들고 구성할 수 있습니다.
재정의된 ProcessInputRow 메서드를 사용하여 각 입력 행을 외부 데이터 원본에 복사합니다. 예를 들어 SQL Server 대상의 경우 열 값을 SqlCommand의 매개 변수에 복사하고 각 행에 대해 이 명령을 한 번씩 실행할 수 있습니다. 플랫 파일 대상의 경우 각 열의 값을 열 구분 기호로 구분하여 StreamWriter에 쓸 수 있습니다.
필요한 경우 외부 데이터 원본과의 연결을 끊고 필요한 다른 모든 정리 작업을 수행하도록 PostExecute 메서드를 재정의합니다.

예제

다음 예제에서는 ScriptMain 클래스에서 대상 구성 요소를 만드는 데 필요한 코드를 보여 줍니다.

참고

이 예제에서는 AdventureWorks 샘플 데이터베이스의 Person.Address 테이블을 사용하고, 이 테이블의 첫 번째 및 네 번째 열인 intAddressID 및 nvarchar(30)City를 데이터 흐름을 통해 전달합니다. 이 섹션의 원본, 변환 및 대상 예제에는 동일한 데이터가 사용됩니다. 각 예에 대해 필수 구성 요소 및 가정도 설명되어 있습니다.

ADO.NET 대상 예

이 예제에서는 기존 ADO.NET 연결 관리자를 사용하여 데이터 흐름의 데이터를 SQL Server 테이블에 저장하는 대상 구성 요소를 보여 줍니다.

이 예제 코드를 실행하려면 다음과 같이 패키지와 구성 요소를 구성해야 합니다.

SqlClient 공급자를 사용하여 AdventureWorks 데이터베이스에 연결하는 ADO.NET 연결 관리자를 만듭니다.
AdventureWorks 데이터베이스에서 다음 Transact-SQL 명령을 실행하여 대상 테이블을 만듭니다.
```
CREATE TABLE [Person].[Address2]([AddressID] [int] NOT NULL,  
    [City] [nvarchar](30) NOT NULL)  
```
데이터 흐름 디자이너 화면에 새 스크립트 구성 요소를 추가하고 이 구성 요소를 대상으로 구성합니다.
업스트림 원본 또는 변환의 출력을 SSIS 디자이너의 대상 구성 요소에 연결합니다. 변환하지 않고 원본을 대상에 직접 연결할 수 있습니다. 이 출력은 AdventureWorks 샘플 데이터베이스에 있는 Person.Address 테이블의 데이터를 제공해야 하며, 이 데이터에는 적어도 AddressID 및 City 열이 포함됩니다.
스크립트 변환 편집기를 엽니다. 입력 열 페이지에서 AddressID 및 City 입력 열을 선택합니다.
입/출력 페이지에서 입력의 이름을 MyAddressInput과 같이 더 알기 쉬운 이름으로 바꿉니다.
연결 관리자 페이지에서 MyADONETConnectionManager와 같은 이름으로 ADO.NET 연결 관리자를 추가하거나 만듭니다.
스크립트 페이지에서 스크립트 편집을 클릭하고 다음 스크립트를 입력합니다. 그런 다음 스크립트 개발 환경을 닫습니다.
스크립트 변환 편집기를 닫고 샘플을 실행합니다.

Imports System.Data.SqlClient  
...  
Public Class ScriptMain  
    Inherits UserComponent  
  
    Dim connMgr As IDTSConnectionManager100  
    Dim sqlConn As SqlConnection  
    Dim sqlCmd As SqlCommand  
    Dim sqlParam As SqlParameter  
  
    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)  
  
        connMgr = Me.Connections.MyADONETConnectionManager  
        sqlConn = CType(connMgr.AcquireConnection(Nothing), SqlConnection)  
  
    End Sub  
  
    Public Overrides Sub PreExecute()  
  
        sqlCmd = New SqlCommand("INSERT INTO Person.Address2(AddressID, City) " & _  
            "VALUES(@addressid, @city)", sqlConn)  
        sqlParam = New SqlParameter("@addressid", SqlDbType.Int)  
        sqlCmd.Parameters.Add(sqlParam)  
        sqlParam = New SqlParameter("@city", SqlDbType.NVarChar, 30)  
        sqlCmd.Parameters.Add(sqlParam)  
  
    End Sub  
  
    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)  
        With sqlCmd  
            .Parameters("@addressid").Value = Row.AddressID  
            .Parameters("@city").Value = Row.City  
            .ExecuteNonQuery()  
        End With  
    End Sub  
  
    Public Overrides Sub ReleaseConnections()  
  
        connMgr.ReleaseConnection(sqlConn)  
  
    End Sub  
  
End Class

using System.Data.SqlClient;  
public class ScriptMain:  
    UserComponent  
  
{  
    IDTSConnectionManager100 connMgr;  
    SqlConnection sqlConn;  
    SqlCommand sqlCmd;  
    SqlParameter sqlParam;  
  
    public override void AcquireConnections(object Transaction)  
    {  
  
        connMgr = this.Connections.MyADONETConnectionManager;  
        sqlConn = (SqlConnection)connMgr.AcquireConnection(null);  
  
    }  
  
    public override void PreExecute()  
    {  
  
        sqlCmd = new SqlCommand("INSERT INTO Person.Address2(AddressID, City) " +  
            "VALUES(@addressid, @city)", sqlConn);  
        sqlParam = new SqlParameter("@addressid", SqlDbType.Int);  
        sqlCmd.Parameters.Add(sqlParam);  
        sqlParam = new SqlParameter("@city", SqlDbType.NVarChar, 30);  
        sqlCmd.Parameters.Add(sqlParam);  
  
    }  
  
    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)  
    {  
        {  
            sqlCmd.Parameters["@addressid"].Value = Row.AddressID;  
            sqlCmd.Parameters["@city"].Value = Row.City;  
            sqlCmd.ExecuteNonQuery();  
        }  
    }  
  
    public override void ReleaseConnections()  
    {  
  
        connMgr.ReleaseConnection(sqlConn);  
  
    }  
  
}

플랫 파일 대상의 예

이 예에서는 기존 플랫 파일 연결 관리자를 사용하여 데이터 흐름에서 받은 데이터를 플랫 파일에 저장하는 대상 구성 요소를 보여 줍니다.