Kapitel 13/Tutorial.md aktualisiert
This commit is contained in:
@@ -801,88 +801,85 @@ Das folgende Schaubild zeigt dir die konkrete Verkabelung
|
|||||||
|
|
||||||
```bash
|
```bash
|
||||||
#!/usr/bin/env bash
|
#!/usr/bin/env bash
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
|
|
||||||
. /etc/clipper/clipper.env
|
. /etc/clipper/clipper.env
|
||||||
|
|
||||||
ID="${1:?need VOD id}"
|
ID="${1:?need VOD id}"
|
||||||
|
|
||||||
VOD_IN_MP4="${CLIPPER_OUT}/${ID}/original/${ID}.mp4"
|
VOD_IN_MP4="${CLIPPER_OUT}/${ID}/original/${ID}.mp4"
|
||||||
OUT_BASE="${CLIPPER_OUT}/${ID}"
|
OUT_BASE="${CLIPPER_OUT}/${ID}"
|
||||||
ANALYSIS="${OUT_BASE}/analysis"
|
ANALYSIS="${OUT_BASE}/analysis"
|
||||||
LOGDIR="${CLIPPER_LOG}/${ID}"
|
LOGDIR="${CLIPPER_LOG}/${ID}"
|
||||||
|
|
||||||
mkdir -p "$ANALYSIS" "$LOGDIR"
|
mkdir -p "$ANALYSIS" "$LOGDIR"
|
||||||
exec > >(tee -a "${LOGDIR}/analyze.log") 2>&1
|
exec > >(tee -a "${LOGDIR}/analyze.log") 2>&1
|
||||||
echo "== Analyze $ID =="
|
echo "== Analyze $ID =="
|
||||||
|
|
||||||
# 1) Szenenwechsel
|
echo "[FFMPEG] Szenewechselanalyse läuft..."
|
||||||
echo "[FFMPEG] Szenewechselanalyse läuft..."
|
ffmpeg -hide_banner -loglevel error -i "${VOD_IN_MP4}" \
|
||||||
ffmpeg -hide_banner -loglevel error -i "${VOD_IN_MP4}" \
|
-vf "scale=-2:360,select=gt(scene\,0.30),showinfo" -an -f null - \
|
||||||
-vf "scale=-2:360,select=gt(scene\,0.30),showinfo" -an -f null - \
|
2> "${LOGDIR}/sceneinfo.log"
|
||||||
2> "${LOGDIR}/sceneinfo.log"
|
|
||||||
|
|
||||||
# 2) Audio-Statistik
|
echo "[FFMPEG] Audiostatistik läuft..."
|
||||||
echo "[FFMPEG] Audiostatistik läuft..."
|
ffmpeg -hide_banner -loglevel error -i "${VOD_IN_MP4}" \
|
||||||
ffmpeg -hide_banner -loglevel error -i "${VOD_IN_MP4}" \
|
-vn -ac 1 -ar 16000 \
|
||||||
-vn -ac 1 -ar 16000 \
|
-af "astats=metadata=1:reset=2,ametadata=print:key=lavfi.astats.Overall.RMS_level" \
|
||||||
-af "astats=metadata=1:reset=2,ametadata=print:key=lavfi.astats.Overall.RMS_level" \
|
-f null - \
|
||||||
-f null - \
|
2> "${LOGDIR}/astats.log" || true
|
||||||
2> "${LOGDIR}/astats.log" || true
|
|
||||||
|
|
||||||
# 3) Logs → candidates.json
|
ANALYSIS="$ANALYSIS" LOGDIR="$LOGDIR" python3 - <<'PY'
|
||||||
ANALYSIS="$ANALYSIS" LOGDIR="$LOGDIR" python3 - <<'PY'
|
import os, re, json, sys
|
||||||
import os, re, json, sys
|
from datetime import datetime
|
||||||
from datetime import datetime
|
|
||||||
|
|
||||||
def log(msg):
|
def log(msg):
|
||||||
timestamp = datetime.now().strftime("%F %T")
|
timestamp = datetime.now().strftime("%F %T")
|
||||||
print(f"[PY] [{timestamp}] {msg}")
|
print(f"[PY] [{timestamp}] {msg}")
|
||||||
|
|
||||||
out = os.environ["ANALYSIS"]
|
out = os.environ["ANALYSIS"]
|
||||||
logdir = os.environ["LOGDIR"]
|
logdir = os.environ["LOGDIR"]
|
||||||
|
|
||||||
scene_ts = []
|
scene_ts = []
|
||||||
log("Lese sceneinfo.log...")
|
log("Lese sceneinfo.log...")
|
||||||
try:
|
try:
|
||||||
with open(os.path.join(logdir, "sceneinfo.log"), errors="ignore") as f:
|
with open(os.path.join(logdir, "sceneinfo.log"), errors="ignore") as f:
|
||||||
for line in f:
|
for line in f:
|
||||||
m = re.search(r"pts_time:([0-9]+(?:\.[0-9]+)?)", line)
|
m = re.search(r"pts_time:([0-9]+(?:\.[0-9]+)?)", line)
|
||||||
if m:
|
if m:
|
||||||
scene_ts.append(float(m.group(1)))
|
scene_ts.append(float(m.group(1)))
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log(f"Fehler beim Lesen von sceneinfo.log: {e}")
|
log(f"Fehler beim Lesen von sceneinfo.log: {e}")
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
|
|
||||||
log(f"{len(scene_ts)} Szenenwechsel gefunden.")
|
log(f"{len(scene_ts)} Szenenwechsel gefunden.")
|
||||||
|
|
||||||
has_audio = False
|
has_audio = False
|
||||||
ap = os.path.join(logdir, "astats.log")
|
ap = os.path.join(logdir, "astats.log")
|
||||||
if os.path.exists(ap):
|
if os.path.exists(ap):
|
||||||
log("Prüfe astats.log auf Audiodaten...")
|
log("Prüfe astats.log auf Audiodaten...")
|
||||||
with open(ap, errors="ignore") as f:
|
with open(ap, errors="ignore") as f:
|
||||||
has_audio = "RMS_level" in f.read()
|
has_audio = "RMS_level" in f.read()
|
||||||
|
|
||||||
log(f"Audioanalyse: {'gefunden' if has_audio else 'nicht vorhanden'}")
|
log(f"Audioanalyse: {'gefunden' if has_audio else 'nicht vorhanden'}")
|
||||||
|
|
||||||
cands = [{
|
cands = [{
|
||||||
"start": max(0.0, t - 2.0),
|
"start": max(0.0, t - 2.0),
|
||||||
"end": t + 6.0,
|
"end": t + 6.0,
|
||||||
"score": round(0.6 + (0.1 if has_audio else 0), 2),
|
"score": round(0.6 + (0.1 if has_audio else 0), 2),
|
||||||
"tags": ["scene-cut"] + (["audio-peak"] if has_audio else [])
|
"tags": ["scene-cut"] + (["audio-peak"] if has_audio else [])
|
||||||
} for t in scene_ts]
|
} for t in scene_ts]
|
||||||
|
|
||||||
target = os.path.join(out, "candidates.json")
|
target = os.path.join(out, "candidates.json")
|
||||||
try:
|
try:
|
||||||
with open(target, "w", encoding="utf-8") as f:
|
with open(target, "w", encoding="utf-8") as f:
|
||||||
json.dump(cands, f, ensure_ascii=False, indent=2)
|
json.dump(cands, f, ensure_ascii=False, indent=2)
|
||||||
log(f"{len(cands)} Kandidaten gespeichert → {target}")
|
log(f"{len(cands)} Kandidaten gespeichert → {target}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log(f"Fehler beim Schreiben von candidates.json: {e}")
|
log(f"Fehler beim Schreiben von candidates.json: {e}")
|
||||||
sys.exit(2)
|
sys.exit(2)
|
||||||
PY
|
PY
|
||||||
|
|
||||||
echo "== Done $ID =="
|
echo "== Done $ID =="
|
||||||
```
|
```
|
||||||
|
|
||||||
### Ergebnis
|
### Ergebnis
|
||||||
|
|||||||
Reference in New Issue
Block a user