Konektor Supabase

Propojte svůj projekt Supabase pro synchronizaci databázových záznamů, dat ověřování uživatelů, událostí úložiště souborů a změn v reálném čase pro automatizaci zapojení zákazníků.

Přehled

Funkce

• Automaticky generované REST API – CRUD operace na libovolné tabulce Postgres přes PostgREST, bez kódu
• Synchronizace uživatelů Auth – Synchronizujte uživatele Supabase Auth (e-mail, telefon, sociální přihlášení) do vaší platformy zapojení
• Odběry v reálném čase – Naslouchejte událostem INSERT, UPDATE, DELETE na libovolné tabulce v reálném čase
• Row Level Security – Veškerý přístup API respektuje politiky Postgres RLS pro bezpečná multi-tenantní data
• Integrace úložiště – Sledujte nahrávání souborů a spravujte prostředky napříč buckety Storage
• Edge Functions – Vyvolávejte serverless Deno funkce pro vlastní logiku a webhooky
• Fulltextové vyhledávání – Využívejte možnosti fulltextového vyhledávání Postgres přes API

Předpoklady

Než začnete, ujistěte se, že máte:

1. Projekt Supabase (app.supabase.com)
2. API URL a API klíče projektu (nalezené v Settings → API)
3. Účet Tajo s přístupem k API

Ověření

Supabase používá ověřování API klíčem. Každý požadavek vyžaduje hlavičku apikey a volitelně bearer token Authorization pro přístup v rozsahu uživatele.

# Použití anonymního klíče (respektuje RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_ANON_KEY>" \
  -H "Authorization: Bearer <SUPABASE_ANON_KEY>"

# Použití klíče service_role (obchází RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_SERVICE_ROLE_KEY>" \
  -H "Authorization: Bearer <SUPABASE_SERVICE_ROLE_KEY>"

Konfigurace

Základní nastavení

connectors:
  supabase:
    enabled: true
    project_url: "https://xyzcompany.supabase.co"
    api_key: "${SUPABASE_SERVICE_ROLE_KEY}"

    # Možnosti synchronizace dat
    sync:
      users: true
      tables:
        - customers
        - orders
        - products
      storage: true
      realtime: true

    # Mapování uživatelů Auth Supabase na kontakty
    user_mapping:
      email: email
      phone: SMS
      user_metadata.full_name: FIRSTNAME
      created_at: SIGNUP_DATE

Mapování polí

Mapujte sloupce tabulky Supabase na atributy platformy zapojení:

Mapování vlastní tabulky

table_mapping:
  customers:
    # Mapování sloupec → atribut
    email: email
    full_name: FIRSTNAME
    company: COMPANY
    plan: SUBSCRIPTION_PLAN
    mrr: MONTHLY_REVENUE
    created_at: SIGNUP_DATE

  orders:
    # Sledovat jako události
    sync_as: events
    event_name: "order_placed"
    properties:
      total: amount
      status: order_status
      items: line_items

Koncové body API

REST API Supabase je automaticky generováno ze schématu databáze na adrese https://<ref>.supabase.co/rest/v1/.

Operátory filtrování

Události

Události Auth

Události databáze (Realtime)

Webhookové události

Příklady kódu

Inicializace konektoru

import { TajoClient } from '@tajo/sdk';
import { createClient } from '@supabase/supabase-js';

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

// Připojení projektu Supabase
await tajo.connectors.connect('supabase', {
  projectUrl: process.env.SUPABASE_URL,
  serviceRoleKey: process.env.SUPABASE_SERVICE_ROLE_KEY,
});

Synchronizace uživatelů do kontaktů

// Synchronizace všech uživatelů Supabase Auth jako kontaktů
await tajo.connectors.sync('supabase', {
  type: 'full',
  resources: ['users'],
});

// Přírůstková synchronizace (pouze noví/změnění uživatelé)
await tajo.connectors.sync('supabase', {
  type: 'incremental',
  resources: ['users'],
  since: '2024-01-01T00:00:00Z',
});

Naslouchání změnám v reálném čase

// Přihlášení k odběru nových objednávek pro spouštěče zapojení
const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_ROLE_KEY
);

supabase
  .channel('orders')
  .on('postgres_changes',
    { event: 'INSERT', schema: 'public', table: 'orders' },
    async (payload) => {
      // Přepošlete do Tajo jako událost
      await tajo.events.track({
        email: payload.new.customer_email,
        event: 'order_placed',
        properties: {
          order_id: payload.new.id,
          total: payload.new.total,
          items: payload.new.line_items,
        },
      });
    }
  )
  .subscribe();

Dotaz a segmentace

// Dotaz na zákazníky podle plánu pro cílené kampaně
const { data: proUsers } = await supabase
  .from('customers')
  .select('email, full_name, plan, mrr')
  .eq('plan', 'pro')
  .gt('mrr', 100)
  .order('mrr', { ascending: false });

// Synchronizace do seznamu Brevo pro cílení kampaní
await tajo.lists.addContacts(PRO_LIST_ID, proUsers);

Omezení rychlosti

Řešení problémů

Časté problémy

Režim ladění

connectors:
  supabase:
    debug: true
    log_level: verbose
    log_queries: true
    log_realtime: true

Test připojení

tajo connectors test supabase
# ✓ Připojení API úspěšné
# ✓ Koncový bod Auth přístupný
# ✓ Tabulky čitelné (nalezeno 12 tabulek)
# ✓ Storage přístupný (3 buckety)
# ✓ Připojení Realtime navázáno
# ✓ Edge Functions dostupné (4 funkce)

Osvědčené postupy

1. Používejte klíč service_role pouze na straně serveru – Nikdy ho nezveřejňujte v klientském kódu
2. Povolte RLS na všech tabulkách – I s service_role navrhujte s ohledem na RLS pro hloubkovou ochranu
3. Používejte Realtime pro synchronizaci řízenou událostmi – Efektivnější než polling pro sledování změn
4. Dávkové operace – Používejte hromadné vkládání a filtr in pro operace s vysokým objemem
5. Mapujte metadata uživatelů – Ukládejte pole relevantní pro zapojení v user_metadata při registraci
6. Používejte Edge Functions pro webhooky – Zpracovávejte příchozí webhooky pomocí Supabase Edge Functions pro zpracování s nízkou latencí

Zabezpečení

• Ověřování API klíčem – Všechny požadavky vyžadují platné API klíče
• Row Level Security (RLS) – Řízení přístupu nativní v Postgres na úrovni řádků
• Ověřování JWT – Auth tokeny jsou podepsané JWT ověřované u každého požadavku
• SSL/TLS – Všechna spojení šifrovaná při přenosu
• SOC 2 Type II – Supabase splňuje SOC 2
• Síťová omezení – Volitelný whitelisting IP na placených plánech

Související zdroje

• Konektor Shopify
• Konektor Stripe
• Konektor Auth0
• Oficiální dokumentace Supabase
• Průvodce REST API Supabase
• Průvodce Auth Supabase