Twilio Segment 커넥터

// Write Key로 Analytics.js 초기화
analytics.load("YOUR_SEGMENT_WRITE_KEY");

connectors:
  segment:
    enabled: true
    write_key: "your-segment-write-key"
    data_region: "us"  # 또는 EU 워크스페이스의 경우 "eu"

    # 데이터 동기화 옵션
    sync:
      identify: true
      track: true
      page: true
      group: false

    # Brevo 목록 할당
    lists:
      all_contacts: 5
      active_users: 6
      high_value: 7

event_mapping:
  # Segment 이벤트 -> Brevo 이벤트
  "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"

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

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'
});

// 사용자 식별 - 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"
});

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();