Коннектор Salesforce

Коннектор Salesforce

Подключите вашу Salesforce CRM к Brevo через Tajo для корпоративной синхронизации контактов, управления лидами, отслеживания возможностей и маркетинговой автоматизации на основе данных CRM.

Обзор

Возможности

• Двусторонняя синхронизация контактов/лидов, синхронизация контактов и лидов Salesforce со списками контактов Brevo
• Отслеживание возможностей, сопоставляйте стадии сделок и суммы для сегментации по выручке
• Иерархия аккаунтов, синхронизируйте компании-аккаунты для account-based маркетинга в Brevo
• Сопоставление кастомных объектов, сопоставляйте кастомные объекты Salesforce с атрибутами и событиями Brevo
• Синхронизация участников кампаний, синхронизируйте участников кампаний Salesforce со списками Brevo
• Отслеживание активности, синхронизируйте задачи, события и email-активности для оценки вовлечённости
• Стриминг в реальном времени, используйте Salesforce Streaming API для мгновенных обновлений данных
• Поддержка SOQL-запросов, фильтруйте синхронизируемые данные кастомными SOQL-запросами

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

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

1. Salesforce org (любой edition с доступом к API)
2. Connected App, настроенное в Salesforce Setup
3. Включённый API-доступ для профиля пользователя Salesforce
4. Аккаунт Brevo с доступом к API
5. Аккаунт Tajo

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

OAuth 2.0 Web Server Flow (рекомендуется)

Лучший вариант для продакшен-интеграций с авторизацией пользователя.

# Step 1: Authorize
https://login.salesforce.com/services/oauth2/authorize?
  response_type=code&
  client_id={consumer_key}&
  redirect_uri={callback_url}

# Step 2: Exchange code for tokens
curl -X POST https://login.salesforce.com/services/oauth2/token \
  -d "grant_type=authorization_code" \
  -d "code={auth_code}" \
  -d "client_id={consumer_key}" \
  -d "client_secret={consumer_secret}" \
  -d "redirect_uri={callback_url}"

Username-Password Flow

Для интеграций server-to-server без участия пользователя.

curl -X POST https://login.salesforce.com/services/oauth2/token \
  -d "grant_type=password" \
  -d "client_id={consumer_key}" \
  -d "client_secret={consumer_secret}" \
  -d "username={username}" \
  -d "password={password}{security_token}"

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

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

connectors:
  salesforce:
    enabled: true
    instance_url: "https://yourorg.my.salesforce.com"
    api_version: "v59.0"
    auth:
      type: oauth2
      consumer_key: "${SF_CONSUMER_KEY}"
      consumer_secret: "${SF_CONSUMER_SECRET}"
      refresh_token: "${SF_REFRESH_TOKEN}"

    # Data sync options
    sync:
      contacts: true
      leads: true
      accounts: true
      opportunities: true
      campaigns: true

    # Sync direction
    direction: salesforce_to_brevo

    # Brevo list assignment
    lists:
      all_leads: 15
      qualified_leads: 16
      customers: 17

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

Сопоставьте поля Salesforce с атрибутами контакта Brevo:

Сопоставление кастомных полей

field_mapping:
  # Standard fields
  Email: email
  FirstName: FIRSTNAME
  LastName: LASTNAME
  Phone: SMS

  # CRM fields
  LeadSource: LEAD_SOURCE
  Lead_Score__c: LEAD_SCORE
  Account.Name: COMPANY_NAME
  Account.Industry: INDUSTRY

  # Opportunity fields
  Amount: DEAL_VALUE
  StageName: DEAL_STAGE
  CloseDate: EXPECTED_CLOSE_DATE

  # Custom fields
  Preferred_Channel__c: PREFERRED_CHANNEL
  Customer_Tier__c: VIP_TIER

Эндпоинты API

Ресурсы REST API

Bulk API

Streaming API

События

События записей (Change Data Capture)

Platform Events

Примеры кода

Инициализация коннектора

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

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

// Connect Salesforce
await tajo.connectors.connect('salesforce', {
  instanceUrl: 'https://yourorg.my.salesforce.com',
  consumerKey: process.env.SF_CONSUMER_KEY,
  consumerSecret: process.env.SF_CONSUMER_SECRET,
  refreshToken: process.env.SF_REFRESH_TOKEN
});

Синхронизация контактов с SOQL-фильтром

// Sync only qualified leads from Salesforce
await tajo.connectors.sync('salesforce', {
  type: 'filtered',
  resources: ['leads'],
  filter: "SELECT Id, Email, FirstName, LastName, LeadScore__c FROM Lead WHERE Status = 'Qualified' AND Email != null",
  brevoListId: 16
});

// Check sync status
const status = await tajo.connectors.status('salesforce');
console.log(status);
// {
//   connected: true,
//   lastSync: '2024-01-15T10:30:00Z',
//   contactsSynced: 18400,
//   leadsSynced: 7200,
//   opportunitiesSynced: 3100
// }

Стриминг в реальном времени

// Subscribe to Salesforce Change Data Capture
await tajo.connectors.stream('salesforce', {
  channels: [
    '/data/ContactChangeEvent',
    '/data/LeadChangeEvent',
    '/data/OpportunityChangeEvent'
  ],
  handler: async (event) => {
    console.log(`Change detected: ${event.entity} ${event.changeType}`);
    // Automatically synced to Brevo by Tajo
  }
});

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

Лимиты REST API Salesforce зависят от вашего edition и количества лицензий:

Дополнительные ограничения:

• Лимит параллельных API-вызовов: 25 долгих запросов
• Bulk API: 15 000 пакетов за 24 часа
• Streaming API: 2 000 событий в день (можно увеличить)
• Composite API: 25 подзапросов на композитный запрос

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

Частые проблемы

Режим отладки

Включите подробное логирование:

connectors:
  salesforce:
    debug: true
    log_level: verbose
    log_api_calls: true

Проверка подключения

tajo connectors test salesforce
# ✓ OAuth token valid
# ✓ Contacts accessible
# ✓ Leads accessible
# ✓ Accounts accessible
# ✓ Opportunities accessible
# ✓ Bulk API enabled

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

1. Используйте Bulk API для крупных синхронизаций, переключайтесь на Bulk API 2.0 для наборов данных свыше 2 000 записей
2. Внедряйте Change Data Capture, используйте CDC для синхронизации в реальном времени вместо опроса
3. Сопоставляйте только нужные поля, снижайте нагрузку на API, синхронизируя только необходимые поля
4. Обрабатывайте обновление токенов, реализуйте автоматическую логику обновления OAuth-токенов
5. Используйте composite-запросы, объединяйте связанные API-вызовы, чтобы уменьшить количество запросов
6. Сначала тестируйте в sandbox, используйте Salesforce sandbox org перед развёртыванием в продакшен

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

• OAuth 2.0, отраслевой стандарт авторизации с несколькими типами grant
• Ограничения по IP, Salesforce поддерживает диапазоны IP для входа и trusted IP
• TLS 1.2+, все API-коммуникации зашифрованы минимум TLS 1.2
• Безопасность на уровне полей, детальный контроль доступа к полям по профилям
• Управление сессиями, настраиваемый таймаут сессии и лимиты параллельных сессий

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

• Документация Salesforce REST API
• Руководство Salesforce Bulk API 2.0
• Коннектор HubSpot
• Навык синхронизации клиентов
• Brevo Contacts API