Supabase Konektor

Povežite svoj Supabase projekt za sinkronizaciju zapisa baze podataka, korisničkih podataka autentifikacije, događaja pohrane datoteka i promjena u stvarnom vremenu za automatizaciju angažmana s klijentima.

Pregled

Značajke

• Automatski generirani REST API, CRUD operacije na bilo kojoj Postgres tablici putem PostgREST, bez koda
• Sinkronizacija Auth korisnika, Sinkronizacija Supabase Auth korisnika (e-mail, telefon, socijalne prijave) na vašu platformu za angažman
• Pretplate u stvarnom vremenu, Slušajte INSERT, UPDATE, DELETE događaje na bilo kojoj tablici u stvarnom vremenu
• Sigurnost na razini reda, Sav API pristup poštuje Postgres RLS politike za sigurne višestanarne podatke
• Integracija pohrane, Pratite učitavanja datoteka i upravljajte resursima kroz Storage buckete
• Edge funkcije, Pozivajte serverless Deno funkcije za prilagođenu logiku i webhookove
• Pretraživanje cijelog teksta, Iskoristite Postgres mogućnosti pretraživanja cijelog teksta putem API-ja

Preduvjeti

Prije nego što počnete, osigurajte da imate:

1. Supabase projekt (app.supabase.com)
2. Vaš projektni API URL i API ključevi (pronađeni u Postavke → API)
3. Tajo račun s API pristupom

Autentifikacija

Supabase koristi autentifikaciju API ključem. Svaki zahtjev zahtijeva zaglavlje apikey i opcionalno Authorization bearer token za pristup ograničen na korisnika.

# Korištenje anon ključa (poštuje RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_ANON_KEY>" \
  -H "Authorization: Bearer <SUPABASE_ANON_KEY>"

# Korištenje service_role ključa (zaobilazi RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_SERVICE_ROLE_KEY>" \
  -H "Authorization: Bearer <SUPABASE_SERVICE_ROLE_KEY>"

Konfiguracija

Osnovna konfiguracija

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

    # Opcije sinkronizacije podataka
    sync:
      users: true
      tables:
        - customers
        - orders
        - products
      storage: true
      realtime: true

    # Mapiranje Supabase Auth korisnika na kontakte
    user_mapping:
      email: email
      phone: SMS
      user_metadata.full_name: FIRSTNAME
      created_at: SIGNUP_DATE

Mapiranje polja

Mapirajte stupce Supabase tablice na atribute platforme za angažman:

Mapiranje prilagođenih tablica

table_mapping:
  customers:
    # Mapiranje Stupac → Atribut
    email: email
    full_name: FIRSTNAME
    company: COMPANY
    plan: SUBSCRIPTION_PLAN
    mrr: MONTHLY_REVENUE
    created_at: SIGNUP_DATE

  orders:
    # Pratite kao događaje
    sync_as: events
    event_name: "order_placed"
    properties:
      total: amount
      status: order_status
      items: line_items

API krajnje točke

Supabase REST API automatski se generira iz vaše sheme baze podataka na https://<ref>.supabase.co/rest/v1/.

Operatori filtriranja

Događaji

Auth događaji

Događaji baze podataka (Realtime)

Webhook događaji

Primjeri koda

Inicijalizacija konektora

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

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

// Povežite Supabase projekt
await tajo.connectors.connect('supabase', {
  projectUrl: process.env.SUPABASE_URL,
  serviceRoleKey: process.env.SUPABASE_SERVICE_ROLE_KEY,
});

Sinkronizacija korisnika s kontaktima

// Sinkronizacija svih Supabase Auth korisnika kao kontakata
await tajo.connectors.sync('supabase', {
  type: 'full',
  resources: ['users'],
});

// Inkrementalna sinkronizacija (samo novi/promijenjeni korisnici)
await tajo.connectors.sync('supabase', {
  type: 'incremental',
  resources: ['users'],
  since: '2024-01-01T00:00:00Z',
});

Slušanje promjena u stvarnom vremenu

// Pretplatite se na nove narudžbe za okidače angažmana
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) => {
      // Proslijedite Taju kao događaj
      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();

Upit i segmentacija

// Upitajte korisnike prema planu za ciljane kampanje
const { data: proUsers } = await supabase
  .from('customers')
  .select('email, full_name, plan, mrr')
  .eq('plan', 'pro')
  .gt('mrr', 100)
  .order('mrr', { ascending: false });

// Sinkronizacija na Brevo popis za ciljanje kampanje
await tajo.lists.addContacts(PRO_LIST_ID, proUsers);

Ograničenja brzine

Rješavanje problema

Uobičajeni problemi

Način otklanjanja grešaka

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

Testiranje veze

tajo connectors test supabase
# ✓ API veza uspješna
# ✓ Auth krajnja točka dostupna
# ✓ Tablice čitljive (pronađeno 12 tablica)
# ✓ Pohrana dostupna (3 bucketa)
# ✓ Realtime veza uspostavljena
# ✓ Edge funkcije dostupne (4 funkcije)

Preporučene prakse

1. Koristite service_role ključ samo na strani servera - Nikada ga ne izlažite u klijentskom kodu
2. Omogućite RLS na svim tablicama - Čak i uz service_role, dizajnirajte s RLS-om za obranu u dubini
3. Koristite Realtime za sinkronizaciju vođenu događajima - Učinkovitije od anketiranja za promjene
4. Skupne operacije - Koristite skupno umetanje i in filtar za viskovoluenske operacije
5. Mapirajte korisničke metapodatke - Pohranite relevantna polja za angažman u user_metadata tijekom registracije
6. Koristite Edge funkcije za webhookove - Obradite dolazne webhookove s Supabase Edge funkcijama za rukovanje s niskom latencijom

Sigurnost

• Autentifikacija API ključem - Svi zahtjevi zahtijevaju valjane API ključeve
• Sigurnost na razini reda (RLS) - Postgres-nativna kontrola pristupa po redu
• JWT verifikacija - Auth tokeni su potpisani JWT-ovi verificirani na svakom zahtjevu
• SSL/TLS - Sve veze šifrirane u prijenosu
• SOC 2 Type II - Supabase je SOC 2 usklađen
• Mrežna ograničenja - Opcionalno IP dodavanje na popis dopuštenih na plaćenim planovima

Povezani resursi

• Shopify Konektor
• Stripe Konektor
• Auth0 Konektor
• Supabase službena dokumentacija
• Supabase vodič za REST API
• Supabase vodič za Auth