Pipedrive Connector

Pipedrive Connector

เชื่อมต่อ Pipedrive กับ Brevo ผ่าน Tajo เพื่อเชื่อมไปป์ไลน์การขายกับระบบอัตโนมัติทางการตลาด ซิงค์ผู้ติดต่อ ดีล องค์กร และกิจกรรมเพื่อขับเคลื่อนแคมเปญวงจรชีวิตที่ทริกเกอร์โดยการเปลี่ยนแปลงขั้นตอน CRM

ภาพรวม

ฟีเจอร์

• การซิงค์ผู้ติดต่อ - การซิงค์บุคคล Pipedrive กับผู้ติดต่อ Brevo แบบสองทิศทาง
• การติดตามขั้นตอนดีล - ทริกเกอร์ระบบอัตโนมัติ Brevo ตามการเปลี่ยนแปลงขั้นตอนไปป์ไลน์ดีล
• การซิงค์องค์กร - แมปองค์กร Pipedrive กับแอตทริบิวต์บริษัท Brevo
• การติดตามกิจกรรม - ส่งต่อกิจกรรม Pipedrive (การโทร อีเมล การประชุม) เป็นเหตุการณ์ Brevo
• ฟิลด์แบบกำหนดเอง - แมปฟิลด์แบบกำหนดเองของ Pipedrive กับแอตทริบิวต์ผู้ติดต่อ Brevo
• รายงานไปป์ไลน์ - ดึงข้อมูลไปป์ไลน์ดีลสำหรับการระบุแหล่งที่มาทางการตลาด
• การซิงค์ลีด - นำเข้าลีด Pipedrive ใน Brevo สำหรับแคมเปญบ่มเพาะ
• ระบบอัตโนมัติ Webhook - การอัปเดตแบบเรียลไทม์ผ่าน Pipedrive webhooks

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

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

1. บัญชี Pipedrive ที่มีสิทธิ์ผู้ดูแลระบบ
2. Pipedrive API Token (พบได้ใน Settings > Personal preferences > API)
3. สำหรับ OAuth apps: Pipedrive app ที่ลงทะเบียนพร้อม Client ID และ Client Secret
4. บัญชี Brevo ที่มีสิทธิ์เข้าถึง API
5. บัญชี Tajo ที่มีข้อมูลรับรอง API

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

API Token

วิธีการยืนยันตัวตนที่ง่ายที่สุด ค้นหา API Token ของคุณใน Pipedrive ที่ Settings > Personal preferences > API

curl "https://api.pipedrive.com/v1/persons?api_token=YOUR_API_TOKEN"

OAuth 2.0 (แนะนำสำหรับ Apps)

สำหรับแอปพลิเคชันในการผลิต ใช้ OAuth 2.0:

# Authorization URL
https://oauth.pipedrive.com/oauth/authorize?client_id=CLIENT_ID&redirect_uri=REDIRECT_URI

# Token exchange
curl -X POST https://oauth.pipedrive.com/oauth/token \
  -d "grant_type=authorization_code" \
  -d "code=AUTH_CODE" \
  -d "redirect_uri=REDIRECT_URI" \
  -u "CLIENT_ID:CLIENT_SECRET"

หลังจากได้รับ access token:

curl "https://api.pipedrive.com/v1/persons" \
  -H "Authorization: Bearer ACCESS_TOKEN"

การกำหนดค่า

การตั้งค่าพื้นฐาน

connectors:
  pipedrive:
    enabled: true
    api_token: "your-pipedrive-api-token"
    company_domain: "yourcompany"  # yourcompany.pipedrive.com

    # Data sync options
    sync:
      persons: true
      deals: true
      organizations: true
      activities: true
      leads: true

    # Brevo list assignment
    lists:
      all_contacts: 60
      qualified_leads: 61
      customers: 62
      churned: 63

การแมปฟิลด์บุคคล

แมปฟิลด์บุคคล Pipedrive กับแอตทริบิวต์ผู้ติดต่อ Brevo:

person_mapping:
  email: email
  name: FULLNAME
  first_name: FIRSTNAME
  last_name: LASTNAME
  phone: SMS
  org_id.name: COMPANY

  # Deal-related computed fields
  won_deals_count: WON_DEALS
  lost_deals_count: LOST_DEALS
  open_deals_count: OPEN_DEALS
  closed_deals_count: CLOSED_DEALS
  total_revenue: LTV

  # Custom fields (use Pipedrive field key)
  custom_fields.lead_source: LEAD_SOURCE
  custom_fields.industry: INDUSTRY
  custom_fields.company_size: COMPANY_SIZE

การแมปขั้นตอนดีล

แมปขั้นตอนไปป์ไลน์ Pipedrive กับการกำหนดรายการ Brevo:

deal_stage_mapping:
  # stage_id -> brevo_list_id
  1: 61   # Lead In
  2: 61   # Contact Made
  3: 62   # Proposal Made
  4: 62   # Negotiations Started
  "won": 63   # Won -> Customers list
  "lost": 64   # Lost -> Win-back list

การกำหนดค่า Webhook

webhooks:
  - event_action: "added"
    event_object: "person"
    brevo_event: "contact_created"
  - event_action: "updated"
    event_object: "person"
    brevo_event: "contact_updated"
  - event_action: "added"
    event_object: "deal"
    brevo_event: "deal_created"
  - event_action: "updated"
    event_object: "deal"
    brevo_event: "deal_updated"
  - event_action: "merged"
    event_object: "person"
    brevo_event: "contact_merged"
  - event_action: "added"
    event_object: "activity"
    brevo_event: "activity_logged"

API Endpoints

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

เริ่มต้น Pipedrive Connector

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

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

// Connect Pipedrive account
await tajo.connectors.connect('pipedrive', {
  apiToken: process.env.PIPEDRIVE_API_TOKEN,
  companyDomain: 'yourcompany'
});

ซิงค์บุคคลกับ Brevo

// Fetch persons from Pipedrive
const response = await fetch(
  `https://api.pipedrive.com/v1/persons?start=0&limit=100&api_token=${API_TOKEN}`
);

const { data, additional_data } = await response.json();
// data: [{ id, name, first_name, last_name, email, phone, org_id, ... }]
// additional_data.pagination: { start, limit, more_items_in_collection }

ติดตามการเปลี่ยนแปลงขั้นตอนดีล

// Webhook handler for deal updates
app.post('/webhooks/pipedrive', async (req, res) => {
  const { meta, current, previous } = req.body;

  if (meta.object === 'deal' && meta.action === 'updated') {
    // Detect stage change
    if (current.stage_id !== previous.stage_id) {
      await tajo.connectors.handleWebhook('pipedrive', {
        topic: 'deal.stage_changed',
        payload: {
          dealId: current.id,
          dealTitle: current.title,
          previousStage: previous.stage_id,
          newStage: current.stage_id,
          personId: current.person_id,
          value: current.value,
          currency: current.currency
        }
      });
    }
  }

  res.status(200).send('OK');
});

ค้นหาทั่ว Pipedrive

// Global search across persons, deals, and organizations
const query = encodeURIComponent('[email protected]');
const response = await fetch(
  `https://api.pipedrive.com/v1/itemSearch?term=${query}&item_types=person,deal&api_token=${API_TOKEN}`
);

const { data } = await response.json();
// Returns matching persons, deals, and organizations

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

ขีดจำกัดเพิ่มเติม:

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

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

1. ใช้ OAuth สำหรับการผลิต - ใช้ OAuth 2.0 แทน API tokens สำหรับแอปพลิเคชันในการผลิต
2. ติดตามการเปลี่ยนแปลงขั้นตอนดีล - ใช้ webhooks เพื่อทริกเกอร์ระบบอัตโนมัติ Brevo ในการเปลี่ยนผ่านขั้นตอนไปป์ไลน์
3. แมปฟิลด์แบบกำหนดเอง - ใช้คีย์ฟิลด์แบบกำหนดเองของ Pipedrive (ไม่ใช่ชื่อ) สำหรับการแมปฟิลด์ที่เชื่อถือได้
4. จัดการ pagination - ใช้พารามิเตอร์ start และ limit ตรวจสอบ more_items_in_collection
5. ใช้ Recents endpoint - Poll /v1/recents สำหรับการซิงค์แบบเพิ่มทีละน้อยแทนการส่งออกแบบเต็ม
6. ลบรายการซ้ำก่อนซิงค์ - รวมบุคคลที่ซ้ำกันใน Pipedrive ก่อนซิงค์กับ Brevo
7. ใช้บัญชี sandbox - สร้างบัญชี sandbox สำหรับนักพัฒนาสำหรับการทดสอบการผสานรวม

ความปลอดภัย

• การยืนยันตัวตนด้วย API token - การเข้าถึงตาม token แบบง่ายสำหรับการใช้งานส่วนตัว
• OAuth 2.0 - การเข้าถึงที่ได้รับมอบอำนาจอย่างปลอดภัยสำหรับแอปพลิเคชันบุคคลที่สาม
• HTTPS เท่านั้น - การสื่อสาร API ทั้งหมดต้องการการเข้ารหัส TLS
• Webhook HTTPS - Webhooks ส่งมอบให้กับ endpoints HTTPS เท่านั้น
• การเข้าถึงตามบทบาท - สิทธิ์ Pipedrive เคารพบทบาทผู้ใช้
• รับรอง SOC 2 - Pipedrive รักษาการปฏิบัติตาม SOC 2
• การปฏิบัติตาม GDPR - รองรับคำขอส่งออกและลบข้อมูล

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

• Brevo Connector
• Shopify Connector
• Customer Sync Skill
• Brevo Contacts API