U-SQL UDO(사용자 정의 연산자) 개발

  • 아티클

이 문서에서는 U-SQL 작업에서 데이터를 처리하기 위한 사용자 정의 연산자를 개발하는 방법을 설명합니다.

U-SQL에서 사용자 정의 연산자 정의 및 사용

U-SQL 작업을 만들고 제출하기

  1. Visual Studio 메뉴에서 파일 > 새로 만들기 > 프로젝트 > U-SQL 프로젝트를 선택합니다.

  2. 확인을 선택합니다. Visual Studio는 Script.usql 파일로 솔루션을 만듭니다.

  3. 솔루션 탐색기에서 Script.usql을 확장하고 Script.usql.cs를 두 번 클릭합니다.

  4. 다음 코드를 파일에 붙여넣습니다.

    using Microsoft.Analytics.Interfaces;
using System.Collections.Generic;
namespace USQL_UDO
{
    public class CountryName : IProcessor
    {
        private static IDictionary<string, string> CountryTranslation = new Dictionary<string, string>
        {
            {
                "Deutschland", "Germany"
            },
            {
                "Suisse", "Switzerland"
            },
            {
                "UK", "United Kingdom"
            },
            {
                "USA", "United States of America"
            },
            {
                "中国", "PR China"
            }
        };
        public override IRow Process(IRow input, IUpdatableRow output)
        {
            string UserID = input.Get<string>("UserID");
            string Name = input.Get<string>("Name");
            string Address = input.Get<string>("Address");
            string City = input.Get<string>("City");
            string State = input.Get<string>("State");
            string PostalCode = input.Get<string>("PostalCode");
            string Country = input.Get<string>("Country");
            string Phone = input.Get<string>("Phone");
            if (CountryTranslation.Keys.Contains(Country))
            {
                Country = CountryTranslation[Country];
            }
            output.Set<string>(0, UserID);
            output.Set<string>(1, Name);
            output.Set<string>(2, Address);
            output.Set<string>(3, City);
            output.Set<string>(4, State);
            output.Set<string>(5, PostalCode);
            output.Set<string>(6, Country);
            output.Set<string>(7, Phone);
            return output.AsReadOnly();
        }
    }
}

  5. Script.usql을 열고 다음 U-SQL 스크립트를 붙여넣습니다.

    @drivers =
    EXTRACT UserID      string,
            Name        string,
            Address     string,
            City        string,
            State       string,
            PostalCode  string,
            Country     string,
            Phone       string
    FROM "/Samples/Data/AmbulanceData/Drivers.txt"
    USING Extractors.Tsv(Encoding.Unicode);

@drivers_CountryName =
    PROCESS @drivers
    PRODUCE UserID string,
            Name string,
            Address string,
            City string,
            State string,
            PostalCode string,
            Country string,
            Phone string
    USING new USQL_UDO.CountryName();

OUTPUT @drivers_CountryName
    TO "/Samples/Outputs/Drivers.csv"
    USING Outputters.Csv(Encoding.Unicode);

  6. 데이터 레이크 분석 계정, 데이터베이스, 스키마를 지정합니다.

  7. 솔루션 탐색기에서 Script.usql을 마우스 오른쪽 클릭하고 빌드 스크립트를 선택합니다.

  8. 솔루션 탐색기에서 Script.usql을 마우스 오른쪽 클릭한 다음, 스크립트 제출을 선택합니다.

  9. Azure 구독에 연결하지 않았다면 Azure 계정 자격 증명을 입력하라는 메시지가 표시됩니다.

  10. 제출을 선택합니다. 제출이 완료되면 결과 창에서 제출 결과 및 작업 링크를 사용할 수 있습니다.

  11. 최근 작업 상태를 보고 화면을 새로 고치려면 새로 고침 단추를 선택합니다.

출력을 보려면

  1. 서버 탐색기, Azure 확장, 데이터 레이크 분석 확장, 사용자 데이터 레이크 분석 계정 확장, Storage 계정 확장에서 기본 스토리지를 오른 클릭하고 탐색기를 선택합니다.

  2. 샘플 및 출력을 확장하고 Drivers.csv를 두 번 클릭합니다.

다음 단계