Konektor Supabase

Hubungkan proyek Supabase Anda untuk menyinkronkan record database, data autentikasi pengguna, event penyimpanan file, dan perubahan real-time untuk otomatisasi customer engagement.

Ikhtisar

Fitur

• REST API yang dibuat otomatis, operasi CRUD pada tabel Postgres mana pun via PostgREST, tanpa perlu kode
• Sinkronisasi pengguna Auth, sinkronkan pengguna Supabase Auth (email, telepon, login sosial) ke platform engagement Anda
• Langganan real-time, dengarkan event INSERT, UPDATE, DELETE pada tabel mana pun secara real-time
• Row Level Security, seluruh akses API menghormati kebijakan RLS Postgres untuk data multi-tenant yang aman
• Integrasi Storage, lacak unggahan file dan kelola aset di seluruh bucket Storage
• Edge Functions, panggil fungsi serverless Deno untuk logika kustom dan webhook
• Pencarian teks penuh, manfaatkan kemampuan full-text search Postgres melalui API

Prasyarat

Sebelum memulai, pastikan Anda memiliki:

1. Sebuah proyek Supabase (app.supabase.com)
2. API URL dan API key proyek Anda (tersedia di Settings → API)
3. Akun Tajo dengan akses API

Autentikasi

Supabase menggunakan autentikasi API key. Setiap permintaan memerlukan header apikey dan secara opsional token bearer Authorization untuk akses yang dicakup per pengguna.

# Using anon key (respects RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_ANON_KEY>" \
  -H "Authorization: Bearer <SUPABASE_ANON_KEY>"

# Using service_role key (bypasses RLS)
curl 'https://<project_ref>.supabase.co/rest/v1/customers' \
  -H "apikey: <SUPABASE_SERVICE_ROLE_KEY>" \
  -H "Authorization: Bearer <SUPABASE_SERVICE_ROLE_KEY>"

Konfigurasi

Setup dasar

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

    # Data sync options
    sync:
      users: true
      tables:
        - customers
        - orders
        - products
      storage: true
      realtime: true

    # Map Supabase Auth users to contacts
    user_mapping:
      email: email
      phone: SMS
      user_metadata.full_name: FIRSTNAME
      created_at: SIGNUP_DATE

Pemetaan field

Petakan kolom tabel Supabase ke atribut platform engagement:

Pemetaan tabel kustom

table_mapping:
  customers:
    # Column → Attribute mapping
    email: email
    full_name: FIRSTNAME
    company: COMPANY
    plan: SUBSCRIPTION_PLAN
    mrr: MONTHLY_REVENUE
    created_at: SIGNUP_DATE

  orders:
    # Track as events
    sync_as: events
    event_name: "order_placed"
    properties:
      total: amount
      status: order_status
      items: line_items

Endpoint API

REST API Supabase dibuat otomatis dari skema database Anda di https://<ref>.supabase.co/rest/v1/.

Operator filter

Event

Event Auth

Event database (Realtime)

Event webhook

Contoh kode

Inisialisasi konektor

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

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

// Connect Supabase project
await tajo.connectors.connect('supabase', {
  projectUrl: process.env.SUPABASE_URL,
  serviceRoleKey: process.env.SUPABASE_SERVICE_ROLE_KEY,
});

Menyinkronkan pengguna ke kontak

// Sync all Supabase Auth users as contacts
await tajo.connectors.sync('supabase', {
  type: 'full',
  resources: ['users'],
});

// Incremental sync (new/changed users only)
await tajo.connectors.sync('supabase', {
  type: 'incremental',
  resources: ['users'],
  since: '2024-01-01T00:00:00Z',
});

Mendengarkan perubahan real-time

// Subscribe to new orders for engagement triggers
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) => {
      // Forward to Tajo as an event
      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();

Kueri dan segmentasi

// Query customers by plan for targeted campaigns
const { data: proUsers } = await supabase
  .from('customers')
  .select('email, full_name, plan, mrr')
  .eq('plan', 'pro')
  .gt('mrr', 100)
  .order('mrr', { ascending: false });

// Sync to a Brevo list for campaign targeting
await tajo.lists.addContacts(PRO_LIST_ID, proUsers);

Batas rate

Pemecahan masalah

Masalah umum

Mode debug

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

Menguji koneksi

tajo connectors test supabase
# ✓ API connection successful
# ✓ Auth endpoint accessible
# ✓ Tables readable (12 tables found)
# ✓ Storage accessible (3 buckets)
# ✓ Realtime connection established
# ✓ Edge Functions available (4 functions)

Praktik terbaik

1. Gunakan key service_role hanya di sisi server, jangan pernah mengeksposnya dalam kode klien
2. Aktifkan RLS pada semua tabel, bahkan dengan service_role, rancanglah dengan RLS untuk defense in depth
3. Gunakan Realtime untuk sinkronisasi berbasis event, lebih efisien daripada polling untuk perubahan
4. Kelompokkan operasi, gunakan bulk insert dan filter in untuk operasi bervolume tinggi
5. Petakan metadata pengguna, simpan field yang relevan untuk engagement di user_metadata saat pendaftaran
6. Gunakan Edge Functions untuk webhook, proses webhook masuk dengan Supabase Edge Functions untuk penanganan berlatensi rendah

Keamanan

• Autentikasi API key, seluruh permintaan memerlukan API key yang valid
• Row Level Security (RLS), kontrol akses native Postgres per baris
• Verifikasi JWT, token Auth berupa JWT bertanda tangan yang diverifikasi pada setiap permintaan
• SSL/TLS, seluruh koneksi dienkripsi saat transit
• SOC 2 Type II, Supabase telah memenuhi kepatuhan SOC 2
• Network Restrictions, allowlist IP opsional pada paket berbayar

Sumber daya terkait

• Konektor Shopify
• Konektor Stripe
• Konektor Auth0
• Supabase Official Docs
• Supabase REST API Guide
• Supabase Auth Guide