환경 설정 및 연결

개요: 다음 단계에 따라 Klaviyo 에 대한 데이터브릭을 준비합니다. 카탈로그에서 필요한 스키마를 만들고, Klaviyo 에 대한 전용 계정 및 액세스 토큰을 설정하고, 필요한 최소 권한을 할당하고, 구성을 확인하고, Databricks를 Klaviyo 에 연결합니다.

중요: 현재 데이터브릭스 연결은 Klaviyo로의 데이터 가져오기만 지원합니다.

• 이제 프로필을 가져올 수 있습니다.
• 이벤트 가져오기가 곧 출시됩니다.
• 데이터브릭으로 내보내기는 아직 사용할 수 없습니다. 그때까지는 S3로 내보내기를 권장합니다.

스키마 구조, 필수 테이블 및 필드 매핑을 포함하여 Klaviyo에서 데이터 웨어하우스 가져오기가 작동하는 방식에 대한 자세한 내용은 Klaviyo 에서 데이터 웨어하우스 가져오기 작동 방식을참조하세요.

1) 필수 스키마 생성

데이터브릭에서 스키마 (데이터베이스라고도 함)는 카탈로그 안에 있습니다. 워크스페이스에서 Unity 카탈로그를 사용하는 경우 기본 기본 카탈로그 또는 다른 카탈로그를 사용할 수 있습니다.

USE CATALOG main; -- 또는 조직에서 지정한 카탈로그
CREATE SCHEMA IF NOT EXISTS KLAVIYO_IMPORT_FROM_DWH;
CREATE SCHEMA IF NOT EXISTS KLAVIYO_TMP;

• KLAVIYO_IMPORT_FROM_DWH: 이 스키마에서 만든 테이블 및 뷰는 새 동기화를 구성할 때 선택할 수 있습니다.
• KLAVIYO_TMP: 동기화 중에 사용되는 임시/준비 데이터입니다.

참고: 워크스페이스에서 Unity 카탈로그를 사용하지 않는 경우, 데이터브릭스에서는 "스키마"와 "데이터베이스"를 동등한 것으로 취급합니다. 스키마 만들기 대신 데이터베이스 만들기를 사용할 수 있습니다.

2) Klaviyo 서비스 계정 및 액세스 토큰을 생성합니다.

Klaviyo 는 개인 액세스 토큰(PAT)이 있는 전용 계정을 사용하여 데이터브릭스에서 인증합니다. 가능하면 사람이 아닌 (서비스) 계정을 사용하고 비밀번호 관리자나 비밀 저장소 등 안전한 곳에 PAT를 저장하세요. 초기 설정 시 이 토큰을 Klaviyo 에 제공해야 합니다.

2.1 계정 만들기

이 연동 전용으로 사용할 데이터브릭스 워크스페이스 사용자 또는 Klaviyo 서비스 주체를 만듭니다.

2.2 개인 액세스 토큰 생성하기

• 워크스페이스 사용자 계정: 데이터브릭스 웹 UI를 통해 토큰을 생성합니다(데이터브릭스 문서 참조): 워크스페이스 사용자를 위한 개인 액세스 토큰을 생성합니다.
• 서비스 주체: 데이터브릭스 CLI를 사용하여 토큰을 생성합니다(데이터브릭스 문서 참조): 데이터브릭스 CLI를 통해 개인 액세스 토큰을 생성합니다.

중요: PAT를 비밀로 취급하세요. 토큰을 가진 사람은 누구나 연결된 계정의 권한으로 데이터브릭에 액세스할 수 있습니다.

3) 필수 권한 할당

Klaviyo 계정에 1단계에서 만든 스키마에 대해 다음 권한을 부여합니다. klaviyo_service_user를 실제 사용자 이름 또는 서비스 관리자 이름으로 바꾸고 스키마 접두사를 올바른 카탈로그(예: main)로 바꿉니다.

-- 임시 스키마에 대한 권한 부여
GRANT ALL PRIVILEGES ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- 또는, 세부 권한 부여:
GRANT USE SCHEMA, MODIFY, SELECT, CREATE TABLE ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- 스키마 가져오기에 대한 읽기 전용 액세스 권한 부여
GRANT USE SCHEMA, SELECT ON SCHEMA main.KLAVIYO_IMPORT_FROM_DWH TO `klaviyo_service_user`;

모범 사례: 최소 권한 원칙을 적용하여 필요한 권한만 부여하세요.

4) 설정 확인(선택 사항)

4.1 스키마가 있는지 확인

데이터브릭스 SQL 노트북 또는 편집기에서 실행합니다:

메인에 스키마 표시; -- 다른 경우 '메인'을 카탈로그로 바꿉니다.

보셔야 합니다:

클라비요_임포트_프롬_dwh
클라비요_tmp

4.2 인증 테스트(PAT 사용)

Klaviyo 에 제공하려는 토큰과 동일한 토큰으로 데이터브릭스 CLI를 사용하세요:

# 토큰 및 호스트 설정(AWS의 예)
export DATABRICKS_HOST="https://<your-workspace>.cloud.databricks.com"
export DATABRICKS_TOKEN="<your-PAT>" 

 # 간단한 API 호출 실행
databricks current-user me

예상 결과입니다: 사용자 또는 서비스 주체의 세부 정보(예: 표시 이름, 사용자 ID)를 보여주는 JSON 출력입니다. HTTP 403 또는 인증 오류가 발생하면 토큰과 호스트 URL을 확인하세요.

4.3 각 스키마에 대한 권한 확인

SCHEMA main.klaviyo_tmp에 보조금 표시;
SCHEMA main.klaviyo_import_from_dwh에 보조금 표시;

Klaviyo 계정에 예상 권한(예: USE SCHEMA, SELECT, MODIFY, CREATE TABLE)이 표시되는지 확인합니다.

4.4 생성/읽기 작업 유효성 검사

-- KLAVIYO_TMP에서 생성/추가 삭제 테스트
USE SCHEMA main.klaviyo_tmp;
CREATE TABLE IF NOT EXISTS test_perissions (id INT);
DROP TABLE test_perissions;

-- 테스트 선택 KLAVIYO_IMPORT_FROM_DWH에서
USE SCHEMA main.klaviyo_IMPORT_From_dwh에서 실행합니다;
표 표시;

팁:

• Klaviyo 에서 공유할 동일한 ID 및 PAT를 사용하여 이 확인 단계를 실행합니다.
• 감사/문제 해결을 위해 SQL 부여 내역 및 확인 출력을 보관합니다.
• 일정한 주기로 그리고 스태프가 바뀐 후에 PAT를 회전합니다.

5) 데이터브릭스( Klaviyo )에 연결

데이터브릭스 구성이 완료되면 Klaviyo 에서 연결을 완료합니다.

1. Klaviyo 에서 왼쪽 사이드바를 열고 고급 > 동기화로 이동합니다.
2. 동기화 생성을 클릭합니다.
3. 데이터 웨어하우스에서 데이터 가져오기를 선택합니다.
4. 데이터 웨어하우스로 데이터브릭스를 선택합니다.
5. 데이터브릭에 연결을 클릭합니다.

메시지가 표시되면 다음 연결 세부 정보를 입력합니다:

카탈로그 보기;

연결 후: Klaviyo 에서 연결을 테스트하고 데이터브릭스 환경에 대한 액세스를 확인합니다. 확인이 완료되면 앞서 준비한 스키마에서 데이터를 가져오도록 동기화를 구성할 수 있습니다.

다음 단계: 연결이 성공적으로 완료되면 Klaviyo에서 첫 번째 동기화를 생성하고 데이터브릭스에서 데이터 가져오기를 시작합니다.