1) 구성 개요

video-worker는 FastAPI 기반의 단일 마이크로서비스로, n8n에서 HTTP로 호출됩니다. 역할은 다음 3단입니다.

1. Playwright 자동화로 마크뷰 검색 녹화 수행
2. 생성된 raw video.webm → ffmpeg로 mp4 변환/정규화
3. mp4를 Google Drive에 업로드(항상 시도) + YouTube 업로드(auto일 때만)

이 모든 과정이 /generate 한 번의 요청으로 실행됩니다.

2) 디렉토리/모듈 아키텍처

A. API Layer (FastAPI)

services/video-worker/app/main.py

• 엔드포인트
  • GET /health: baseDir/videoDir 상태 확인 main
  • POST /generate: 전체 파이프라인 오케스트레이션 main
• 역할
  • 입력 검증(빈 검색어 → 400)
  • subprocess로 runner 실행(영상 생성)
  • mp4 탐색(find_latest_mp4)
  • Drive 업로드(try/except로 실패 흡수)
  • YouTube 업로드(auto일 때만, 실패 흡수)
  • 결과를 JSON으로 반환(성공은 200 유지)

B. Contract Layer (Schema)

services/video-worker/app/schemas.py

• GenerateRequest: keyword, uploadMode(auto|manual) schemas
• GenerateResponse: n8n 분기를 위한 상태 필드 포함
  • YouTube: youtubeUrl, uploadStatus, uploadError
  • Drive: driveFileId, driveUrl, driveStatus, driveError
  • 에러 케이스용 errorCode/message/detail schemas

C. Utility Layer

services/video-worker/app/file_utils.py

• find_latest_mp4(video_dir, keyword=None)
  • output/video에서 최신 mp4 찾기
  • keyword가 있으면 파일명이 keyword로 시작하는 것만 필터 file_utils

D. Integration Layer (Google APIs)