Ultimate

Snowflake 스트리밍 원본

마지막 업데이트: 2025년 1월 9일
  • 주제:

작성 대상:

  • 개발자
IMPORTANT

  • Snowflake 스트리밍 소스는 Real-Time CDP Ultimate을 구매한 사용자에게 API에서 사용할 수 있습니다.

  • 이제 Amazon Web Services(AWS)에서 Adobe Experience Platform을 실행할 때 Snowflake 스트리밍 소스를 사용할 수 있습니다. 현재 AWS에서 실행 중인 Experience Platform은 제한된 수의 고객이 사용할 수 있습니다. 지원되는 Experience Platform 인프라에 대한 자세한 내용은 Experience Platform 멀티 클라우드 개요를 참조하세요.

Adobe Experience Platform을 사용하면 외부 소스에서 데이터를 수집할 수 있으며 Platform 서비스를 사용하여 들어오는 데이터를 구조화하고, 레이블을 지정하고, 향상시킬 수 있습니다. Adobe 애플리케이션, 클라우드 기반 스토리지, 데이터베이스 및 기타 여러 소스와 같은 다양한 소스에서 데이터를 수집할 수 있습니다.

Experience Platform은 Snowflake 데이터베이스에서 데이터를 스트리밍할 수 있도록 지원합니다.

Snowflake 스트리밍 원본 이해

Snowflake 스트리밍 원본은 SQL 쿼리를 주기적으로 실행하고 결과 집합에서 각 행에 대한 출력 레코드를 만들어 데이터를 로드하여 작동합니다.

Kafka Connect을(를) 사용하여 Snowflake 스트리밍 소스는 다음 반복에 대한 올바른 위치에서 시작할 수 있도록 각 테이블에서 받은 최신 레코드를 추적합니다. 소스는 이 기능을 사용하여 데이터를 필터링하고 각 반복의 테이블에서 업데이트된 행만 가져옵니다.

전제 조건

다음 섹션에서는 Snowflake 데이터베이스에서 Experience Platform으로 데이터를 스트리밍하기 전에 완료해야 하는 필수 조건 단계에 대해 설명합니다.

IP 주소 허용 목록 업데이트

소스 커넥터로 작업하려면 먼저 IP 주소 목록을 허용 목록에 추가해야 합니다. 지역별 IP 주소를 허용 목록에 추가하지 않으면 소스 사용 시 오류가 발생하거나 성능이 저하될 수 있습니다. 자세한 내용은 IP 주소 허용 목록 페이지를 참조하세요.

아래 설명서는 API 또는 사용자 인터페이스를 사용하여 Amazon Redshift을(를) 플랫폼에 연결하는 방법에 대한 정보를 제공합니다.

필요한 자격 증명 수집

Flow Service이(가) Snowflake과(와) 연결하려면 다음 연결 속성을 제공해야 합니다.

자격 증명설명
account

snowflakecomputing.com 접미사가 추가된 Snowflake 계정의 전체 계정 식별자(계정 이름 또는 계정 로케이터)입니다. 계정 식별자는 다양한 형식일 수 있습니다.

  • {ORG_NAME}-{ACCOUNT_NAME}.snowflakecomputing.com(예: acme-abc12345.snowflakecomputing.com)
  • {ACCOUNT_LOCATOR}.{CLOUD_REGION_ID}.snowflakecomputing.com (예: acme12345.ap-southeast-1.snowflakecomputing.com)
  • {ACCOUNT_LOCATOR}.{CLOUD_REGION_ID}.{CLOUD}.snowflakecomputing.com (예: acme12345.east-us-2.azure.snowflakecomputing.com)

자세한 내용은 Snowflake document on account identifiers을(를) 참조하십시오.

warehouseSnowflake 웨어하우스에서 응용 프로그램의 쿼리 실행 프로세스를 관리합니다. 각 Snowflake 웨어하우스는 서로 독립적이며 데이터를 플랫폼으로 가져올 때 개별적으로 액세스해야 합니다.
databaseSnowflake 데이터베이스에 플랫폼에 가져올 데이터가 있습니다.
usernameSnowflake 계정의 사용자 이름입니다.
passwordSnowflake 사용자 계정의 암호입니다.
role(선택 사항) 지정된 연결에 대해 사용자에게 제공할 수 있는 사용자 정의 역할입니다. 지정하지 않으면 이 값은 기본적으로 public(으)로 설정됩니다.
connectionSpec.id연결 사양은 기본 및 소스 연결 만들기와 관련된 인증 사양을 포함하여 소스의 커넥터 속성을 반환합니다. Snowflake의 연결 사양 ID는 51ae16c2-bdad-42fd-9fce-8d5dfddaf140입니다.

역할 설정 구성

기본 공용 역할이 할당되었더라도 소스 연결이 관련 Snowflake 데이터베이스, 스키마 및 테이블에 액세스할 수 있도록 역할에 대한 권한을 구성해야 합니다. 서로 다른 Snowflake 엔터티에 대한 다양한 권한은 다음과 같습니다.

Snowflake 엔터티역할 권한 필요
웨어하우스운영, 사용
데이터베이스사용
스키마사용
테이블선택
NOTE
창고의 고급 설정 구성에서 자동 재개 및 자동 일시 중지를 활성화해야 합니다.

역할 및 권한 관리에 대한 자세한 내용은 Snowflake API 참조를 참조하세요.