Omgeving instellen en verbinden

Overzicht: Volg deze stappen om Databricks voor te bereiden op Klaviyo. Je maakt de vereiste schema's aan (in een catalogus), stelt een speciaal account en toegangstoken in voor Klaviyo, kent de minimaal vereiste privileges toe, verifieert de configuratie en verbindt Databricks met Klaviyo.

Belangrijk: De Databricks-verbinding ondersteunt momenteel alleen het importeren van gegevens in Klaviyo.

• Profiel kan nu worden geïmporteerd.
• Het importeren van evenementen komt eraan.
• Exporteren naar Databricks is nog niet beschikbaar. Tot die tijd is exporteren naar S3 aan te raden.

Voor meer informatie over hoe importeren uit datawarehouse werkt in Klaviyo- inclusief schema-structuur, vereiste tabellen en veld-toewijzingen - zie Hoe importeren uit datawarehouse werkt in Klaviyo .

1) Vereiste schema's maken

In Databricks leven schema's (ook wel databases genoemd) in een catalogus. Je kunt de standaard hoofdcatalogus gebruiken of een andere catalogus als je werkruimte Unity Catalog gebruikt.

USE CATALOG main; -- of de door jouw organisatie aangewezen catalogus
CREATE SCHEMA IF NOT EXISTS KLAVIYO_IMPORT_FROM_DWH;
CREATE SCHEMA IF NOT EXISTS KLAVIYO_TMP;

• KLAVIYO_IMPORT_FROM_DWH: Tabellen en views die zijn aangemaakt in dit schema zullen beschikbaar zijn voor selectie bij het configureren van een nieuwe synchronisatie.
• KLAVIYO_TMP: tijdelijke gegevens die gebruikt worden tijdens het synchroniseren.

Opmerking: Als je werkruimte Unity Catalog niet gebruikt, behandelt Databricks "schema" en "database" als gelijkwaardig. Je kunt CREATE DATABASE gebruiken in plaats van CREATE SCHEMA.

2) Maak de Klaviyo Service account en Access Token aan.

Klaviyo authenticeert zich bij Databricks door middel van een speciale account met een persoonlijk toegangstoken (PAT). Gebruik waar mogelijk een niet-menselijk (service) account en sla het PAT veilig op (bijvoorbeeld een wachtwoordmanager of geheime opslag). Je geeft dit token aan Klaviyo tijdens de eerste installatie.

2.1 De account aanmaken

Maak een Databricks workspace gebruiker of een service principal aan die Klaviyo exclusief voor deze integratie zal gebruiken.

2.2 Het persoonlijke toegangstoken genereren

• Werkruimtegebruiker account: Genereer het token via de Databricks web UI (zie Databricks docs): Creëer persoonlijke toegangstokens voor werkruimtegebruikers
• Service principal: Genereer het token met behulp van de Databricks CLI (zie Databricks docs): Creëer persoonlijke toegangstokens via de Databricks CLI

Belangrijk: behandel het PAT als een geheim. Iedereen met het token heeft toegang tot Databricks met de bijbehorende account's rechten.

3) Vereiste machtigingen toewijzen

Ken de Klaviyo account de volgende rechten toe op de schema's die in stap 1 zijn aangemaakt. Vervang klaviyo_service_user door je echte gebruikersnaam of service principal naam, en zet schema's voor de juiste catalogus (bijv. main).

-- Geef rechten op tijdelijk schema
GRANT ALL PRIVILEGES ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- OF, geef granulaire rechten:
GRANT USE SCHEMA, MODIFY, SELECT, CREATE TABLE ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- Alleen-lezen toegang verlenen tot importschema
GRANT USE SCHEMA, SELECT ON SCHEMA main.KLAVIYO_IMPORT_FROM_DWH TO `klaviyo_service_user`;

Beste werkwijze: Pas het principe van de minste privileges toe: geef alleen dat wat nodig is.

4) Je instellingen controleren (optioneel)

4.1 Bevestig dat de schema's bestaan

Voer uit in een Databricks SQL-notebook of -editor:

SHOW SCHEMAS IN main; -- vervang 'main' door je catalogus als die anders is

Moet je zien:

klaviyo_import_from_dwh
klaviyo_tmp

4.2 Authenticatie testen (met je PAT)

Gebruik de Databricks CLI met hetzelfde token dat je aan Klaviyo wilt geven:

# Stel je token en host in (voorbeeld voor AWS)
export DATABRICKS_HOST="https://<your-workspace>.cloud.databricks.com"
export DATABRICKS_TOKEN="<your-PAT>" 

 # Voer een eenvoudige API-aanroep uit
databricks current-user me

Verwacht resultaat: JSON uitvoer met de details van de gebruiker of diensthoofd (bijv. weergavenaam, gebruikers-ID). Als je een HTTP 403 of authenticatiefout krijgt, controleer dan het token en de host URL.

4.3 Controleer de rechten op elk schema

SCHEMA main.klaviyo_tmp;
SHOW GRANTS ON SCHEMA main.klaviyo_import_from_dwh;

Controleer of je Klaviyo account verschijnt met de verwachte privileges (bijv. USE SCHEMA, SELECT, MODIFY, CREATE TABLE).

4.4 Creatie/leesbewerkingen valideren

-- Test creëren/verwijderen in KLAVIYO_TMP
USE SCHEMA main.klaviyo_tmp;
CREATE TABLE IF NOT EXISTS test_permissions (id INT);
DROP TABLE test_permissions;

-- Test select in KLAVIYO_IMPORT_FROM_DWH
USE SCHEMA main.klaviyo_import_from_dwh;
TABELLEN TONEN;

Tips:

• Voer deze verificatiestappen uit met dezelfde identiteit en PAT die u met Klaviyo deelt.
• Bewaar de SQL grant statements en verificatie-uitvoer voor audit/troubleshooting.
• Draai de PAT regelmatig en na personeelswisselingen.

5) Klaviyo verbinden met Databricks

Zodra Databricks is geconfigureerd, voltooi je de verbinding in Klaviyo.

1. Open in Klaviyo de linker zijbalk en navigeer naar Geavanceerd > Synchroniseren.
2. Klik op Synchronisatie maken.
3. Selecteer Gegevens importeren uit je datawarehouse.
4. Kies Databricks als je datawarehouse.
5. Klik op Verbinden met Databricks.

Geef de volgende verbindingsgegevens op wanneer daarom wordt gevraagd:

SHOWCATALOGI;

Nadat u verbinding hebt gemaakt: Klaviyo zal de verbinding testen en de toegang tot uw Databricks-omgeving bevestigen. Eenmaal geverifieerd kun je syncs configureren om gegevens te importeren uit de schema's die je eerder hebt voorbereid.

Volgende stap: Nadat je met succes verbinding hebt gemaakt, ga je verder met het aanmaken van je eerste synchronisatie in Klaviyo en begin je met het importeren van gegevens uit Databricks.