Conector Airtable

Conectați bazele de date Airtable la Brevo pentru sincronizare CRM, gestionarea catalogului de produse și fluxuri de marketing automatizate bazate pe date structurate prin Tajo.

Prezentare generală

Funcționalități

• Sincronizare tabel-la-listă - Sincronizați înregistrările din tabelele Airtable direct în listele de contacte Brevo
• Punte catalog produse - Utilizați tabelele Airtable ca cataloage de produse pentru recomandări în e-mail
• Sincronizare CRM - Sincronizare bidirecțională între CRM-ul Airtable și contactele Brevo
• Evenimente de trimitere formulare - Transmiteți trimiterile de formulare Airtable ca evenimente Brevo
• Filtrare bazată pe vizualizări - Sincronizați vizualizări specifice Airtable în listele Brevo targetate
• Automatizare webhook - Declanșați campanii Brevo când înregistrările Airtable se modifică

Cerințe preliminare

Înainte de a începe, asigurați-vă că aveți:

1. Un cont Airtable (plan Gratuit sau superior)
2. Un Token de acces personal sau aplicație OAuth configurată
3. Acces la bazele de date și tabelele pe care doriți să le sincronizați
4. Un cont Brevo cu acces API
5. Un cont Tajo cu abonament activ

Autentificare

Airtable suportă Tokeni de acces personal și OAuth 2.0.

Opțiunea 1: Token de acces personal (Recomandat)

1. Accesați airtable.com/create/tokens
2. Faceți clic pe Create new token
3. Denumiți-l “Tajo Integration”
4. Adăugați scopuri:

data.records:read
data.records:write
data.recordComments:read
schema.bases:read
webhook:manage

5. Adăugați acces la baze specifice sau la toate bazele de date
6. Faceți clic pe Create token

Opțiunea 2: OAuth 2.0

Pentru integrări cu mai mulți utilizatori, utilizați fluxul OAuth 2.0:

1. Înregistrați integrarea la airtable.com/create/oauth
2. Configurați URI-ul de redirecționare: https://app.tajo.io/callbacks/airtable
3. Solicitați aceleași scopuri ca mai sus

Conectare la Tajo

tajo connectors install airtable \
  --token $AIRTABLE_TOKEN

Configurare

Configurare de bază

connectors:
  airtable:
    enabled: true

    sync:
      records: true
      comments: false

    tables:
      - base_id: "appXXXXXXXXXXXXXX"
        table_name: "Customers"
        view: "Active Customers"
        sync_to_list: 28
      - base_id: "appXXXXXXXXXXXXXX"
        table_name: "Products"
        sync_as: "catalog"

Mapare câmpuri

Mapați câmpurile Airtable la atributele de contact Brevo:

field_mapping:
  # Airtable field -> Brevo attribute
  Name: FIRSTNAME
  Email: email
  Phone: SMS
  Company: COMPANY
  Status: LEAD_STATUS
  Revenue: TOTAL_REVENUE
  "Last Contact": LAST_CONTACT_DATE
  Tags: TAGS
  Notes: NOTES
  "Created Time": SIGNUP_DATE

Sincronizare bazată pe vizualizări

views:
  - base_id: "appXXXXXXXXXXXXXX"
    table_name: "Customers"
    view: "High Value"
    sync_to_list: 29
    filter_by_view: true

  - base_id: "appXXXXXXXXXXXXXX"
    table_name: "Customers"
    view: "Churned"
    sync_to_list: 30
    filter_by_view: true

Puncte finale API

Tajo se integrează cu următoarele puncte finale ale API-ului web Airtable:

Exemple de cod

Inițializare conector

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

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

await tajo.connectors.connect('airtable', {
  token: process.env.AIRTABLE_TOKEN
});

Sincronizare tabel cu Brevo

// Sync an Airtable table to a Brevo list
await tajo.connectors.sync('airtable', {
  type: 'full',
  resources: ['records'],
  baseId: 'appXXXXXXXXXXXXXX',
  tableName: 'Customers',
  view: 'Active Customers',
  targetList: 28
});

const status = await tajo.connectors.status('airtable');
console.log(status);
// {
//   connected: true,
//   lastSync: '2024-03-15T15:00:00Z',
//   recordsSynced: 2340,
//   tablesMonitored: 2,
//   basesConnected: 1
// }

Gestionare webhook-uri

// Airtable webhooks notify of changes; fetch details with cursor
app.post('/webhooks/airtable', async (req, res) => {
  const { base, webhook, timestamp } = req.body;

  // Fetch changed records using webhook cursor
  const changes = await tajo.connectors.getWebhookPayloads('airtable', {
    baseId: base.id,
    webhookId: webhook.id,
    cursor: timestamp
  });

  for (const change of changes) {
    await tajo.connectors.handleEvent('airtable', {
      type: change.actionType,
      payload: change
    });
  }

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

Creare înregistrare din Brevo

// Create an Airtable record when a Brevo contact converts
tajo.events.on('contact.attribute_updated', async (event) => {
  if (event.attribute === 'LIFECYCLE_STAGE' && event.value === 'customer') {
    await tajo.connectors.create('airtable', {
      baseId: 'appXXXXXXXXXXXXXX',
      tableName: 'Customers',
      fields: {
        Name: event.contact.name,
        Email: event.contact.email,
        Status: 'Customer',
        'Converted Date': new Date().toISOString().split('T')[0]
      }
    });
  }
});

Limite de rată

Airtable aplică limite de rată per bază de date:

Depanare

Probleme frecvente

Modul de depanare

connectors:
  airtable:
    debug: true
    log_level: verbose
    log_api_calls: true

Testare conexiune

tajo connectors test airtable
# ✓ API authentication successful
# ✓ Base access verified
# ✓ Table schema readable
# ✓ Record listing operational
# ✓ Webhook registration available

Bune practici

1. Limitați tokenii la baze specifice - Nu acordați acces la toate bazele dacă nu este necesar
2. Utilizați vizualizări pentru sincronizare filtrată - Sincronizați vizualizări specifice în loc de tabele complete pentru a reduce volumul de date
3. Grupați operațiile pe înregistrări - Grupați creările și actualizările în loturi de 10
4. Gestionați paginarea - Airtable returnează 100 înregistrări per pagină; iterați cu offset
5. Utilizați webhook-uri pentru timp real - Înregistrați webhook-uri în loc de interogare pentru modificări
6. Mapați tipurile de câmpuri cu precizie - Potriviți tipurile de câmpuri Airtable (select, number, date) cu tipurile de atribute Brevo

Securitate

• Tokeni de acces personal - Limitați la baze și operații specifice
• OAuth 2.0 - Flux de autorizare securizat cu tokeni de reîmprospătare
• Numai HTTPS - Toată comunicarea API criptată prin TLS 1.2+
• Control acces la nivel de bază - Tokeni limitați la baze individuale
• Stocare criptată - Tokenii sunt criptați în repaus în Tajo
• Verificare HMAC webhook - Verificați autenticitatea notificărilor webhook

Resurse conexe

• Conector Notion
• Conector GitHub
• Skill Sincronizare clienți
• API Contacte Brevo