Коннектор Twilio Segment

Подключите Twilio Segment к Brevo через Tajo, чтобы объединить пайплайн данных о клиентах, маршрутизировать события из любого источника в Brevo и использовать разрешение идентичностей Segment для более богатой маркетинговой автоматизации.

Обзор

Возможности

• Универсальный сбор данных, сбор событий с сайтов, мобильных приложений и серверов через SDK Segment
• Маршрутизация источников, маршрутизация данных из 400+ источников в Brevo через Tajo
• Разрешение идентичностей, автоматическое объединение анонимных и известных профилей пользователей
• Синхронизация аудиторий, отправка вычисленных трейтов и аудиторий Segment в листы Brevo
• Стриминг событий, пересылка событий в реальном времени через Connections-фреймворк Segment
• Reverse ETL, синхронизация данных хранилища обратно в Brevo с помощью Segment Reverse ETL
• Соблюдение схемы, валидация схем событий через Segment Protocols перед синхронизацией

Предварительные требования

Прежде чем начать, убедитесь, что у вас есть:

1. Рабочее пространство Twilio Segment с настроенным источником
2. Write Key источника Segment
3. Аккаунт Brevo с доступом к API
4. Аккаунт Tajo с API-учётными данными

Аутентификация

Write Key Segment

Segment аутентифицирует источники с помощью Write Key, уникального идентификатора, привязанного к каждому источнику.

// Инициализация Analytics.js с Write Key
analytics.load("YOUR_SEGMENT_WRITE_KEY");

Tajo API Token

Настройте коннектор Tajo с вашими учётными данными:

tajo connectors install segment \
  --write-key $SEGMENT_WRITE_KEY \
  --workspace-slug your-workspace \
  --brevo-api-key $BREVO_API_KEY

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

Базовая настройка

connectors:
  segment:
    enabled: true
    write_key: "your-segment-write-key"
    data_region: "us"  # или "eu" для рабочего пространства ЕС

    # Параметры синхронизации данных
    sync:
      identify: true
      track: true
      page: true
      group: false

    # Назначение листов Brevo
    lists:
      all_contacts: 5
      active_users: 6
      high_value: 7

Сопоставление событий

Сопоставьте track-события Segment с типами событий Brevo:

event_mapping:
  # Segment event -> Brevo event
  "Order Completed": "order_completed"
  "Product Viewed": "product_viewed"
  "Cart Updated": "cart_updated"
  "Signed Up": "customer_created"
  "Checkout Started": "checkout_started"

  # Пользовательские события
  "Feature Used": "feature_used"
  "Plan Upgraded": "plan_upgraded"

Сопоставление трейтов

Сопоставьте identify-трейты Segment с атрибутами контактов Brevo:

trait_mapping:
  email: email
  firstName: FIRSTNAME
  lastName: LASTNAME
  phone: SMS
  plan: PLAN_TYPE
  company: COMPANY
  createdAt: SIGNUP_DATE
  lifetimeValue: LTV

Эндпоинты API

Примеры кода

Инициализация Segment с назначением Tajo

import { TajoClient } from '@tajo/sdk';

const tajo = new TajoClient({
  apiKey: process.env.TAJO_API_KEY,
  brevoApiKey: process.env.BREVO_API_KEY
});

// Подключение источника Segment
await tajo.connectors.connect('segment', {
  writeKey: process.env.SEGMENT_WRITE_KEY,
  workspaceSlug: 'your-workspace'
});

Трекинг событий через Segment

// Идентификация пользователя, синхронизируется с контактами Brevo
analytics.identify("user_123", {
  email: "[email protected]",
  firstName: "Jane",
  lastName: "Kim",
  plan: "premium",
  lifetimeValue: 450.00
});

// Трекинг события, пересылается в Brevo
analytics.track("Order Completed", {
  orderId: "ORD-1234",
  revenue: 89.99,
  currency: "USD",
  products: [
    { id: "SKU-001", name: "Widget", price: 89.99 }
  ]
});

// Трекинг просмотров страниц
analytics.page("Pricing", {
  title: "Pricing - Tajo",
  url: "https://tajo.io/pricing"
});

Серверная пересылка событий (Node.js)

const Analytics = require('analytics-node');
const analytics = new Analytics(process.env.SEGMENT_WRITE_KEY);

// Пакетная идентификация пользователей из базы данных
const users = await db.query('SELECT * FROM users WHERE updated_at > $1', [lastSync]);

for (const user of users) {
  analytics.identify({
    userId: user.id,
    traits: {
      email: user.email,
      firstName: user.first_name,
      lastName: user.last_name,
      totalOrders: user.order_count,
      lifetimeValue: user.ltv
    }
  });
}

// Сброс очереди
await analytics.flush();

Ограничения скорости

Устранение неполадок

Лучшие практики

1. Вызывайте identify перед track, всегда вызывайте identify до track, чтобы события атрибутировались правильному пользователю
2. Внедрите план отслеживания, используйте Segment Protocols для соблюдения схем событий
3. Группируйте серверные вызовы, используйте batch API для серверных интеграций для снижения HTTP-нагрузки
4. Явно сопоставляйте трейты, определяйте сопоставления трейт-атрибут, не полагаясь на значения по умолчанию
5. Используйте Segment Functions, преобразовывайте события “на лету” перед отправкой в Brevo
6. Следите за доставкой событий, проверяйте дашборд Event Delivery в Segment для выявления неудачных событий
7. Настройте Replay, включите Segment Replay для повторной обработки исторических событий

Безопасность

• TLS-шифрование, все данные передаются через HTTPS/TLS 1.2+
• Изоляция Write Key, каждый источник имеет собственный Write Key
• Соответствие GDPR, Segment поддерживает запросы на удаление и подавление данных
• SOC 2 Type II, Segment сертифицирован по SOC 2 Type II
• Региональное хранение данных, опция рабочего пространства ЕС для соответствия требованиям резидентности данных

Связанные ресурсы

• Коннектор Amplitude
• Коннектор Mixpanel
• Скилл синхронизации клиентов
• Brevo Events API