(3주차) FastAPI와 n8n을 활용한 요약 챗봇 자동화 사례

1. FastAPI를 활용한 퍼플렉시티 요약봇 만들기

유튜브 자막을 요약하기 위해 FastAPI 기반 요약 서버를 만들었습니다. 요약 모델은 퍼플렉시티 또는 ChatGPT를 사용할 수 있으며, 핵심은 서버가 항상 실행 중이어야 한다는 점입니다.

✅ 핵심 포인트

서버 세팅: 디지털오션 서버를 활용하여 외부 접속 가능하게 uvicorn 설정
systemd를 활용해 서버를 항상 실행 상태로 유지
현우님이 제공한 perbot.js와 Python main.py 구조로 구성

🔧 FastAPI 코드 예시

📷 실제 동작 화면

사용자가 '검색 오늘 날씨' 입력
레오봇이 FastAPI 서버를 호출해 Perplexity 응답을 받아 전달
풍부한 자연어 요약으로 사용자에게 응답됨

💡 PerBot.js: FastAPI 서버를 호출하는 메신저봇R 스크립트

// Perplexity 검색 요청을 FastAPI 서버에 전달하고 응답을 받아오는 봇
// 작동 방식:
// 1. 사용자가 "검색 [질문]" 입력
// 2. FastAPI 서버의 /search 엔드포인트에 POST 요청 전송
// 3. 서버가 Perplexity API를 호출하여 응답 생성 후 반환

var bot = BotManager.getCurrentBot();

var CONFIG = {
    BOT_NAME: "PerBot",
    VERSION: "1.0.0",
    TARGET_ROOMS: ["레오봇", "명한일"],
    API_URL: "http://0000.0000.000.00:8000",
    TRIGGER_PREFIX: "검색"
};

function searchPerplexity(query, room) {
    new java.lang.Thread(function() {
        try {
            var conn = org.jsoup.Jsoup.connect(CONFIG.API_URL + "/search")
                .ignoreContentType(true)
                .header("Content-Type", "application/json")
                .timeout(30000)
                .requestBody(JSON.stringify({ query: query }))
                .method(org.jsoup.Connection.Method.POST);

            var response = conn.execute();
            var statusCode = response.statusCode();
            var responseText = response.body();

            if (statusCode === 200) {
                var result = JSON.parse(responseText);
                bot.send(room, result.answer);
            } else {
                bot.send(room, "❌ 오류 발생 (HTTP " + statusCode + ")");
            }
        } catch (e) {
            bot.send(room, "❌ 서버 연결 오류");
        }
    }).start();
}

function onMessage(msg) {
    if (CONFIG.TARGET_ROOMS.indexOf(msg.room) === -1) return;
    var content = msg.content.trim();
    if (content.indexOf(CONFIG.TRIGGER_PREFIX + " ") === 0) {
        var query = content.substring(CONFIG.TRIGGER_PREFIX.length + 1).trim();
        if (query.length === 0) {
            bot.send(msg.room, "❓ 검색어를 입력해주세요. 예: 검색 오늘 날씨");
            return;
        }
        searchPerplexity(query, msg.room);
    }
}

bot.addListener(Event.MESSAGE, onMessage);

sudo nano /etc/systemd/system/leo.service
# 서비스이름은 leo

[Unit]
Description=FastAPI Server Service
After=network.target

[Service]
Type=simple
User=root
WorkingDirectory=/root/fastapi-project
ExecStart=/root/fastapi-project/venv/bin/uvicorn main:app --host 0.0.0.0 --port 8000
Restart=on-failure

[Install]
WantedBy=multi-user.target

# 적용 명령어
sudo systemctl daemon-reload             # 새 서비스 인식
sudo systemctl enable leo.service        # 부팅 시 자동 시작 설정
sudo systemctl start leo.service         # 서비스 시작
sudo systemctl status leo.service        # 서비스 상태 확인
sudo journalctl -u leo.service -f        #서비스 로그 실시간 보기 (별도창)