video_analyzer.pyの実装と初回エラー｜ffprobeパス・文字コード・Ollama接続のトラブル対応

def analyze_video(video_path: Path, cfg: dict) -> dict:
    duration, w, h, fps, codec = probe_video_meta(video_path, cfg["ffprobe_path"])
    frame_paths = extract_scene_frames(video_path, tmp_dir, cfg)
    if len(frame_paths) < cfg.get("min_frames", 3):
        frame_paths = extract_uniform_frames(video_path, tmp_dir, duration,
                                              count=cfg.get("fallback_frames", 6))

    frame_scores = [analyze_single_frame(p) for p in frame_paths]  # 画像版と共通の関数
    shake_score = calc_shake_score(video_path, cfg)
    silence_ratio = calc_silence_ratio(video_path, cfg["ffmpeg_path"])

    return {
        "duration": duration, "resolution": f"{w}x{h}", "fps": fps, "codec": codec,
        "clip_avg": mean(s["clip_score"] for s in frame_scores),
        "clip_min": min(s["clip_score"] for s in frame_scores),
        "shake_score": shake_score,
        "silence_ratio": silence_ratio,
        "scene_count": len(frame_paths),
    }

# video_utils.py（設計段階のコードをモジュール化）
# video_analyzer.py
from video_utils import (
    extract_scene_frames,
    extract_uniform_frames,
    calc_shake_score,
    calc_silence_ratio
)

"analyze_video": {
  "ffmpeg_dir": "E:\\tools\\ffmpeg\\bin",
  ...
}

# コード側
FFMPEG_PATH = str(Path(cfg["ffmpeg_dir"]) / "ffmpeg.exe")
FFPROBE_PATH = str(Path(cfg["ffmpeg_dir"]) / "ffprobe.exe")

# Before
result = subprocess.run(cmd, capture_output=True, text=True, timeout=30)

# After
result = subprocess.run(cmd, capture_output=True, timeout=30)
stdout = result.stdout.decode("utf-8", errors="replace")
stderr = result.stderr.decode("utf-8", errors="replace")

def wait_for_ollama(url: str, retries: int = 3, wait_sec: int = 3) -> bool:
    for i in range(retries):
        try:
            r = requests.get(f"{url}/api/tags", timeout=3)
            if r.status_code == 200:
                return True
        except requests.exceptions.RequestException:
            pass
        print(f"[INFO] Ollamaサーバーへの接続待機中... ({i+1}/{retries})")
        time.sleep(wait_sec)
    return False

if not wait_for_ollama(cfg["ollama_url"]):
    print("[ERROR] Ollamaサーバーに接続できません。ollama serve を起動してください。")
    sys.exit(1)