無人で回し続けても重くならないか — Claude Code 長時間セッションのメモリ使用量を観測して頭打ちにする

#!/usr/bin/env bash
# rss-sample.sh — 指定 PID とその子孫の RSS 合計を CSV に追記する
# 使い方: ./rss-sample.sh <root_pid> <out.csv> [interval_sec]
set -euo pipefail
 
ROOT_PID="$1"
OUT="$2"
INTERVAL="${3:-15}"
 
# 子孫 PID を再帰的に集める
collect_descendants() {
  local pid="$1"
  echo "$pid"
  for child in $(pgrep -P "$pid" 2>/dev/null || true); do
    collect_descendants "$child"
  done
}
 
# ヘッダ（初回のみ）
[ -s "$OUT" ] || echo "ts_epoch,iso,proc_count,rss_kb" >> "$OUT"
 
while kill -0 "$ROOT_PID" 2>/dev/null; do
  pids="$(collect_descendants "$ROOT_PID" | sort -u)"
  count=0
  total=0
  for p in $pids; do
    # ps の rss は KB 単位。存在しない PID は無視
    kb="$(ps -o rss= -p "$p" 2>/dev/null | tr -d ' ' || true)"
    if [ -n "${kb:-}" ]; then
      total=$(( total + kb ))
      count=$(( count + 1 ))
    fi
  done
  printf '%s,%s,%s,%s\n' "$(date +%s)" "$(date -u +%FT%TZ)" "$count" "$total" >> "$OUT"
  sleep "$INTERVAL"
done

# run-with-sampling.sh の抜粋
claude -p "$PROMPT" --output-format stream-json > run.log 2>&1 &
CLAUDE_PID=$!
 
./rss-sample.sh "$CLAUDE_PID" "metrics/rss-$(date +%Y%m%d-%H%M%S).csv" 15 &
SAMPLER_PID=$!
 
wait "$CLAUDE_PID"
kill "$SAMPLER_PID" 2>/dev/null || true

#!/usr/bin/env python3
# rss-watchdog.py — CSV を読み、ローリング中央値+MAD で逸脱を検知する
import csv, sys, statistics
 
WINDOW = 20          # 直近サンプル数
K = 6.0              # しきい値の係数（MAD の何倍まで許すか）
MIN_SAMPLES = 8      # 基準を作るのに最低限必要なサンプル数
 
def mad(xs, med):
    return statistics.median([abs(x - med) for x in xs]) or 1.0
 
def main(path):
    rss = []
    with open(path) as f:
        for row in csv.DictReader(f):
            rss.append(int(row["rss_kb"]))
 
    if len(rss) < MIN_SAMPLES:
        print("not enough samples"); return 0
 
    # 立ち上がり直後を除いた安定区間を基準にする
    baseline = rss[2:2 + WINDOW] if len(rss) >= 2 + WINDOW else rss[2:]
    med = statistics.median(baseline)
    spread = mad(baseline, med)
 
    latest = rss[-1]
    threshold = med + K * spread
    drift = (latest - med) / med * 100
 
    print(f"baseline_median={med/1024:.0f}MB latest={latest/1024:.0f}MB "
          f"threshold={threshold/1024:.0f}MB drift={drift:+.1f}%")
 
    if latest > threshold:
        print("ALERT: RSS drifted above rolling baseline")
        return 1
    return 0
 
if __name__ == "__main__":
    sys.exit(main(sys.argv[1]))

#!/usr/bin/env bash
# segmented-run.sh — 長いジョブを境界付きセグメントに割って回す
set -euo pipefail
 
JOBS=("記事A生成" "記事B生成" "記事C生成" "記事D生成")
SEGMENT_SIZE=2   # 1セグメントあたりのジョブ数
 
i=0
session_id=""
while [ "$i" -lt "${#JOBS[@]}" ]; do
  batch=("${JOBS[@]:i:SEGMENT_SIZE}")
  prompt="$(printf '%s\n' "${batch[@]}")"
 
  # 文脈の連続が必要なら --resume、独立なら省略
  if [ -n "$session_id" ]; then
    claude -p "$prompt" --resume "$session_id" --output-format stream-json > "seg-$i.log" 2>&1
  else
    claude -p "$prompt" --output-format stream-json > "seg-$i.log" 2>&1
  fi
 
  # 次セグメントへ。プロセスは毎回終了するので RSS はここでリセットされる
  session_id="$(grep -o '"session_id":"[^"]*"' "seg-$i.log" | head -1 | cut -d'"' -f4 || true)"
  i=$(( i + SEGMENT_SIZE ))
done

# Before: 全部を一本のセッションに積む（RSS が右肩上がりになりやすい）
claude -p "$(printf '%s\n' "${ALL_JOBS[@]}")" --output-format stream-json > run.log 2>&1

# After: セグメントに割り、切れ目でプロセスを終了させる（各セグメント先頭で RSS がリセット）
for batch in "${SEGMENTS[@]}"; do
  claude -p "$batch" --output-format stream-json > "seg.log" 2>&1
done