다음을 통해 공유

Azure Synapse Analytics의 전용 SQL 풀에 대한 데이터 로드 전략

  • 아티클

기존의 SMP 전용 SQL 풀은 데이터를 로드할 때 ETL(추출, 변환, 로드) 프로세스를 사용합니다. Azure Synapse Analytics 내의 Synapse SQL은 확장성과 유연성이 뛰어난 컴퓨팅 및 스토리지 리소스를 활용하는 분산 쿼리 처리 아키텍처를 사용합니다.

ELT(추출, 로드, 변환) 프로세스를 사용하면 기본 제공된 분산 쿼리 처리 기능을 활용하고 로드 전에 데이터 변환에 필요한 리소스를 제거합니다.

전용 SQL 풀은 bcp, SqlBulkCopy API 등의 널리 사용되는 SQL Server 옵션을 비롯한 여러 로드 방법을 지원하지만, 데이터를 로드하기 위한 가장 빠르고 확장성이 뛰어난 방법은 PolyBase 외부 테이블과 COPY 문을 사용하는 것입니다.

PolyBase와 COPY 문을 사용하면 T-SQL 언어를 통해 Azure Blob Storage 또는 Azure Data Lake Store에 저장된 외부 데이터에 액세스할 수 있습니다. 로드 시 유연성을 극대화하려면 COPY 문을 사용하는 것이 좋습니다.

ELT란 무엇인가요?

ELT(추출, 로드, 변환)는 데이터를 원본 시스템에서 추출하여 전용 SQL 풀로 로드한 다음 변환하는 프로세스입니다.

ELT를 구현하는 기본 단계는 다음과 같습니다.

  1. 원본 데이터를 텍스트 파일로 추출합니다.
  2. Azure Blob Storage 또는 Azure Data Lake Store에 데이터를 둡니다.
  3. 로드할 데이터를 준비합니다.
  4. PolyBase 또는 COPY 문을 사용하여 준비 테이블로 데이터를 로드합니다.
  5. 데이터를 변환합니다.
  6. 프로덕션 테이블에 데이터를 삽입합니다.

로드 자습서는 Azure Blob Storage에서 데이터 로드를 참조하세요.

1. 텍스트 파일에 원본 데이터 추출

원본 시스템에서 데이터를 추출하는 방식은 스토리지 위치에 따라 달라집니다. 지원되는 구분 텍스트 파일 또는 CSV 파일로 데이터를 이동하는 것이 목표입니다.

지원되는 파일 형식

PolyBase 및 COPY 문을 사용하면 UTF-8 및 UTF-16으로 인코딩된 구분된 텍스트 또는 CSV 파일에서 데이터를 로드할 수 있습니다. 구분된 텍스트 또는 CSV 파일 외에도 ORC, Parquet과 같은 Hadoop 파일 형식에서도 데이터를 로드하며, 또한 Gzip 및 Snappy 압축 파일에서도 데이터를 로드합니다.

확장 ASCII, 고정 너비 형식 및 중첩된 형식(예: WinZip, XML)은 지원되지 않습니다. SQL Server에서 내보내는 경우에는 bcp 명령줄 도구를 사용하여 구분된 텍스트 파일로 데이터를 내보낼 수 있습니다.

2. Azure Blob Storage 또는 Azure Data Lake Store에 데이터 저장

Azure 스토리지에 데이터를 두려면 Azure Blob Storage 또는 Azure Data Lake Store Gen2로 이동할 수 있습니다. 어느 위치에서든 데이터를 텍스트 파일에 저장해야 합니다. PolyBase 및 COPY 문은 두 위치 중 어디서든 데이터를 로드할 수 있습니다.

데이터를 Azure Storage로 이동하는 데 사용할 수 있는 도구와 서비스는 다음과 같습니다.

  • Azure ExpressRoute 서비스는 네트워크 처리량, 성능 및 예측 가능성을 개선합니다. ExpressRoute는 Azure에 대한 전용 프라이빗 연결을 통해 데이터를 라우팅하는 서비스입니다. ExpressRoute 연결은 공용 인터넷을 통해 데이터를 라우팅하지 않습니다. 이 연결은 공용 인터넷을 통한 일반적인 연결보다 안정적이고 속도가 빠르며 대기 시간이 짧고 보안성이 높습니다.
  • AzCopy 유틸리티는 공용 인터넷을 통해 Azure Storage로 데이터를 이동합니다. 이는 데이터 크기가 10TB 미만인 경우에 작동합니다. AzCopy를 사용하여 정기적으로 로드를 수행하려면 네트워크 속도를 테스트하여 작업이 가능한지 확인하세요.
  • ADF(Azure Data Factory)에는 로컬 서버에 설치할 수 있는 게이트웨이가 있습니다. 그런 다음 파이프라인을 만들어 로컬 서버에서 Azure Storage로 데이터를 이동할 수 있습니다. 전용 SQL 풀에서 Data Factory를 사용하려면 전용 SQL 풀에 대한 데이터 로드를 참조하세요.

3. 로드할 데이터 준비

데이터를 로드하기 전에 스토리지 계정에서 데이터를 준비하고 정리해야 할 수 있습니다. 데이터가 원본에 있는 동안, 데이터를 텍스트 파일로 내보낼 때 또는 Azure Storage로 이동한 후 데이터 준비를 수행할 수 있습니다. 가능한 경우 프로세스의 초기에 데이터로 작업하는 것이 가장 쉽습니다.

테이블 정의

COPY 문을 사용할 때 먼저 전용 SQL 풀에 로드하는 테이블을 정의해야 합니다.

PolyBase를 사용하는 경우 데이터를 로드하려면 먼저 전용 SQL 풀에서 외부 테이블을 정의해야 합니다. PolyBase는 외부 테이블을 사용하여 Azure Storage의 데이터를 정의하고 액세스합니다. 데이터베이스 뷰와 비슷한 외부 테이블은 테이블 스키마를 포함하며 전용 SQL 풀 외부에 저장된 데이터를 가리킵니다.

외부 테이블 정의에는 데이터 원본, 텍스트 파일 형식 및 테이블 정의를 지정하는 것이 포함됩니다. 다음은 필요한 T-SQL 구문 참조 아티클입니다.

Parquet 파일을 로드할 때 다음 SQL 데이터 형식 매핑을 사용합니다.

Parquet 형식 Parquet 논리 형식(주석) SQL 데이터 형식
BOOLEAN bit
BINARY / BYTE_ARRAY varbinary
DOUBLE float
FLOAT real
INT32 int
INT64 bigint
INT96 datetime2
FIXED_LEN_BYTE_ARRAY binary
BINARY UTF8 nvarchar
BINARY STRING nvarchar
BINARY ENUM nvarchar
BINARY UUID uniqueidentifier
BINARY DECIMAL decimal
BINARY JSON nvarchar(MAX)
BINARY BSON varbinary(max)
FIXED_LEN_BYTE_ARRAY DECIMAL decimal
BYTE_ARRAY INTERVAL varchar(max),
INT32 INT(8, true) smallint
INT32 INT(16, true) smallint
INT32 INT(32, true) int
INT32 INT(8, false) tinyint
INT32 INT(16, false) int
INT32 INT(32, false) bigint
INT32 DATE date
INT32 DECIMAL decimal
INT32 TIME(MILLIS ) time
INT64 INT(64, true) bigint
INT64 INT(64, false) decimal(20,0)
INT64 DECIMAL decimal
INT64 TIME(MILLIS) time
INT64 TIMESTAMP(MILLIS) datetime2
복합 형식 명단 등록 varchar(max)
복합 형식 MAP varchar(max)

Important

  • SQL 전용 풀은 현재 MICROS 및 NANOS 정밀도의 Parquet 데이터 형식을 지원하지 않습니다.
  • Parquet과 SQL 간에 형식이 일치하지 않거나 지원되지 않는 Parquet 데이터 형식이 있는 경우 다음과 같은 오류가 발생할 수 있습니다. HdfsBridge::recordReaderFillBuffer - Unexpected error encountered filling record reader buffer: ClassCastException:...
  • Parquet 및 ORC 파일 형식의 경우 0~127 범위 밖의 값을 tinyint 열에 로드하는 것은 지원되지 않습니다.

외부 개체를 만드는 예제는 외부 테이블 만들기를 참조하세요.

텍스트 파일 형식 지정

PolyBase를 사용하는 경우 정의된 외부 개체는 텍스트 파일의 행을 외부 테이블 및 파일 형식 정의와 정렬해야 합니다. 텍스트 파일의 각 행에 있는 데이터는 테이블 정의와 정렬되어야 합니다. 텍스트 파일의 형식을 지정하려면:

  • 데이터가 비관계형 원본에서 오는 경우 행과 열로 변환해야 합니다. 데이터가 관계형 원본에서 오건 비관계형 원본에서 오건, 데이터를 로드하려고 하는 테이블에 대한 열 정의와 정렬되도록 데이터를 변환해야 합니다.
  • 대상 테이블의 열 및 데이터 형식과 정렬되도록 텍스트 파일에서 데이터의 형식을 지정합니다. 외부 텍스트 파일의 데이터 형식과 전용 SQL 풀 테이블의 데이터 형식이 정렬되지 않으면 로드 중에 행이 거부됩니다.
  • 종결자로 텍스트 파일의 필드를 구분합니다. 원본 데이터에서 찾을 수 없는 문자 또는 문자 시퀀스를 사용해야 합니다. CREATE EXTERNAL FILE FORMAT으로 지정한 종결자를 사용하세요.

4. PolyBase 또는 COPY 문을 사용하여 데이터 로드

데이터는 준비 테이블로 로드하는 것이 가장 좋습니다. 준비 테이블을 사용하면 프로덕션 테이블에 영향을 주지 않고 오류를 처리할 수 있습니다. 준비 테이블에서는 데이터를 프로덕션 테이블에 삽입하기 전에 전용 SQL 풀 병렬 처리 아키텍처를 사용하여 데이터를 변환할 수도 있습니다.

로드 옵션

데이터를 로드하려는 경우 다음 로드 옵션 중 하나를 사용할 수 있습니다.

  • COPY 문은 데이터를 원활하고 유연하게 로드할 수 있도록 권장되는 로드 유틸리티입니다. 해당 문에는 PolyBase에서 제공하지 않는 여러 추가 로드 기능이 있습니다. 샘플 자습서를 실행하려면 뉴욕 택시 COPY 자습서를 참조하세요.
  • T-SQL을 사용하는 PolyBase를 사용하려면 외부 데이터 개체를 정의해야 합니다.
  • ADF(Azure Data Factory)를 이용한 PolyBase 및 COPY 문은 또 다른 오케스트레이션 도구입니다. 파이프라인을 정의하고 작업을 예약합니다.
  • PolyBase와 SSIS는 원본 데이터가 SQL Server에 있을 때 원활하게 작동합니다. SSIS는 대상 테이블 매핑에 대해 원본을 정의하고 로드를 조정합니다. 이미 SSIS 패키지가 있는 경우 새 데이터 웨어하우스 대상으로 작업하도록 패키지를 수정할 수 있습니다.
  • PolyBase와 Azure Databricks는 PolyBase를 사용하여 테이블에서 Databricks 데이터 프레임으로 데이터를 전송하거나 Databricks 데이터 프레임에서 테이블로 데이터를 씁니다.

기타 로드 옵션

PolyBase와 COPY 문 외에도 bcp나 SqlBulkCopy API를 사용할 수 있습니다. bcp는 Azure Blob Storage를 거치지 않고 데이터베이스에 직접 데이터를 로드하며, 소규모 로드에만 사용됩니다.

참고 항목

이러한 옵션의 로드 성능은 PolyBase 및 COPY 문보다 훨씬 느립니다.

5. 데이터 변환

데이터가 준비 테이블에 있는 동안, 워크로드에 필요한 변환을 수행하세요. 그런 다음 데이터를 프로덕션 테이블로 이동하세요.

6. 프로덕션 테이블에 데이터 삽입

INSERT INTO ... SELECT 문은 스테이징 테이블에서 영구 테이블로 데이터를 이동합니다.

ETL 프로세스를 설계할 때 작은 테스트 샘플에서 프로세스를 실행해 보세요. 테이블에서 파일로 1000개 행을 추출하여 Azure로 이동한 다음 준비 테이블에 로드해 보세요.

파트너 로드 솔루션

상당수의 파트너에게는 로드 솔루션이 있습니다. 자세한 내용을 알아보려면 솔루션 파트너 목록을 참조하세요.

다음 단계

로드 지침은 데이터 로드 모범 사례를 참조하세요.