chore(logging): Debug-Logs raus + app.log-Rotation gegen volllaufende Platte
- diagnostic/server.js: die beiden Debug-Logs der ai-box-Fehlersuche entfernt (roher RX-Dump jeder worker_*/sat_hello-Nachricht + 'worker_hello empfangen' bei jedem 30s-Resend). Die Flotte laeuft, der Firehose kann weg. - bridge/aria_bridge.py: /shared/logs/app.log (JSONL, wuchs unbegrenzt bei jeder App-Log-Zeile) rotiert jetzt bei >5 MB auf die letzten 2000 Zeilen (Muster wie metrics._maybe_rotate). RVS selbst loggt nur Lifecycle (Connect/Disconnect) — kein Message-Firehose, unveraendert. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
+11
-1
@@ -2806,8 +2806,18 @@ class ARIABridge:
|
|||||||
"message": payload.get("message", ""),
|
"message": payload.get("message", ""),
|
||||||
"stack": payload.get("stack", ""),
|
"stack": payload.get("stack", ""),
|
||||||
}
|
}
|
||||||
with (log_dir / "app.log").open("a", encoding="utf-8") as f:
|
log_path = log_dir / "app.log"
|
||||||
|
with log_path.open("a", encoding="utf-8") as f:
|
||||||
f.write(json.dumps(line, ensure_ascii=False) + "\n")
|
f.write(json.dumps(line, ensure_ascii=False) + "\n")
|
||||||
|
# Rotation: app.log waechst sonst unbegrenzt (jede App-Log-Zeile
|
||||||
|
# haengt an). Bei >5 MB die letzten 2000 Zeilen behalten.
|
||||||
|
try:
|
||||||
|
if log_path.stat().st_size > 5 * 1024 * 1024:
|
||||||
|
tail = log_path.read_text(encoding="utf-8",
|
||||||
|
errors="ignore").splitlines()[-2000:]
|
||||||
|
log_path.write_text("\n".join(tail) + "\n", encoding="utf-8")
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
logger.info("[app-log] %s %s: %s",
|
logger.info("[app-log] %s %s: %s",
|
||||||
line["level"], line["scope"], line["message"][:120])
|
line["level"], line["scope"], line["message"][:120])
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
|
|||||||
@@ -1018,12 +1018,6 @@ function connectRVS(forcePlain) {
|
|||||||
ws.on("message", (raw) => {
|
ws.on("message", (raw) => {
|
||||||
try {
|
try {
|
||||||
const msg = JSON.parse(raw.toString());
|
const msg = JSON.parse(raw.toString());
|
||||||
// DEFINITIVE Roh-Diagnose: jede worker_*/sat_hello-Nachricht loggen, BEVOR
|
|
||||||
// irgendein Handler greift — zeigt eindeutig, ob sie ueberhaupt ankommt.
|
|
||||||
if (msg.type && (msg.type.indexOf("worker") === 0 || msg.type === "sat_hello")) {
|
|
||||||
const p = msg.payload || {};
|
|
||||||
log("info", "rvs", `RX ${msg.type} <- ${p.instanceId || p.id || "?"} (svc=${p.service || "-"})`);
|
|
||||||
}
|
|
||||||
if (msg.type === "chat" && msg.payload) {
|
if (msg.type === "chat" && msg.payload) {
|
||||||
const sender = msg.payload.sender || "?";
|
const sender = msg.payload.sender || "?";
|
||||||
// Eigene Nachrichten ignorieren (Echo)
|
// Eigene Nachrichten ignorieren (Echo)
|
||||||
@@ -1080,7 +1074,6 @@ function connectRVS(forcePlain) {
|
|||||||
} else if (msg.type === "worker_hello") {
|
} else if (msg.type === "worker_hello") {
|
||||||
// Ein Compute-Worker (GPU-Dienst) meldet sich mit seiner Identitaet.
|
// Ein Compute-Worker (GPU-Dienst) meldet sich mit seiner Identitaet.
|
||||||
const p = msg.payload || {};
|
const p = msg.payload || {};
|
||||||
log("info", "rvs", `worker_hello empfangen: ${p.instanceId || "?"} (service=${p.service || "?"}, models=${JSON.stringify(p.models || [])})`);
|
|
||||||
if (p.instanceId) {
|
if (p.instanceId) {
|
||||||
const prev = workers.get(p.instanceId) || {};
|
const prev = workers.get(p.instanceId) || {};
|
||||||
// War die Box vor diesem hello schon frisch gesehen? worker_hello wird
|
// War die Box vor diesem hello schon frisch gesehen? worker_hello wird
|
||||||
|
|||||||
Reference in New Issue
Block a user