[Beta]{class="badge informative"} [Ultimate]{class="badge positive"}

Snowflake 스트리밍 원본

Last update: Tue Jul 16 2024 00:00:00 GMT+0000 (Coordinated Universal Time)

주제:

작성 대상:

개발자

IMPORTANT

Snowflake 스트리밍 원본이 베타 버전입니다. 베타 레이블 소스를 사용하는 방법에 대한 자세한 내용은 소스 개요를 참조하십시오.
Snowflake 스트리밍 소스는 Real-time Customer Data Platform Ultimate를 구매한 사용자에게 API에서 사용할 수 있습니다.

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

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

Snowflake 스트리밍 원본 이해

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

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

전제 조건

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

필요한 자격 증명 수집

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

자격 증명

설명

account

Snowflake 계정과 연결된 전체 계정 이름. 정규화된 Snowflake 계정 이름에는 계정 이름, 지역 및 클라우드 플랫폼이 포함됩니다. 예, cj12345.east-us-2.azure. 계정 이름에 대한 자세한 내용은 이 [Snowflake document on account identifiers] (https://docs.snowflake.com/en/user-guide/admin-account-identifier.html)을(를) 참조하세요.

warehouse

Snowflake 웨어하우스에서 응용 프로그램의 쿼리 실행 프로세스를 관리합니다. 각 Snowflake 웨어하우스는 서로 독립적이며 데이터를 플랫폼으로 가져올 때 개별적으로 액세스해야 합니다.

database

Snowflake 데이터베이스에 플랫폼에 가져올 데이터가 있습니다.

username

Snowflake 계정의 사용자 이름입니다.

password

Snowflake 사용자 계정의 암호입니다.

role

(선택 사항) 지정된 연결에 대해 사용자에게 제공할 수 있는 사용자 정의 역할입니다. 지정하지 않으면 이 값은 기본적으로 public(으)로 설정됩니다.

connectionSpec.id

연결 사양은 기본 및 소스 연결 만들기와 관련된 인증 사양을 포함하여 소스의 커넥터 속성을 반환합니다. Snowflake의 연결 사양 ID는 51ae16c2-bdad-42fd-9fce-8d5dfddaf140입니다.

역할 설정 구성 configure-role-settings

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

Snowflake 엔터티

역할 권한 필요

웨어하우스

운영, 사용

데이터베이스

사용

스키마

사용

테이블

선택

NOTE

창고의 고급 설정 구성에서 자동 재개 및 자동 일시 중지를 활성화해야 합니다.

역할 및 권한 관리에 대한 자세한 내용은 [Snowflake API 참조] (https://docs.snowflake.com/en/sql-reference/sql/grant-privilege)를 참조하세요.

제한 사항 및 FAQ limitations-and-frequently-asked-questions

Snowflake 원본의 데이터 처리량은 초당 레코드 2000개입니다.
창고가 활성화된 시간과 창고 크기에 따라 가격 책정이 달라질 수 있다. Snowflake 소스 통합의 경우 가장 작은 크기의 x-small 웨어하우스로 충분합니다. 자동 중지를 가능하게 하여 창고가 미사용 시 자체적으로 중지를 할 수 있도록 할 것을 제안한다.
Snowflake 원본은 10초마다 새 데이터를 위해 데이터베이스를 폴링합니다.
구성 옵션:
- 소스 연결을 만들 때 Snowflake 소스에 대해 backfill 부울 플래그를 사용하도록 설정할 수 있습니다.
  - backfill 이 true 로 설정되면 timestamp.initial 의 값이 0으로 설정됩니다. 즉, 타임스탬프 열이 0 epoch 시간보다 큰 데이터를 가져옵니다.
  - backfill 이 false 로 설정되어 있으면 timestamp.initial 의 값이 -1 로 설정됩니다. 즉, 타임스탬프 열이 현재 시간(소스가 수집을 시작하는 시간)보다 큰 데이터를 가져옵니다.
- 타임스탬프 열의 형식은 TIMESTAMP_LTZ 또는 TIMESTAMP_NTZ 형식으로 지정해야 합니다. 타임스탬프 열이 TIMESTAMP_NTZ(으)로 설정된 경우 값이 저장된 해당 시간대가 timezoneValue 매개 변수를 통해 전달되어야 합니다. 제공되지 않는 경우 값은 기본적으로 UTC로 설정됩니다.
  - TIMESTAMP_TZ은(는) 타임스탬프 열 또는 매핑에서 사용할 수 없습니다.

다음 단계

다음 자습서에서는 API를 사용하여 Snowflake 스트리밍 소스를 Experience Platform에 연결하는 방법에 대한 단계를 제공합니다.

recommendation-more-help

337b99bb-92fb-42ae-b6b7-c7042161d089