Конектор Amplitude

Свържете Amplitude с Brevo чрез Tajo, за да използвате данните от продуктовата аналитика за маркетингова автоматизация. Синхронизирайте поведенчески кохорти, потребителски свойства и продуктови събития, за да задвижвате насочени кампании.

Преглед

СвойствоСтойност
ПлатформаAmplitude
КатегорияAnalytics (Персонализирана)
Сложност на настройкаСредна
Официална интеграцияНе
Синхронизирани данниСъбития, потребители, кохорти, свойства
Налични умения6

Функции

  • Препращане на събития – Изпращайте track събития от Amplitude към Brevo за тригери на маркетингова автоматизация
  • Синхронизация на кохорти – Експортирайте поведенчески кохорти от Amplitude като списъци с контакти в Brevo
  • Синхронизация на потребителски свойства – Мапвайте потребителски свойства от Amplitude към атрибути на контактите в Brevo
  • Проследяване на приходи – Синхронизирайте събития за приходи за анализ на жизнената стойност на клиента
  • Поведенческа сегментация – Използвайте данни за ангажираност от Amplitude в сегменти на Brevo
  • Интеграция с HTTP V2 API – Директна интеграция с ingestion API на Amplitude HTTP V2

Предварителни условия

Преди да започнете, уверете се, че имате:

  1. Акаунт в Amplitude със създаден проект
  2. Вашия Amplitude API Key и Secret Key
  3. Акаунт в Brevo с API достъп
  4. Акаунт в Tajo с API идентификационни данни

Автентикация

Amplitude API ключове

Amplitude използва двойки от API Key и Secret Key за автентикация. API Key идентифицира вашия проект, докато Secret Key автентицира server-side заявки.

Terminal window
# Find your keys in Amplitude:
# Settings > Projects > [Your Project] > General

Автентикация за HTTP V2 API

HTTP V2 API използва API ключа в тялото на заявката:

Terminal window
curl -X POST https://api2.amplitude.com/2/httpapi \
-H "Content-Type: application/json" \
-d '{
"api_key": "YOUR_AMPLITUDE_API_KEY",
"events": [...]
}'

Конфигурация

Основна настройка

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: 12

Мапване на събития

Мапвайте събития от Amplitude към тригери за автоматизация в 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"

Мапване на потребителски свойства

Мапвайте потребителски свойства от Amplitude към атрибути на контактите в 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: DEVICE

API крайни точки

MethodEndpointОписание
POST/2/httpapiКачване на събития (HTTP V2 API)
POST/batchГрупово качване на събития (Batch API)
POST/identifyЗадаване на потребителски свойства
POST/groupidentifyЗадаване на групови свойства
GET/2/exportЕкспорт на сурови данни от събития
GET/2/usersearchТърсене на потребители
GET/2/useractivityПолучаване на времева линия на активността на потребител
POST/api/3/cohort/exportЕкспорт на членове на кохорта
GET/api/3/chart/{chart_id}/queryЗаявка за данни на запазена диаграма

Примери за код

Инициализация на конектора Amplitude

import { TajoClient } from '@tajo/sdk';
const tajo = new TajoClient({
apiKey: process.env.TAJO_API_KEY,
brevoApiKey: process.env.BREVO_API_KEY
});
// Connect Amplitude project
await tajo.connectors.connect('amplitude', {
apiKey: process.env.AMPLITUDE_API_KEY,
secretKey: process.env.AMPLITUDE_SECRET_KEY,
dataCenter: 'US'
});

Изпращане на събития чрез 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 }

Синхронизация на кохорта към списък в Brevo

// Export an Amplitude cohort and sync to Brevo
const 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
// }

Лимити на заявки

APIЛимитДетайли
HTTP V2 API1000 събития/секЗа проект, при пик до 2000/сек
Batch API1000 събития/batchМаксимум 20 batch/сек
Identify API1000 заявки/секЗа проект
Export API360 заявки/часЗа проект
Cohort Export1 конкурентен експортЗа кохорта
Dashboard REST API360 заявки/часЗа проект

Лимити на размера на събитията

Всеки payload на събитие не може да надвишава 1 MB. HTTP V2 API приема до 2000 събития на заявка с максимален размер на тялото 20 MB.

Отстраняване на проблеми

ПроблемПричинаРешение
Събития връщат статус invalidЛипсващи задължителни полетаУверете се, че user_id или device_id е зададен за всяко събитие
Потребителските свойства не се синхронизиратГрешен оператор за свойствотоИзползвайте $set за задаване, $setOnce за стойности при първо докосване
Експортът на кохорта е празенКохортата все още се изчисляваИзчакайте изчисляването на кохортата да приключи преди експорт
429 Too Many RequestsНадвишен лимит на заявкитеПриложете експоненциално отлагане и използвайте batch API
Приходите не се проследяватЛипсващи полета за приходиВключете price, quantity и revenue в свойствата на събитието
ЕС данните не се маршрутизиратГрешен център за данниЗадайте data_center: "EU" и използвайте api.eu.amplitude.com

Най-добри практики

  1. Използвайте HTTP V2 API – Предпочитайте V2 API пред наследеното HTTP API за по-добра валидация и грешки
  2. Групирайте събитията – Изпращайте събитията на групи до 1000 за оптимален throughput
  3. Задавайте потребителски свойства на събитията – Включвайте user_properties в track събитията, за да намалите identify повикванията
  4. Използвайте кохорти за сегментация – Синхронизирайте поведенчески кохорти, вместо да репликирате сложна сегментационна логика
  5. Проследявайте събитията за приходи правилно – Използвайте полетата revenue, price и productId за точно проследяване на приходите
  6. Наблюдавайте здравето на ingestion – Проверявайте Ingestion Debugger на Amplitude за грешки при валидация на събития
  7. Имплементирайте server-side проследяване – Използвайте server-side SDK за надеждна доставка на събития

Сигурност

  • Само HTTPS – Цялата API комуникация изисква TLS 1.2+
  • Ротация на API ключове – Периодично ротирайте Secret Keys чрез настройките на Amplitude
  • Allow-list на IP – Налично в Enterprise планове
  • SOC 2 Type II – Amplitude е сертифициран по SOC 2 Type II
  • GDPR/CCPA – Поддръжка за заявки за изтриване и експорт на потребителски данни
  • ЕС резидентност на данни – Налична опция за център за данни в ЕС

Свързани ресурси

Subscribe to updates

developer-docs

Drop your email or phone number — we'll send you what matters next.

auto-detect
AI асистент

Здравейте! Попитайте ме за документацията.