Persistenzsystem
Positionswiederherstellung
Die Handelsengine enthält eine eingebaute Persistenzschicht, die dafür ausgelegt ist, Abstürze, Neustarts und unerwartete Herunterfahrungen zu überstehen, ohne den kritischen Handelszustand zu verlieren.
Alle aktiven Handelsdaten werden automatisch auf der Festplatte unter Verwendung der benutzerdefinierten PersistentMap-Komponente gespeichert.
Das System speichert persistent:
- •Aktive Positionen
- •Ausstehende Orders
- •Symbol-Handelskontrollen
- •Risikomanagementzustände
Wenn der Bot neu startet:
- 1.Persistenzdateien werden automatisch geladen.
- 2.Der vorherige Handelszustand wird in den Speicher zurückgeladen.
- 3.Aktive Positionen werden sofort weiter überwacht.
- 4.Ausstehende Orders verfolgen weiterhin den Ausführungsstatus der Exchange.
- 5.Risikokontrollen bleiben erhalten.
Dies ermöglicht es dem Bot, den Betrieb nach Unterbrechungen ohne manuelles Eingreifen fortzusetzen.
Zweck:
- •Verhindert den Verlust des Überblicks über offene Positionen
- •Bewahrt die Handelskontinuität
- •Hält einen genauen Risikomanagementzustand aufrecht
- •Vermeidet doppelte Einstiege nach einem Neustart
Datenbankstruktur
Die Persistenzschicht verwendet eine leichtgewichtige, lokale dateibasierte Speicherung, die auf der Python-Pickle-Serialisierung aufbaut.
Jede persistente Struktur wird in einer unabhängigen Datei gespeichert:
- •
active_positions.pkl - •
pending_orders.pkl - •
symbol_controls.pkl
Die Architektur ist bewusst minimalistisch und für latenzarme Handelssysteme optimiert.
Aktive Positionen
Speichert aktuell offene Trades.
Jede Position enthält:
- •Handelssymbol
- •Positionsseite
- •Menge
- •Einstiegspreis
- •Stop-Loss-Preis
- •Take-Profit-Preis
- •Trailing-Stop-Status
- •Zeitstempel
Zweck:
- •Fortsetzung des Positionsmanagements nach Neustart
- •Fortsetzung der Stop-Loss- und Trailing-Logik
- •Bewahrt den genauen Einstiegszustand
Ausstehende Orders
Speichert Exchange-Orders, die auf eine Ausführungsbestätigung warten.
Jede Order enthält:
- •Symbol
- •Orderseite
- •Ordertyp
- •Menge
- •Exchange-Order-ID
- •Aktueller Status
Zweck:
- •Verhindert doppelte Orders
- •Fortsetzung der Überwachung des Exchange-Ausführungszustands
- •Wiederherstellung unvollständiger Orderabläufe
Symbolsteuerungen
Speichert Laufzeit-Handelsberechtigungen und Schutzstatus.
Jedes Symbol kann enthalten:
- •Kaufaktivierungsstatus
- •Verkaufsaktivierungsstatus
- •Deaktivierungsgründe
- •Risikosperrzustände
Zweck:
- •Bewahrt automatisierte Risikobeschränkungen
- •Verhindert versehentliche Reaktivierung nach Neustart
Absturzwiederherstellungslogik
Das Persistenzsystem ist für die automatische Wiederherstellung während der folgenden Ereignisse ausgelegt:
- •Prozessabstürze
- •Serverneustarts
- •VPS-Ausfälle
- •Stromausfälle
- •Unerwartete Ausnahmen
Asynchrone Persistenz
Alle Schreibvorgänge werden in einem dedizierten Hintergrundthread verarbeitet.
Funktionen:
- •Nicht blockierende Handelsausführung
- •Kontinuierliches automatisches Speichern
- •Warteschlangenbasiertes Speicherplanung
Zweck:
- •Verhindert Handelsverzögerungen durch Festplattenoperationen.
Atomares Dateispeichern
Das System verwendet atomaren Dateiersatz für maximale Datensicherheit.
Speicherablauf:
- 1.Daten werden in eine temporäre .tmp-Datei geschrieben.
- 2.Die temporäre Datei wird vollständig abgeschlossen.
- 3.Die Datei wird atomar in die endgültige Persistenzdatei umbenannt.
Zweck:
- •Verhindert beschädigte Persistenzdateien während Abstürzen oder unterbrochenen Schreibvorgängen.
Speicherdeduplizierung
Die Persistenzwarteschlange entfernt automatisch veraltete Speicheranforderungen.
Verhalten:
- •Nur der neueste Zustand wird persistiert.
- •Redundante Festplattenschreibvorgänge werden übersprungen.
Zweck:
- •Reduziert die Festplattennutzung
- •Verbessert die Leistung bei hoher Aktualisierungshäufigkeit
Automatisches Zustandsneuladen
Während des Startvorgangs:
- 1.Persistenzdateien werden erkannt.
- 2.Serialisierte Objekte werden zurück in den Speicher geladen.
- 3.Die Handelsengine setzt die Überwachung sofort fort.
Wenn Persistenzdateien nicht existieren:
- •Ein neuer, leerer Speicher wird automatisch initialisiert.
Threadsicherheit
Die Persistenzengine verwendet interne Synchronisationssperren während Speichervorgängen.
Funktionen:
- •Parallelitätssichere Schreibvorgänge
- •Sicherer Multithread-Zugriff
- •Geschützter Dateiersatz
Zweck:
- •Stellt die Konsistenz zwischen Handels-Threads und Persistenzschicht sicher
Schutz beim kontrollierten Herunterfahren
Vor dem Herunterfahren:
- 1.Ein endgültiger Speichervorgang wird erzwungen.
- 2.Die Speicherwarteschlange wird vollständig geleert.
- 3.Der Hintergrund-Persistenz-Thread wird sicher gestoppt.
Zweck:
- •Garantiert, dass der neueste Handelszustand vor dem Beenden auf die Festplatte geschrieben wird.