Σύνδεσμος Supabase

Συνδέστε το project Supabase για συγχρονισμό εγγραφών βάσης δεδομένων, δεδομένων πιστοποίησης χρηστών, εκδηλώσεων αποθήκευσης αρχείων και αλλαγών σε πραγματικό χρόνο για αυτοματοποίηση αφοσίωσης πελατών.

Επισκόπηση

Χαρακτηριστικά

• Αυτόματα δημιουργούμενο REST API, λειτουργίες CRUD σε οποιονδήποτε πίνακα Postgres μέσω PostgREST, χωρίς κώδικα
• Συγχρονισμός χρηστών Auth, Συγχρονισμός χρηστών Supabase Auth (email, τηλέφωνο, κοινωνικές συνδέσεις) στην πλατφόρμα αφοσίωσης
• Εγγραφές σε πραγματικό χρόνο, Ακρόαση εκδηλώσεων INSERT, UPDATE, DELETE σε οποιονδήποτε πίνακα σε πραγματικό χρόνο
• Ασφάλεια Επιπέδου Γραμμής, Όλη η πρόσβαση API σέβεται τις πολιτικές RLS Postgres για ασφαλή πολυ-ενοικιαστή δεδομένα
• Ενσωμάτωση αποθήκευσης, Παρακολούθηση μεταφορτώσεων αρχείων και διαχείριση πόρων σε buckets αποθήκευσης
• Edge Functions, Κλήση serverless συναρτήσεων Deno για προσαρμοσμένη λογική και webhooks
• Αναζήτηση πλήρους κειμένου, Αξιοποίηση δυνατοτήτων αναζήτησης πλήρους κειμένου Postgres μέσω API

Προαπαιτούμενα

Πριν ξεκινήσετε, βεβαιωθείτε ότι διαθέτετε:

1. Project Supabase (app.supabase.com)
2. Το URL API και τα κλειδιά API του project σας (στις Ρυθμίσεις → API)
3. Λογαριασμό Tajo με πρόσβαση API

Πιστοποίηση

Το Supabase χρησιμοποιεί πιστοποίηση με κλειδί API. Κάθε αίτημα απαιτεί header apikey και προαιρετικά Bearer token Authorization για πρόσβαση με εύρος χρήστη.

# 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>"

Διαμόρφωση

Βασική Ρύθμιση

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

Αντιστοίχιση Πεδίων

Αντιστοίχηση στηλών πίνακα Supabase σε χαρακτηριστικά πλατφόρμας αφοσίωσης:

Αντιστοίχιση Προσαρμοσμένου Πίνακα

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

Endpoints API

Το REST API Supabase δημιουργείται αυτόματα από το σχήμα βάσης δεδομένων σας στο https://<ref>.supabase.co/rest/v1/.

Τελεστές Φιλτραρίσματος

Εκδηλώσεις

Εκδηλώσεις Auth

Εκδηλώσεις Βάσης Δεδομένων (Realtime)

Εκδηλώσεις Webhook

Παραδείγματα Κώδικα

Αρχικοποίηση Συνδέσμου

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,
});

Συγχρονισμός Χρηστών σε Επαφές

// 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',
});

Ακρόαση Αλλαγών σε Πραγματικό Χρόνο

// 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();

Ερώτηση και Τμηματοποίηση

// 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);

Όρια Ρυθμού

Αντιμετώπιση Προβλημάτων

Συνήθη Προβλήματα

Λειτουργία Εντοπισμού Σφαλμάτων

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

Δοκιμή Σύνδεσης

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)

Βέλτιστες Πρακτικές

1. Χρησιμοποιήστε κλειδί service_role μόνο πλευράς server, Μην το εκθέτετε ποτέ σε κώδικα client
2. Ενεργοποιήστε RLS σε όλους τους πίνακες, Ακόμα και με service_role, σχεδιάστε με RLS για άμυνα σε βάθος
3. Χρησιμοποιήστε Realtime για συγχρονισμό βάσει εκδηλώσεων, Πιο αποδοτικό από polling για αλλαγές
4. Λειτουργίες batch, Χρησιμοποιήστε μαζικές εισαγωγές και φίλτρο in για λειτουργίες υψηλού όγκου
5. Αντιστοιχίστε μεταδεδομένα χρήστη, Αποθηκεύστε πεδία σχετικά με αφοσίωση στο user_metadata κατά την εγγραφή
6. Χρησιμοποιήστε Edge Functions για webhooks, Επεξεργαστείτε εισερχόμενα webhooks με Supabase Edge Functions για χαμηλή καθυστέρηση

Ασφάλεια

• Πιστοποίηση Κλειδιού API, Όλα τα αιτήματα απαιτούν έγκυρα κλειδιά API
• Ασφάλεια Επιπέδου Γραμμής (RLS), Εγγενής στο Postgres έλεγχος πρόσβασης ανά γραμμή
• Επαλήθευση JWT, Τα tokens πιστοποίησης είναι υπογεγραμμένα JWT που επαληθεύονται σε κάθε αίτημα
• SSL/TLS, Όλες οι συνδέσεις κρυπτογραφούνται κατά τη μεταφορά
• SOC 2 Type II, Το Supabase είναι συμβατό με SOC 2
• Περιορισμοί Δικτύου, Προαιρετικό allowlisting IP σε πληρωμένα πλάνα

Σχετικοί Πόροι

• Σύνδεσμος Shopify
• Σύνδεσμος Stripe
• Σύνδεσμος Auth0
• Επίσημη Τεκμηρίωση Supabase
• Οδηγός REST API Supabase
• Οδηγός Auth Supabase