Kevin Adametz
6a34ab48ee
Bisher lief pro Seitenaufruf ein UPDATE press_releases SET hits = hits + 1 im Request. Auf der über 1 GB großen Tabelle blockiert dieser Schreibzugriff, sobald dort eine Schemaänderung läuft — die wartenden Requests belegten dabei PHP-FPM-Worker und DB-Verbindungen, bis die ganze Seite stand. Der Request schreibt jetzt nur noch in die kleine Append-Tabelle press_release_events, und selbst dabei wird jeder Fehler geschluckt und gemeldet: Ein Aufruf-Zähler darf eine Seite niemals langsamer oder kaputt machen. Die Summierung in press_releases.hits übernimmt gebündelt der Scheduler. Der Fortschritt läuft über eine Wasserstandsmarke (höchste bereits verbuchte Event-ID) statt über einen Zwischenspeicher, damit bei einem Neustart kein Aufruf verloren geht. Zähler und Marke werden je Durchgang gemeinsam committet — sonst wäre nur der Durchgang wiederanlaufsicher, nicht der Abbruch darin, und der nächste Lauf verbuchte dieselben Aufrufe doppelt. Eine Migration setzt die Marke beim Deploy auf den Ist-Stand; ohne sie würde der erste Lauf den gesamten Altbestand ein zweites Mal aufaddieren. Weil das Log damit mit dem Traffic wächst und als einzige Log-Tabelle des Systems keine Bereinigung hatte, begrenzt press-releases:purge-events es auf einen Aufbewahrungszeitraum (Default 395 Tage = 13 Monate, damit der Vorjahresmonats-Vergleich möglich bleibt). Gelöscht wird ausschließlich unterhalb der Wasserstandsmarke — alles darüber ist noch nicht in hits verbucht und wäre sonst dauerhaft verloren. Fehlt die Marke, bricht der Lauf ab, statt zu raten. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
99 lines
3.3 KiB
PHP
99 lines
3.3 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Models\AppSetting;
|
|
use App\Models\PressReleaseEvent;
|
|
use Illuminate\Console\Command;
|
|
|
|
/**
|
|
* Begrenzt das Ereignis-Log der Pressemitteilungen auf einen
|
|
* Aufbewahrungszeitraum.
|
|
*
|
|
* Seit der Aufruf-Zähler nicht mehr im Request auf `press_releases.hits`
|
|
* schreibt, ist `press_release_events` die Quelle jedes einzelnen
|
|
* Seitenaufrufs — die Tabelle wächst also mit dem Traffic und hatte als
|
|
* einzige Log-Tabelle des Systems keine Bereinigung. Für die Gesamtzahl ist
|
|
* das Log nach der Aggregation nicht mehr nötig (die steckt in `hits`);
|
|
* gebraucht wird es nur noch für den zeitlichen Verlauf in der Absenderansicht.
|
|
*
|
|
* ZWEI SICHERUNGEN, beide zwingend:
|
|
*
|
|
* 1. Gelöscht wird ausschließlich UNTERHALB der Wasserstandsmarke von
|
|
* `press-releases:aggregate-views`. Alles darüber ist noch nicht in `hits`
|
|
* verbucht — würde es hier verschwinden, wären diese Aufrufe dauerhaft
|
|
* verloren. Fehlt die Marke, bricht der Lauf ab, statt zu raten.
|
|
* 2. Gelöscht wird in Blöcken. Ein einzelnes DELETE über Millionen Zeilen
|
|
* hielte die Sperre über die gesamte Laufzeit.
|
|
*/
|
|
class PurgePressReleaseEvents extends Command
|
|
{
|
|
protected $signature = 'press-releases:purge-events
|
|
{--days= : Ereignisse älter als X Tage löschen (Standard: config press_releases.events.retention_days)}
|
|
{--chunk=5000 : Zeilen je Durchgang}
|
|
{--dry-run : Nur zählen, nichts löschen}';
|
|
|
|
protected $description = 'Begrenzt das Ereignis-Log der Pressemitteilungen auf den Aufbewahrungszeitraum.';
|
|
|
|
public function handle(): int
|
|
{
|
|
$days = (int) ($this->option('days') ?? config('press_releases.events.retention_days'));
|
|
|
|
if ($days < 1) {
|
|
$this->error('Aufbewahrungszeitraum muss mindestens einen Tag betragen.');
|
|
|
|
return self::FAILURE;
|
|
}
|
|
|
|
$watermark = AppSetting::getValue(AggregatePressReleaseViews::WatermarkKey);
|
|
|
|
if ($watermark === null) {
|
|
$this->error(
|
|
'Wasserstandsmarke des Aufruf-Zählers fehlt — es ist unbekannt, welche Ereignisse '
|
|
.'bereits in `hits` verbucht sind. Erst "php artisan press-releases:aggregate-views" laufen lassen.'
|
|
);
|
|
|
|
return self::FAILURE;
|
|
}
|
|
|
|
$watermark = (int) $watermark;
|
|
$cutoff = now()->subDays($days);
|
|
$chunk = max(100, (int) $this->option('chunk'));
|
|
|
|
$expired = PressReleaseEvent::query()
|
|
->where('id', '<=', $watermark)
|
|
->where('created_at', '<', $cutoff);
|
|
|
|
if ($this->option('dry-run')) {
|
|
$this->info(sprintf(
|
|
'[Dry-Run] %d Ereignisse älter als %s und bereits verbucht (Stand Event-ID %d).',
|
|
(clone $expired)->count(),
|
|
$cutoff->format('d.m.Y'),
|
|
$watermark,
|
|
));
|
|
|
|
return self::SUCCESS;
|
|
}
|
|
|
|
$deleted = 0;
|
|
|
|
while (true) {
|
|
$removed = (clone $expired)->limit($chunk)->delete();
|
|
|
|
if ($removed === 0) {
|
|
break;
|
|
}
|
|
|
|
$deleted += $removed;
|
|
}
|
|
|
|
$this->info(sprintf(
|
|
'Ereignis-Log bereinigt: %d Einträge vor dem %s gelöscht (Aufbewahrung %d Tage).',
|
|
$deleted,
|
|
$cutoff->format('d.m.Y'),
|
|
$days,
|
|
));
|
|
|
|
return self::SUCCESS;
|
|
}
|
|
}
|