Supabase

Supabase는 오픈 소스 백엔드 서비스 플랫폼으로, 개발자들이 애플리케이션의 데이터베이스와 인증, 실시간 데이터 처리 등을 관리할 수 있도록 지원한다. 이 플랫폼은 PostgreSQL을 기반으로 하며, 데이터베이스와 관련된 다양한 작업을 쉽게 수행할 수 있는 도구와 인터페이스를 제공한다. 또한 Supabase는 API를 통해 클라이언트 애플리케이션과 상호작용하고, 데이터를 실시간으로 업데이트할 수 있는 기능도 제공한다. 요약하자면, Supabase는 백엔드 작업을 간편하게 처리할 수 있도록 도와주는 플랫폼이다.

Supabase | The Open Source Firebase Alternative

Supabase | The Open Source Firebase Alternative

구성요소

• 데이터베이스

Supabase는 모든 프로젝트에 대해 완전한 Postgres 데이터베이스를 제공하여 실시간 기능, 데이터베이스 백업, 확장 기능 등을 제공한다.

• 인증

이메일 및 비밀번호, 비밀번호 없는 인증, OAuth 및 모바일 로그인을 프로젝트에 추가하고 관리할 수 있도록 아이덴티티 제공자 및 API 스위트를 통해 제공한다.

• 저장소

큰 파일을 저장, 구성, 변환 및 제공할 수 있으며, Postgres 데이터베이스와 완전히 통합되어 Row Level Security 액세스 정책을 사용한다.

• AI 및 벡터

Supabase를 사용하여 임베딩 벡터를 저장하고 검색할 수 있다.

• 실시간

데이터베이스 변경 사항을 수신하고, 사용자 상태를 클라이언트 간에 저장 및 동기화하며, 채널에 가입한 클라이언트에게 데이터를 브로드캐스트하는 등 다양한 기능을 제공한다.

• Edge Function

전 세계적으로 분산되어 있으며, 사용자와 가장 가까운 위치에서 코드를 실행하여 최소 지연 시간으로 작동하는 서버 측 함수를 제공한다.

예제 코드

우선 아래와 같이 외부에서 API 등을 통해서 데이터 조회하기 위해서는 API 키 생성과  정책을 추가해줘야 한다.

1. API 키 

- 프로젝트 셋팅 > API > URL 과 anon 키 값 복사

2. Policy

- 테이블을 클릭하고 우측 상단에 Auth policy 를 클릭하고 select 추가

from fastapi import FastAPI, HTTPException, Request
import httpx
import os
from dotenv import load_dotenv
import logging
from fastapi.responses import JSONResponse


# Load environment variables
load_dotenv()

SUPABASE_URL = os.getenv("SUPABASE_URL")
SUPABASE_ANON_KEY = os.getenv("SUPABASE_ANON_KEY")

if not SUPABASE_URL or not SUPABASE_ANON_KEY:
    raise ValueError("Supabase URL and ANON KEY must be set in environment variables.")

# FastAPI application instance
app = FastAPI()

# Configure logging
logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger(__name__)

# HTTP client for Supabase
HEADERS = {
    "apikey": SUPABASE_ANON_KEY,
    "Authorization": f"Bearer {SUPABASE_ANON_KEY}",
}


@app.get("/conversations")
async def get_conversations():
    """
    Endpoint to fetch data from tab1 table in Supabase.
    """
    url = f"{SUPABASE_URL}/rest/v1/tab1"
    params = {"select": "*"}

    # 요청 정보 로깅 추가
    logger.debug(f"Request URL: {url}")
    logger.debug(f"Request Headers: {HEADERS}")
    logger.debug(f"Request Params: {params}")

    try:
        async with httpx.AsyncClient() as client:
            response = await client.get(url, headers=HEADERS, params=params)

            # 응답 상세 정보 로깅
            logger.debug(f"Response Status: {response.status_code}")
            logger.debug(f"Response Headers: {response.headers}")
            logger.debug(f"Response Body: {response.text}")

            if response.status_code != 200:
                raise HTTPException(
                    status_code=response.status_code,
                    detail=f"Error fetching data: {response.text}",
                )

            data = response.json()
            logger.debug(f"Parsed JSON Data: {data}")  # 파싱된 데이터 확인
            return data

    except Exception as e:
        logger.exception("Error while fetching data from Supabase.")
        raise HTTPException(status_code=500, detail=str(e))


# Global exception handler for debugging
@app.middleware("http")
async def catch_exceptions_middleware(request: Request, call_next):
    try:
        return await call_next(request)
    except Exception as exc:
        logger.exception("Unhandled exception occurred.")
        return JSONResponse(
            status_code=500,
            content={"detail": str(exc)},
        )


# Run the FastAPI server
if __name__ == "__main__":
    import uvicorn

    uvicorn.run(app, host="0.0.0.0", port=3000)

 

그외 Supabase를 사용하는 몇 가지 예시는 다음과 같다.:

• 웹 애플리케이션 개발: Supabase는 데이터베이스, 인증 및 저장소 기능을 제공하여 웹 애플리케이션을 개발하는 데 사용될 수 있다. 사용자는 Supabase의 데이터베이스를 사용하여 애플리케이션의 데이터를 저장하고 관리하며, Supabase의 인증 기능을 사용하여 사용자를 인증하고 권한을 관리할 수 있다.

// Supabase 클라이언트 설정

const { createClient } = require('@supabase/supabase-js');

const supabaseUrl = 'YOUR_SUPABASE_URL';

const supabaseKey = 'YOUR_SUPABASE_KEY';

const supabase = createClient(supabaseUrl, supabaseKey);

// 데이터베이스 쿼리 예시

async function fetchData() {

  const { data, error } = await supabase

    .from('table_name')

    .select('*');

  if (error) console.log('Error fetching data:', error.message);

  else console.log('Fetched data:', data);

}

// 인증 예시

async function signIn(email, password) {

  const { user, error } = await supabase.auth.signIn({

    email: email,

    password: password,

  });

  if (error) console.log('Error signing in:', error.message);

  else console.log('Signed in user:', user);

}

• 실시간 애플리케이션: Supabase는 데이터베이스 변경 사항을 실시간으로 수신하고 처리할 수 있는 기능을 제공합니다. 따라서 실시간으로 업데이트되는 애플리케이션을 구축하는 데 사용될 수 있다. 예를 들어, 실시간 채팅 애플리케이션을 개발할 때 Supabase의 실시간 기능을 사용하여 채팅 메시지를 실시간으로 전송할 수 있다.

// 데이터베이스 변경 사항 실시간 구독 예시

const subscription = supabase

  .from('table_name')

  .on('INSERT', (payload) => {

    console.log('New row inserted:', payload.new);

  })

  .subscribe();

// 메시지 전송 예시

async function sendMessage(message) {

  const { data, error } = await supabase

    .from('chat_messages')

    .insert([{ message: message }]);

  if (error) console.log('Error sending message:', error.message);

  else console.log('Message sent successfully');

}

• AI/머신러닝 프로젝트: Supabase의 AI & Vectors 기능을 사용하여 벡터 데이터를 저장하고 검색할 수 있다. 이를 활용하여 사용자의 선호도에 따라 추천 시스템을 개발하거나, 비슷한 항목을 검색하는 등의 작업을 수행할 수 있다.

// 벡터 데이터 저장 예시

async function storeVector(vectorData) {

  const { data, error } = await supabase

    .from('vector_table')

    .insert([{ vector: vectorData }]);

  if (error) console.log('Error storing vector:', error.message);

  else console.log('Vector stored successfully');

}

// 벡터 검색 예시

async function searchVector(queryVector) {

  const { data, error } = await supabase

    .from('vector_table')

    .select('*')

    .order('vector', { ascending: true })

    .limit(1);

  if (error) console.log('Error searching vector:', error.message);

  else console.log('Nearest vector found:', data);

}

• 서버리스 애플리케이션: Supabase의 엣지 함수 기능을 사용하여 서버리스 애플리케이션을 개발할 수 있다. 이를 통해 사용자의 요청을 가장 가까운 위치에서 처리하여 응답 시간을 최적화할 수 있다.

1. 이미지 크기 조정: 사용자가 이미지를 업로드할 때, 서버리스 함수를 사용하여 이미지의 크기를 조정하고 다양한 버전을 생성할 수 있다.
2. 이메일 발송: 회원가입 또는 비밀번호 재설정과 같은 이벤트 발생 시, 서버리스 함수를 사용하여 이메일을 자동으로 전송할 수 있다.
3. 파일 변환: 사용자가 업로드한 파일을 변환해야 할 경우, 서버리스 함수를 사용하여 파일 형식을 변경하거나 데이터를 가공할 수 있다.
4. 웹훅 처리: 외부 서비스로부터 웹훅을 수신하고 이를 처리하는 경우, 서버리스 함수를 사용하여 웹훅을 수신하고 필요한 작업을 수행할 수 있다.

const sharp = require('sharp');

const { createClient } = require('@supabase/supabase-js');

const supabaseUrl = 'YOUR_SUPABASE_URL';

const supabaseKey = 'YOUR_SUPABASE_KEY';

const supabase = createClient(supabaseUrl, supabaseKey);

exports.handler = async (event, context) => {

  try {

    // 이미지 다운로드

    const { data, error } = await supabase.storage

      .from('bucket_name')

      .download('image.jpg');

    // 이미지 리사이즈

    const resizedImage = await sharp(data)

      .resize({ width: 300, height: 300 })

      .toBuffer();

    // 리사이즈된 이미지 저장

    const { data: imageData, error: imageError } = await supabase.storage

      .from('resized_images')

      .upload('resized_image.jpg', resizedImage);

    if (imageError) {

      return {

        statusCode: 500,

        body: JSON.stringify({ message: 'Error uploading resized image' }),

      };

    }

    return {

      statusCode: 200,

      body: JSON.stringify({ message: 'Resized image uploaded successfully' }),

    };

  } catch (error) {

    return {

      statusCode: 500,

      body: JSON.stringify({ message: 'Internal server error' }),

    };

  }

};