스크립트 구성 요소를 사용하여 비동기 변환 만들기

아티클
05/23/2023

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

Integration Services 패키지의 데이터 흐름에서 변환 구성 요소를 사용하여 데이터가 원본에서 대상으로 전달될 때 데이터를 수정하고 분석합니다. 동기 출력이 있는 변환은 구성 요소를 통과할 때 각 입력 행을 처리합니다. 비동기 출력이 있는 변환은 변환이 모든 입력 행을 수신할 때까지 처리를 완료하기 위해 대기하거나 변환이 모든 입력 행을 수신하기 전에 특정 행을 출력할 수 있습니다. 이 항목에서는 비동기 변환에 대해 설명합니다. 처리에 동기 변환이 필요한 경우 스크립트 구성 요소를 사용하여 동기 변환 만들기를 참조하세요. 동기 구성 요소와 비동기 구성 요소 간 차이에 대한 자세한 내용은 동기 및 비동기 변환 이해를 참조하세요.

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

스크립트 구성 요소 및 해당 구성 요소가 생성하는 인프라 코드를 사용하면 사용자 지정 데이터 흐름 구성 요소를 개발하는 과정이 간단해집니다. 하지만 스크립트 구성 요소의 작동 방식을 이해하려면 사용자 지정 데이터 흐름 구성 요소 개발 섹션과 이 섹션의 동기 출력을 사용하여 사용자 지정 변환 구성 요소 개발을 통해 사용자 지정 데이터 흐름 구성 요소를 개발하는 데 필요한 단계를 파악하는 것이 좋습니다.

비동기 변환 구성 요소 시작

SSIS 디자이너 의 데이터 흐름 탭에 스크립트 구성 요소를 추가하면 스크립트 구성 요소 유형 선택 대화 상자가 나타나 구성 요소를 원본, 변환 또는 대상으로 미리 구성하라는 메시지가 표시됩니다. 이 대화 상자에서 변환을 선택합니다.

메타데이터 디자인 모드에서 비동기 변환 구성 요소 구성

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

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

참고 항목

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

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

입력 열 구성

스크립트 구성 요소를 사용하여 만들어진 변환 구성 요소에서는 하나의 입력만 사용합니다.

스크립트 변환 편집기의 입력 열 페이지에서 열 목록에는 데이터 흐름의 업스트림 구성 요소 출력에서 사용 가능한 열이 표시됩니다. 변환하거나 전달할 열을 선택합니다. 현재 위치에서 변환할 모든 열은 읽기/쓰기로 표시합니다.

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

입력, 출력 및 출력 열 구성

변환 구성 요소는 하나 이상의 출력을 지원합니다.

비동기 출력을 사용하는 변환에는 두 개의 출력이 있는 경우가 많습니다. 예를 들어 특정 도시에 있는 주소 수를 계산할 때 집계 결과를 다른 출력으로 보내면서 주소 데이터를 하나의 출력으로 전달할 수 있습니다. 집계 출력에는 새 출력 열도 필요합니다.

스크립트 변환 편집기의 입력 및 출력 페이지에서 단일 출력이 기본적으로 만들어졌지만 출력 열이 만들어지지 않은 것을 볼 수 있습니다. 편집기의 이 페이지에서 다음 항목을 구성할 수 있습니다.

집계 결과에 대한 출력과 같은 하나 이상의 추가 출력을 만들 수 있습니다. 출력 추가 및 출력 제거 단추를 사용하여 비동기 변환 구성 요소의 출력을 관리합니다. 각 출력의 SynchronousInputID 속성을 0으로 설정하여 출력이 단순히 업스트림 구성 요소의 데이터를 통과하거나 기존 행 및 열에서 제자리에서 변환하지 않음을 나타냅니다. 출력을 입력에 비동기식으로 만드는 것은 이 설정입니다.
입력 및 출력에 이름을 지정할 수 있습니다. 스크립트 구성 요소는 이러한 이름을 사용하여 스크립트의 입력 및 출력을 참조하는 데 사용할 형식화된 접근자 속성을 생성합니다.
비동기 변환에서는 데이터 흐름에 열을 추가하는 경우가 많습니다. 출력의 SynchronousInputID 속성이 0이면 출력이 단순히 업스트림 구성 요소의 데이터를 통과하거나 기존 행 및 열에서 데이터를 변환하는 것이 아니라 출력에 출력 열을 명시적으로 추가하고 구성해야 합니다. 출력 열은 매핑되는 입력 열과 동일한 이름을 가질 필요가 없습니다.
추가 정보를 포함하도록 열을 더 추가할 수 있습니다. 추가 열을 데이터로 채우려면 사용자 고유의 코드를 작성해야 합니다. 표준 오류 출력의 동작을 재현하는 방법에 대한 자세한 내용은 스크립트 구성 요소의 오류 출력 시뮬레이션을 참조하세요.

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

변수 추가

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

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

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

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

코드 디자인 모드에서 비동기 변환 구성 요소 스크립팅

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

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

자동 생성된 코드 이해

변환 구성 요소를 만들고 구성한 후 VSTA IDE를 열면 ProcessInputRow 및 CreateNewOutputRows 메서드에 대한 스텁이 있는 편집 가능한 ScriptMain 클래스가 코드 편집기에서 나타납니다. ScriptMain 클래스는 사용자 지정 코드를 작성하는 위치이며 ProcessInputRow는 변환 구성 요소에서 가장 중요한 방법입니다. CreateNewOutputRows 메서드는 일반적으로 원본 구성 요소에서 사용되며, 이는 두 구성 요소가 자체 출력 행을 만들어야 한다는 측면에서 비동기 변환과 같습니다.

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

런타임에 데이터 흐름 엔진은 ScriptComponent 부모 클래스의 PrimeOutput 메서드를 재정의하는 UserComponent 클래스의 PrimeOutput 메서드를 호출합니다. PrimeOutput 메서드는 차례로 CreateNewOutputRows 메서드를 호출합니다.

다음으로, 데이터 흐름 엔진은 ScriptComponent 부모 클래스의 ProcessInput 메서드를 재정의하는 UserComponent 클래스의 ProcessInput 메서드를 호출합니다. ProcessInput 메서드는 입력 버퍼의 행을 반복하고 각 행에 대해 ProcessInputRow 메서드를 한 번 호출합니다.

사용자 지정 코드 작성

사용자 지정 비동기 변환 구성 요소 만들기를 마치려면 재정의된 ProcessInputRow 메서드를 사용하여 입력 버퍼의 각 행에 있는 데이터를 처리해야 합니다. 출력은 입력과 동기적으로 이루어지지 않으므로 데이터 행을 출력에 명시적으로 써야 합니다.

비동기 변환에서는 AddRow 메서드를 사용하여 ProcessInputRow 또는 ProcessInput 메서드 내에서 적절하게 출력에 행을 추가할 수 있습니다. CreateNewOutputRows 메서드를 사용할 필요가 없습니다. 집계 결과와 같은 단일 결과 행을 특정 출력에 작성하는 경우 CreateNewOutputRows 메서드를 사용하여 출력 행을 미리 만들고 나중에 모든 입력 행을 처리한 후 해당 값을 채울 수 있습니다. 그러나 스크립트 구성 요소를 사용하면 입력 또는 출력에서 현재 행만 사용할 수 있으므로 CreateNewOutputRows 메서드에서 여러 행을 만드는 것은 유용하지 않습니다. CreateNewOutputRows 메서드는 처리할 입력 행이 없는 원본 구성 요소에서 더 중요합니다.

ProcessInput 메서드 자체를 재정의할 수도 있으므로 입력 버퍼를 반복하고 각 행에 대해 ProcessInputRow를 호출하기 전이나 그 후에 예비 또는 최종 처리를 추가로 수행할 수 있습니다. 예를 들어, 이 항목의 코드 예제 중 하나는 ProcessInput을 재정의하여 ProcessInputRow가 행을 반복할 때 특정 도시의 주소 수를 계산합니다. 이 예제에서는 모든 행이 처리된 후에 두 번째 출력에 요약 값을 씁니다. PostExecute가 호출되면 출력 버퍼를 더 이상 사용할 수 없으므로 이 예에서는 ProcessInput에서 출력을 완료합니다.

요구 사항에 따라 ScriptMain 클래스에서 사용할 수 있는 PreExecute 및 PostExecute 메서드에서 스크립트를 작성하여 예비 또는 최종 처리를 수행할 수도 있습니다.

참고 항목

사용자 지정 데이터 흐름 구성 요소를 처음부터 개발하는 경우 나중에 버퍼에 데이터 행을 추가할 수 있도록 출력 버퍼에 대한 참조를 캐시하도록 PrimeOutput 메서드를 재정의하는 것이 중요합니다. Script 구성 요소에서는 BufferWrapper 프로젝트 항목의 각 출력 버퍼를 나타내는 자동으로 생성된 클래스가 있으므로 필요하지 않습니다.

예시

이 예제에서는 비동기 변환 구성 요소를 만들기 위해 ScriptMain 클래스에 필요한 사용자 지정 코드를 보여 줍니다.

참고 항목

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

이 예에서는 두 개의 출력을 사용하는 비동기 변환 구성 요소를 보여 줍니다. 이 변환은 AddressID 및 City 열을 하나의 출력으로 전달하고 특정 도시(Redmond, Washington, U.S.A.)에 있는 주소 수를 계산한 다음 결과 값을 두 번째 출력으로 출력합니다.

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

데이터 흐름 디자이너 화면에 새 스크립트 구성 요소를 추가하고 변환으로 구성합니다.
원본 또는 다른 변환의 출력을 디자이너의 새 변환 구성 요소에 연결합니다. 이 출력은 적어도 AddressID 및 City 열을 포함하는 AdventureWorks 샘플 데이터베이스의 Person.Address 테이블에서 데이터를 제공해야 합니다.
스크립트 변환 편집기를 엽니다. 입력 열 페이지에서 AddressID 및 City 열을 선택합니다.
입력 및 출력 페이지에서 첫 번째 출력에 AddressID 및 City 출력 열을 추가하고 구성합니다. 두 번째 출력을 추가하고 두 번째 출력의 요약 값에 대한 출력 열을 추가합니다. 이 예제에서는 각 입력 행을 첫 번째 출력에 명시적으로 복사하므로 첫 번째 출력의 SynchronousInputID 속성을 0으로 설정합니다. 새로 만든 출력의 SynchronousInputID 속성은 이미 0으로 설정되어 있습니다.
입력, 출력 및 새 출력 열의 이름을 변경하여 보다 설명적인 이름을 지정합니다. 이 예제에서는 입력의 이름으로 MyAddressInput, 출력의 경우 MyAddressOutput 및 MySummaryOutput, 두 번째 출력의 출력 열에 MyRedmondCount를 사용합니다.
스크립트 페이지에서 스크립트 편집을 클릭하고 다음 스크립트를 입력합니다. 그런 다음 스크립트 개발 환경 및 스크립트 변환 편집기를 닫습니다.
SQL Server 대상이나 스크립트 구성 요소를 사용하여 대상 만들기에서 보여 준 샘플 대상 구성 요소와 같이 AddressID 및 City 열을 필요로 하는 대상 구성 요소를 첫 번째 출력에 대해 만들고 구성합니다. 그런 다음 변환의 첫 번째 출력인 MyAddressOutput을 대상 구성 요소에 연결합니다. AdventureWorks 데이터베이스에서 다음 Transact-SQL 명령을 실행하여 대상 테이블을 만들 수 있습니다.
```
CREATE TABLE [Person].[Address2]([AddressID] [int] NOT NULL,  
    [City] [nvarchar](30) NOT NULL)  
```
두 번째 출력에 대한 다른 대상 구성 요소를 만들고 구성합니다. 그런 다음 변환의 두 번째 출력인 MySummaryOutput을 대상 구성 요소에 연결합니다. 두 번째 출력은 단일 값으로 단일 행을 작성하므로 단일 열이 있는 새 파일에 연결하는 플랫 파일 연결 관리자를 사용하여 대상을 쉽게 구성할 수 있습니다. 이 예에서 이 대상 열의 이름은 MyRedmondCount입니다.
예제를 실행합니다.

Public Class ScriptMain  
    Inherits UserComponent  
  
    Private myRedmondAddressCount As Integer  
  
    Public Overrides Sub CreateNewOutputRows()  
  
        MySummaryOutputBuffer.AddRow()  
  
    End Sub  
  
    Public Overrides Sub MyAddressInput_ProcessInput(ByVal Buffer As MyAddressInputBuffer)  
  
        While Buffer.NextRow()  
            MyAddressInput_ProcessInputRow(Buffer)  
        End While  
  
        If Buffer.EndOfRowset Then  
            MyAddressOutputBuffer.SetEndOfRowset()  
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount  
            MySummaryOutputBuffer.SetEndOfRowset()  
        End If  
  
    End Sub  
  
    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)  
  
        With MyAddressOutputBuffer  
            .AddRow()  
            .AddressID = Row.AddressID  
            .City = Row.City  
        End With  
  
        If Row.City.ToUpper = "REDMOND" Then  
            myRedmondAddressCount += 1  
        End If  
  
    End Sub  
  
End Class

public class ScriptMain:  
    UserComponent  
  
{  
    private int myRedmondAddressCount;  
  
    public override void CreateNewOutputRows()  
    {  
  
        MySummaryOutputBuffer.AddRow();  
  
    }  
  
    public override void MyAddressInput_ProcessInput(MyAddressInputBuffer Buffer)  
    {  
  
        while (Buffer.NextRow())  
        {  
            MyAddressInput_ProcessInputRow(Buffer);  
        }  
  
        if (Buffer.EndOfRowset())  
        {  
            MyAddressOutputBuffer.SetEndOfRowset();  
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount;  
            MySummaryOutputBuffer.SetEndOfRowset();  
        }  
  
    }  
  
    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)  
    {  
  
        {  
            MyAddressOutputBuffer.AddRow();  
            MyAddressOutputBuffer.AddressID = Row.AddressID;  
            MyAddressOutputBuffer.City = Row.City;  
        }  
  
        if (Row.City.ToUpper() == "REDMOND")  
        {  
            myRedmondAddressCount += 1;  
        }  
  
    }  
  
}

참고 항목

동기 및 비동기 변환 이해
스크립트 구성 요소를 사용하여 동기 변환 만들기
비동기 출력을 사용하여 사용자 지정 변환 구성 요소 개발

다음을 통해 공유

스크립트 구성 요소를 사용하여 비동기 변환 만들기

비동기 변환 구성 요소 시작

메타데이터 디자인 모드에서 비동기 변환 구성 요소 구성

입력 열 구성

입력, 출력 및 출력 열 구성

변수 추가

코드 디자인 모드에서 비동기 변환 구성 요소 스크립팅

자동 생성된 코드 이해

사용자 지정 코드 작성

예시

참고 항목

피드백

피드백

추가 리소스