VPSでFFmpegエンコードサーバーを構築する

# システムを最新化
sudo apt update && sudo apt upgrade -y

# FFmpeg と関連ツールをインストール
sudo apt install -y ffmpeg inotify-tools python3-pip python3-venv

# バージョン確認
ffmpeg -version

# エンコードサーバー用のディレクトリ構造を作成
sudo mkdir -p /opt/encoder/{watch,processing,done,failed,logs}

# 実行ユーザーを作成（rootで動かさない）
sudo useradd -r -s /bin/false encoder

# ディレクトリのオーナーを変更
sudo chown -R encoder:encoder /opt/encoder

# /opt/encoder/encode.sh を作成
sudo tee /opt/encoder/encode.sh > /dev/null << 'EOF'
#!/bin/bash
set -euo pipefail

INPUT="$1"
BASENAME=$(basename "$INPUT" | sed 's/\.[^.]*$//')
OUTPUT="/opt/encoder/done/${BASENAME}_encoded.mp4"

ffmpeg -i "$INPUT" \
  -c:v libx264 \
  -preset slow \
  -crf 23 \
  -c:a aac \
  -b:a 128k \
  -movflags +faststart \
  "$OUTPUT" \
  2>> /opt/encoder/logs/ffmpeg.log

echo "Done: $OUTPUT"
EOF

sudo chmod +x /opt/encoder/encode.sh
sudo chown encoder:encoder /opt/encoder/encode.sh

# /opt/encoder/watch.sh を作成
sudo tee /opt/encoder/watch.sh > /dev/null << 'EOF'
#!/bin/bash
set -euo pipefail

WATCH_DIR="/opt/encoder/watch"
PROCESSING_DIR="/opt/encoder/processing"
FAILED_DIR="/opt/encoder/failed"
LOG="/opt/encoder/logs/watch.log"

log() {
  echo "[$(date '+%Y-%m-%d %H:%M:%S')] $*" | tee -a "$LOG"
}

log "Encoder watch started. Watching: $WATCH_DIR"

inotifywait -m -e close_write --format '%f' "$WATCH_DIR" | while read -r FILENAME; do
  FILEPATH="${WATCH_DIR}/${FILENAME}"

  # 対応拡張子のみ処理（mp4, mkv, mov, avi）
  EXT="${FILENAME##*.}"
  EXT_LOWER=$(echo "$EXT" | tr '[:upper:]' '[:lower:]')
  if [[ ! "$EXT_LOWER" =~ ^(mp4|mkv|mov|avi)$ ]]; then
    log "Skipped (unsupported format): $FILENAME"
    continue
  fi

  log "Detected: $FILENAME"

  # processing ディレクトリへ移動
  PROC_PATH="${PROCESSING_DIR}/${FILENAME}"
  mv "$FILEPATH" "$PROC_PATH"
  log "Moved to processing: $FILENAME"

  # エンコード実行
  if /opt/encoder/encode.sh "$PROC_PATH"; then
    rm -f "$PROC_PATH"
    log "Success: $FILENAME"
  else
    mv "$PROC_PATH" "${FAILED_DIR}/${FILENAME}"
    log "Failed: $FILENAME — moved to failed/"
  fi
done
EOF

sudo chmod +x /opt/encoder/watch.sh
sudo chown encoder:encoder /opt/encoder/watch.sh

# watch.sh をテスト実行
sudo -u encoder /opt/encoder/watch.sh &

# 別ターミナルでテストファイルを配置
cp /path/to/test.mp4 /opt/encoder/watch/

# ログを確認
tail -f /opt/encoder/logs/watch.log

# /etc/systemd/system/encoder.service を作成
[Unit]
Description=FFmpeg Encoding Watch Service
After=network.target

[Service]
Type=simple
User=encoder
Group=encoder
ExecStart=/opt/encoder/watch.sh
Restart=on-failure
RestartSec=5s
StandardOutput=append:/opt/encoder/logs/systemd.log
StandardError=append:/opt/encoder/logs/systemd.log

# セキュリティ強化
NoNewPrivileges=true
ProtectSystem=strict
ReadWritePaths=/opt/encoder
PrivateTmp=true

[Install]
WantedBy=multi-user.target

# サービスファイルをsystemdに読み込ませる
sudo systemctl daemon-reload

# 起動時の自動スタートを有効化
sudo systemctl enable encoder.service

# 今すぐ起動
sudo systemctl start encoder.service

# 状態確認
sudo systemctl status encoder.service

# リアルタイムログ確認
sudo journalctl -u encoder.service -f

# 過去ログの確認
sudo journalctl -u encoder.service --since "1 hour ago"

# Python仮想環境の作成
python3 -m venv /opt/encoder/venv

# FastAPIとUvicornをインストール
/opt/encoder/venv/bin/pip install "fastapi[standard]" python-multipart

# /opt/encoder/api.py
import os
import shutil
from pathlib import Path

from fastapi import FastAPI, File, HTTPException, UploadFile
from fastapi.responses import JSONResponse
from fastapi.security import APIKeyHeader
from fastapi import Security, Depends

app = FastAPI(title="FFmpeg Encoding API")

# 環境変数からAPIキーを取得
API_KEY = os.environ.get("ENCODER_API_KEY", "")
api_key_header = APIKeyHeader(name="X-API-Key", auto_error=False)

WATCH_DIR = Path("/opt/encoder/watch")
DONE_DIR = Path("/opt/encoder/done")
FAILED_DIR = Path("/opt/encoder/failed")
PROCESSING_DIR = Path("/opt/encoder/processing")


def verify_api_key(key: str = Security(api_key_header)) -> str:
    if not API_KEY:
        raise HTTPException(status_code=500, detail="API key not configured")
    if key != API_KEY:
        raise HTTPException(status_code=403, detail="Invalid API key")
    return key


@app.post("/encode")
async def submit_encode(
    file: UploadFile = File(...),
    _: str = Depends(verify_api_key),
) -> JSONResponse:
    """動画ファイルをウォッチフォルダに投入する"""
    allowed_exts = {".mp4", ".mkv", ".mov", ".avi"}
    ext = Path(file.filename).suffix.lower()

    if ext not in allowed_exts:
        raise HTTPException(
            status_code=400,
            detail=f"Unsupported file type: {ext}. Allowed: {allowed_exts}",
        )

    dest = WATCH_DIR / file.filename
    with dest.open("wb") as f:
        shutil.copyfileobj(file.file, f)

    return JSONResponse(
        status_code=202,
        content={"status": "queued", "filename": file.filename},
    )


@app.get("/status")
async def get_status(_: str = Depends(verify_api_key)) -> JSONResponse:
    """各フォルダのファイル数を返す"""
    return JSONResponse(
        content={
            "watching": len(list(WATCH_DIR.iterdir())),
            "processing": len(list(PROCESSING_DIR.iterdir())),
            "done": len(list(DONE_DIR.iterdir())),
            "failed": len(list(FAILED_DIR.iterdir())),
        }
    )


@app.get("/health")
async def health_check() -> JSONResponse:
    """ヘルスチェック（認証不要）"""
    return JSONResponse(content={"status": "ok"})

# APIサービスのsystemdユニットファイル
sudo tee /etc/systemd/system/encoder-api.service > /dev/null << 'EOF'
[Unit]
Description=FFmpeg Encoding API Server
After=network.target

[Service]
Type=simple
User=encoder
Group=encoder
WorkingDirectory=/opt/encoder
Environment="ENCODER_API_KEY=your-secret-key-here"
ExecStart=/opt/encoder/venv/bin/uvicorn api:app --host 127.0.0.1 --port 8000
Restart=on-failure
RestartSec=5s

[Install]
WantedBy=multi-user.target
EOF

sudo systemctl daemon-reload
sudo systemctl enable encoder-api.service
sudo systemctl start encoder-api.service

# ランダムなAPIキーを生成
openssl rand -hex 32

# ファイルを投入
curl -X POST http://your-vps-ip:8000/encode \
  -H "X-API-Key: your-secret-key-here" \
  -F "file=@/path/to/video.mp4"

# ステータス確認
curl http://your-vps-ip:8000/status \
  -H "X-API-Key: your-secret-key-here"

# 7日以上前のファイルを削除するcron（crontab -e で設定）
0 3 * * * find /opt/encoder/done -type f -mtime +7 -delete

# encode.sh の ffmpeg 実行を nice で低優先度に変更
nice -n 10 ffmpeg -i "$INPUT" ...

# /etc/logrotate.d/encoder を作成
sudo tee /etc/logrotate.d/encoder > /dev/null << 'EOF'
/opt/encoder/logs/*.log {
    daily
    rotate 7
    compress
    missingok
    notifempty
}
EOF

# ローカルからVPSのウォッチフォルダへ転送
scp /path/to/video.mp4 user@your-vps-ip:/opt/encoder/watch/