Конектор Amplitude
Свържете Amplitude с Brevo чрез Tajo, за да използвате данните от продуктовата аналитика за маркетингова автоматизация. Синхронизирайте поведенчески кохорти, потребителски свойства и продуктови събития, за да задвижвате насочени кампании.
Преглед
| Свойство | Стойност |
|---|---|
| Платформа | Amplitude |
| Категория | Analytics (Персонализирана) |
| Сложност на настройка | Средна |
| Официална интеграция | Не |
| Синхронизирани данни | Събития, потребители, кохорти, свойства |
| Налични умения | 6 |
Функции
- Препращане на събития – Изпращайте track събития от Amplitude към Brevo за тригери на маркетингова автоматизация
- Синхронизация на кохорти – Експортирайте поведенчески кохорти от Amplitude като списъци с контакти в Brevo
- Синхронизация на потребителски свойства – Мапвайте потребителски свойства от Amplitude към атрибути на контактите в Brevo
- Проследяване на приходи – Синхронизирайте събития за приходи за анализ на жизнената стойност на клиента
- Поведенческа сегментация – Използвайте данни за ангажираност от Amplitude в сегменти на Brevo
- Интеграция с HTTP V2 API – Директна интеграция с ingestion API на Amplitude HTTP V2
Предварителни условия
Преди да започнете, уверете се, че имате:
- Акаунт в Amplitude със създаден проект
- Вашия Amplitude API Key и Secret Key
- Акаунт в Brevo с API достъп
- Акаунт в Tajo с API идентификационни данни
Автентикация
Amplitude API ключове
Amplitude използва двойки от API Key и Secret Key за автентикация. API Key идентифицира вашия проект, докато Secret Key автентицира server-side заявки.
# Find your keys in Amplitude:# Settings > Projects > [Your Project] > GeneralАвтентикация за HTTP V2 API
HTTP V2 API използва API ключа в тялото на заявката:
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: DEVICEAPI крайни точки
| Method | Endpoint | Описание |
|---|---|---|
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 projectawait 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 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// }Лимити на заявки
| API | Лимит | Детайли |
|---|---|---|
| HTTP V2 API | 1000 събития/сек | За проект, при пик до 2000/сек |
| Batch API | 1000 събития/batch | Максимум 20 batch/сек |
| Identify API | 1000 заявки/сек | За проект |
| Export API | 360 заявки/час | За проект |
| Cohort Export | 1 конкурентен експорт | За кохорта |
| Dashboard REST API | 360 заявки/час | За проект |
Лимити на размера на събитията
Всеки 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 |
Най-добри практики
- Използвайте HTTP V2 API – Предпочитайте V2 API пред наследеното HTTP API за по-добра валидация и грешки
- Групирайте събитията – Изпращайте събитията на групи до 1000 за оптимален throughput
- Задавайте потребителски свойства на събитията – Включвайте
user_propertiesв track събитията, за да намалите identify повикванията - Използвайте кохорти за сегментация – Синхронизирайте поведенчески кохорти, вместо да репликирате сложна сегментационна логика
- Проследявайте събитията за приходи правилно – Използвайте полетата
revenue,priceиproductIdза точно проследяване на приходите - Наблюдавайте здравето на ingestion – Проверявайте Ingestion Debugger на Amplitude за грешки при валидация на събития
- Имплементирайте 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 – Поддръжка за заявки за изтриване и експорт на потребителски данни
- ЕС резидентност на данни – Налична опция за център за данни в ЕС