BigQuery 대상 구성

이 페이지에서는 BigQuery 데이터 세트에 데이터를 쓸 수 있도록 Datastream을 구성하는 방법을 설명합니다.

필수 권한

Datastream은 변경 데이터 캡처 (CDC) 업데이트를 위한 BigQuery 내장 지원을 사용합니다. Datastream은 BigQuery Storage Write API를 사용하여 스트리밍된 변경사항을 처리하고 적용하여 BigQuery 테이블을 업데이트합니다.

API를 사용하고 BigQuery에 데이터를 수집하는 데 필요한 권한은 Datastream 서비스 에이전트 역할에 부여됩니다.

BigQuery를 대상으로 구성

BigQuery로 스트리밍하도록 Datastream을 구성하려면 다음 단계를 수행하세요.

  1. Google Cloud프로젝트에 BigQuery API가 사용 설정되어 있어야 합니다.
  2. 모든 스키마를 위한 단일 데이터 세트 옵션을 사용하려면 BigQuery에서 데이터 세트를 만드세요.
  3. 스트림의 대상 데이터 세트 구성
  4. 쓰기 모드 구성
  5. 스트림의 최대 데이터 비활성 한도를 지정합니다.

대상 데이터 세트 구성

데이터 세트는 BigQuery 테이블에 대한 액세스를 구성하고 제어하는 데 사용되는 최상위 컨테이너입니다.

Datastream을 사용하여 BigQuery 대상의 데이터 세트를 구성할 때 다음 옵션 중 하나를 선택할 수 있습니다.

  • 각 스키마를 위한 데이터 세트: 데이터 세트는 지정된 BigQuery 위치에서 소스의 스키마 이름을 기반으로 Datastream에 의해 선택되거나 자동으로 생성됩니다. 따라서 소스의 각 스키마에는 BigQuery의 해당 데이터 세트가 있습니다. 예를 들어 MySQL 소스가 있고 이 소스에 mydb 데이터베이스가 있고 데이터베이스 내에 employees 테이블이 있으면 Datastream이 BigQuery에서 mydb 데이터 세트 및 employees 테이블을 만듭니다.

    이 옵션을 선택하면 Datastream이 스트림이 포함된 프로젝트에 데이터 세트를 만듭니다. 스트림과 동일한 리전에서 데이터 세트를 만들 필요는 없지만 비용 및 성능 최적화를 위해 스트림의 모든 리소스와 데이터 세트를 동일한 리전에 유지하는 것이 좋습니다.

  • 모든 스키마를 위한 단일 데이터 세트: 스트림의 BigQuery 데이터 세트를 선택합니다. Datastream이 모든 데이터를 이 데이터 세트로 스트리밍합니다. Datastream은 선택한 데이터 세트에 대해 모든 테이블을 <schema>_<table>로 만듭니다.

    예를 들어 MySQL 소스가 있고 이 소스에 mydb 데이터베이스가 있고 데이터베이스 내에 employees 테이블이 있으면 Datastream이 선택한 데이터 세트에서 mydb_employees 테이블을 만듭니다.

쓰기 모드 구성

BigQuery에 데이터를 쓰는 방법을 정의할 때는 두 가지 모드를 사용할 수 있습니다.

  • 병합: 기본 쓰기 모드입니다. 선택하면 BigQuery에 소스 데이터베이스에 데이터가 저장된 방식이 반영됩니다. 즉, Datastream은 데이터의 모든 변경사항을 BigQuery에 쓰고 BigQuery는 변경사항을 기존 데이터와 통합하여 소스 테이블의 복제본인 최종 테이블을 만듭니다. 병합 모드에서는 변경 이벤트의 이전 기록이 보관되지 않습니다. 예를 들어 행을 삽입한 후 업데이트하면 BigQuery는 업데이트된 데이터만 유지합니다. 그런 다음 소스 테이블에서 행을 삭제하면 BigQuery에서 해당 행의 레코드를 더 이상 보관하지 않습니다.

  • 추가 전용: 추가 전용 쓰기 모드를 통해 BigQuery에 데이터를 변경 내역으로 추가할 수 있습니다 (INSERT, UPDATE-INSERT, UPDATE-DELETE, DELETE 이벤트). 데이터의 이전 상태를 유지해야 하는 경우 이 모드를 사용합니다. 추가 전용 쓰기 모드를 더 잘 이해하려면 다음 시나리오를 고려하세요.

    • 초기 백필: 초기 백필 후에는 모든 이벤트가 동일한 타임스탬프, 범용 고유 식별자(UUID), 변경 시퀀스 넘버가 있는 INSERT 유형 이벤트로 BigQuery에 기록됩니다.
    • 기본 키 업데이트: 기본 키가 변경되면 두 개의 행이 BigQuery에 기록됩니다.
      • 원래 기본 키가 있는 UPDATE-DELETE
      • 새 기본 키가 있는 UPDATE-INSERT
    • 행 업데이트: 행을 업데이트하면 단일 UPDATE-INSERT 행이 BigQuery에 기록됩니다.
    • 행 삭제: 행을 삭제하면 단일 DELETE 행이 BigQuery에 기록됩니다.

데이터 비활성 한도 지정

BigQuery는 구성된 데이터 비활성 한도에 따라 지속적으로 또는 쿼리 실행 시 백그라운드에서 소스 수정사항을 적용합니다. Datastream이 BigQuery에서 새 테이블을 만들 때 스트림의 현재 데이터 비활성 한도 값에 따라 테이블의 max_staleness 옵션이 설정됩니다.

max_staleness 옵션과 함께 BigQuery 테이블을 사용하는 방법에 대한 자세한 내용은 테이블 비활성을 참조하세요.