Amplitude Connector

เชื่อมต่อ Amplitude กับ Brevo ผ่าน Tajo เพื่อใช้ประโยชน์จากข้อมูล product analytics สำหรับระบบอัตโนมัติทางการตลาด ซิงค์ behavioral cohorts คุณสมบัติผู้ใช้ และเหตุการณ์ผลิตภัณฑ์เพื่อขับเคลื่อนแคมเปญที่กำหนดเป้าหมาย

ภาพรวม

ฟีเจอร์

• การส่งต่อเหตุการณ์ - ส่งเหตุการณ์ track ของ Amplitude ไปยัง Brevo สำหรับทริกเกอร์ระบบอัตโนมัติทางการตลาด
• การซิงค์ cohort - ส่งออก behavioral cohorts ของ Amplitude เป็นรายการผู้ติดต่อ Brevo
• การซิงค์คุณสมบัติผู้ใช้ - แมปคุณสมบัติผู้ใช้ Amplitude กับแอตทริบิวต์ผู้ติดต่อ Brevo
• การติดตามรายได้ - ซิงค์เหตุการณ์รายได้สำหรับการวิเคราะห์มูลค่าตลอดอายุลูกค้า
• การแบ่งกลุ่มตามพฤติกรรม - ใช้ข้อมูลการมีส่วนร่วม Amplitude ใน Brevo segments
• การผสานรวม HTTP V2 API - การผสานรวมโดยตรงกับ HTTP V2 ingestion API ของ Amplitude

ข้อกำหนดเบื้องต้น

ก่อนเริ่มต้น ตรวจสอบให้แน่ใจว่าคุณมี:

1. บัญชี Amplitude ที่มีโปรเจกต์ที่สร้างแล้ว
2. Amplitude API Key และ Secret Key ของคุณ
3. บัญชี Brevo ที่มีสิทธิ์เข้าถึง API
4. บัญชี Tajo ที่มีข้อมูลรับรอง API

การยืนยันตัวตน

Amplitude API Keys

Amplitude ใช้คู่ API Key และ Secret Key สำหรับการยืนยันตัวตน API Key ระบุโปรเจกต์ของคุณ ในขณะที่ Secret Key ยืนยันคำขอฝั่งเซิร์ฟเวอร์

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

การยืนยันตัวตน HTTP V2 API

HTTP V2 API ใช้ API key ในเนื้อหาคำขอ:

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 Endpoints

ตัวอย่างโค้ด

เริ่มต้น Amplitude Connector

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: {
            email: "[email protected]",
            plan_type: "premium"
          }
        },
        time: Date.now()
      }
    ]
  })
});

// Expected response: { "code": 200, "events_ingested": 1 }

ซิงค์ Cohort กับรายการ 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
// }

ขีดจำกัดอัตรา

การแก้ไขปัญหา

แนวทางปฏิบัติที่ดีที่สุด

1. ใช้ HTTP V2 API - ใช้ V2 API แทน legacy HTTP API สำหรับการตรวจสอบและการตอบสนองข้อผิดพลาดที่ดีกว่า
2. Batch เหตุการณ์ - ส่งเหตุการณ์ในกลุ่มละสูงสุด 1,000 เพื่อปริมาณงานที่เหมาะสม
3. ตั้งค่าคุณสมบัติผู้ใช้บนเหตุการณ์ - รวม user_properties บน track events เพื่อลดการเรียก identify
4. ใช้ cohorts สำหรับการแบ่งกลุ่ม - ซิงค์ behavioral cohorts แทนที่จะทำซ้ำตรรกะการแบ่งกลุ่มที่ซับซ้อน
5. ติดตามเหตุการณ์รายได้อย่างถูกต้อง - ใช้ฟิลด์ revenue, price และ productId สำหรับการติดตามรายได้ที่แม่นยำ
6. ตรวจสอบสุขภาพ ingestion - ตรวจสอบ Ingestion Debugger ของ Amplitude สำหรับข้อผิดพลาดการตรวจสอบเหตุการณ์
7. ใช้การติดตามฝั่งเซิร์ฟเวอร์ - ใช้ server-side SDKs สำหรับการส่งเหตุการณ์ที่เชื่อถือได้

ความปลอดภัย

• HTTPS เท่านั้น - การสื่อสาร API ทั้งหมดต้องการ TLS 1.2+
• การหมุนเวียน API key - หมุนเวียน Secret Keys เป็นระยะผ่านการตั้งค่า Amplitude
• IP allowlisting - มีในแผน Enterprise
• SOC 2 Type II - Amplitude ได้รับการรับรอง SOC 2 Type II
• GDPR/CCPA - รองรับการลบและส่งออกข้อมูลผู้ใช้
• EU data residency - มีตัวเลือก EU data center

แหล่งข้อมูลที่เกี่ยวข้อง

• Segment Connector
• Mixpanel Connector
• Customer Sync Skill
• Brevo Events API