Conector Amplitude
Conectați Amplitude la Brevo prin Tajo pentru a valorifica datele de analiză a produselor în automatizarea de marketing. Sincronizați cohortele comportamentale, proprietățile utilizatorilor și evenimentele din produs pentru a alimenta campanii targetate.
Prezentare generală
| Proprietate | Valoare |
|---|---|
| Platformă | Amplitude |
| Categorie | Analiză (Personalizat) |
| Complexitate configurare | Medie |
| Integrare oficială | Nu |
| Date sincronizate | Evenimente, Utilizatori, Cohorte, Proprietăți |
| Skilluri disponibile | 6 |
Funcționalități
- Redirecționare evenimente - Trimiteți evenimentele de urmărire Amplitude la Brevo pentru declanșatoare de automatizare de marketing
- Sincronizare cohorte - Exportați cohortele comportamentale Amplitude ca liste de contacte Brevo
- Sincronizare proprietăți utilizator - Mapați proprietățile utilizatorilor Amplitude la atributele de contact Brevo
- Urmărire venituri - Sincronizați evenimentele de venituri pentru analiza valorii pe durata vieții clientului
- Segmentare comportamentală - Utilizați datele de implicare Amplitude în segmentele Brevo
- Integrare HTTP V2 API - Integrare directă cu API-ul de ingestie HTTP V2 al Amplitude
Cerințe preliminare
Înainte de a începe, asigurați-vă că aveți:
- Un cont Amplitude cu un proiect creat
- Cheia API și Cheia secretă Amplitude
- Un cont Brevo cu acces API
- Un cont Tajo cu credențiale API
Autentificare
Chei API Amplitude
Amplitude utilizează perechi de Cheie API și Cheie secretă pentru autentificare. Cheia API identifică proiectul dvs., în timp ce Cheia secretă autentifică cererile de pe server.
# Find your keys in Amplitude:# Settings > Projects > [Your Project] > GeneralAutentificare HTTP V2 API
HTTP V2 API utilizează cheia API în corpul cererii:
curl -X POST https://api2.amplitude.com/2/httpapi \ -H "Content-Type: application/json" \ -d '{ "api_key": "YOUR_AMPLITUDE_API_KEY", "events": [...] }'Configurare
Configurare de bază
connectors: amplitude: enabled: true api_key: "your-amplitude-api-key" secret_key: "your-amplitude-secret-key" data_center: "US" # or "EU"
# Data sync options sync: events: true user_properties: true cohorts: true revenue: true
# Brevo list assignment lists: active_users: 10 power_users: 11 churning_users: 12Mapare evenimente
Mapați evenimentele Amplitude la declanșatoarele de automatizare Brevo:
event_mapping: # Amplitude event -> Brevo event "Purchase": "order_completed" "Sign Up": "customer_created" "Add to Cart": "cart_updated" "Page View": "page_viewed" "Feature Click": "feature_used"
# Revenue events "Revenue": "revenue_event" "Subscription Started": "subscription_created"Mapare proprietăți utilizator
Mapați proprietățile utilizatorilor Amplitude la atributele de contact Brevo:
property_mapping: # Amplitude property -> Brevo attribute email: email first_name: FIRSTNAME last_name: LASTNAME phone: SMS plan_type: PLAN signup_date: SIGNUP_DATE total_purchases: ORDER_COUNT lifetime_revenue: LTV last_active: LAST_ACTIVE device_type: DEVICEPuncte finale API
| Metodă | Punct final | Descriere |
|---|---|---|
POST | /2/httpapi | Încarcă evenimente (HTTP V2 API) |
POST | /batch | Încarcă evenimente în bloc (Batch API) |
POST | /identify | Setează proprietățile utilizatorului |
POST | /groupidentify | Setează proprietățile grupului |
GET | /2/export | Exportă date brute de evenimente |
GET | /2/usersearch | Caută utilizatori |
GET | /2/useractivity | Obține cronologia activității utilizatorului |
POST | /api/3/cohort/export | Exportă membrii cohortei |
GET | /api/3/chart/{chart_id}/query | Interoghează datele dintr-un grafic salvat |
Exemple de cod
Inițializare conector Amplitude
import { TajoClient } from '@tajo/sdk';
const tajo = new TajoClient({ apiKey: process.env.TAJO_API_KEY, brevoApiKey: process.env.BREVO_API_KEY});
// Connect Amplitude projectawait tajo.connectors.connect('amplitude', { apiKey: process.env.AMPLITUDE_API_KEY, secretKey: process.env.AMPLITUDE_SECRET_KEY, dataCenter: 'US'});Trimitere evenimente prin HTTP V2 API
// Send events to Amplitude (automatically forwarded to Brevo)const response = await fetch('https://api2.amplitude.com/2/httpapi', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ api_key: process.env.AMPLITUDE_API_KEY, events: [ { user_id: "user_123", event_type: "Purchase", event_properties: { revenue: 89.99, product_id: "SKU-001", product_name: "Widget Pro" }, user_properties: { $set: { plan_type: "premium" } }, time: Date.now() } ] })});
// Expected response: { "code": 200, "events_ingested": 1 }Sincronizare cohortă cu lista Brevo
// Export an Amplitude cohort and sync to Brevoconst cohort = await tajo.connectors.syncCohort('amplitude', { cohortId: 'abc123', targetList: 11, // Brevo list ID syncMode: 'mirror' // mirror, append, or remove});
console.log(cohort);// {// cohortName: "Power Users",// membersCount: 2450,// syncedToBrevo: 2450,// listId: 11// }Limite de rată
| API | Limită | Detalii |
|---|---|---|
| HTTP V2 API | 1.000 evenimente/sec | Per proiect, burst până la 2.000/sec |
| Batch API | 1.000 evenimente/lot | Maxim 20 loturi/sec |
| Identify API | 1.000 cereri/sec | Per proiect |
| Export API | 360 cereri/oră | Per proiect |
| Export cohortă | 1 export concurent | Per cohortă |
| Dashboard REST API | 360 cereri/oră | Per proiect |
Limite dimensiune eveniment
Fiecare payload de eveniment nu poate depăși 1 MB. HTTP V2 API acceptă până la 2.000 evenimente per cerere cu o dimensiune maximă a corpului de 20 MB.
Depanare
| Problemă | Cauză | Soluție |
|---|---|---|
Evenimentele returnează status invalid | Câmpuri obligatorii lipsă | Asigurați-vă că user_id sau device_id este setat pe fiecare eveniment |
| Proprietăți utilizator nesincronizate | Operator de proprietate greșit | Utilizați $set pentru setare, $setOnce pentru valori first-touch |
| Export cohortă gol | Cohortă în calcul | Așteptați finalizarea calculului cohortei înainte de export |
| 429 Too Many Requests | Limită de rată depășită | Implementați backoff exponențial și utilizați batch API |
| Venituri neînregistrate | Câmpuri de venituri lipsă | Includeți price, quantity și revenue în proprietățile evenimentului |
| Datele EU nu sunt rutate | Centru de date greșit | Setați data_center: "EU" și utilizați api.eu.amplitude.com |
Bune practici
- Utilizați HTTP V2 API - Preferați API-ul V2 față de API-ul HTTP moștenire pentru validare mai bună și răspunsuri de eroare
- Grupați evenimentele - Trimiteți evenimente în loturi de până la 1.000 pentru un randament optim
- Setați proprietățile utilizatorului pe evenimente - Includeți
user_propertiespe evenimentele de urmărire pentru a reduce apelurile identify - Utilizați cohortele pentru segmentare - Sincronizați cohortele comportamentale în loc să replicați logica complexă de segmentare
- Urmăriți corect evenimentele de venituri - Utilizați câmpurile
revenue,priceșiproductIdpentru urmărire precisă a veniturilor - Monitorizați sănătatea ingestiei - Verificați Ingestion Debugger-ul Amplitude pentru erori de validare a evenimentelor
- Implementați urmărire pe server - Utilizați SDK-uri de server pentru livrare fiabilă a evenimentelor
Securitate
- Numai HTTPS - Toată comunicarea API necesită TLS 1.2+
- Rotație chei API - Rotiți Cheile secrete periodic prin setările Amplitude
- Allowlisting IP - Disponibil pe planurile Enterprise
- SOC 2 Tip II - Amplitude este certificat SOC 2 Tip II
- GDPR/CCPA - Suport pentru ștergerea și exportul datelor utilizatorilor
- Rezidență date EU - Opțiunea de centru de date EU disponibilă