Ich habe erfolgreich ein @ gebaRESTful microservice mit Python asyncio und aiohttp, die ein POST-Ereignis abhören, um Echtzeitereignisse von verschiedenen Feedern zu sammeln.

Anschließend wird eine In-Memory-Struktur erstellt, um die letzten 24 Stunden von Ereignissen in einer verschachtelten Defaultdict / Deque-Struktur zwischenzuspeichern.

Nun möchte ich diese Struktur regelmäßig auf Disc überprüfen, vorzugsweise mit Pickle.

Da die Speicherstruktur> 100 MB sein kann, möchte ich vermeiden, dass die Verarbeitung eingehender Ereignisse für die Zeit unterbrochen wird, die zum Überprüfen der Struktur erforderlich ist.

Ich möchte lieber eine Snapshot-Kopie (z. B. Deepcopy) der Struktur erstellen und mir dann die Zeit nehmen, sie auf die Festplatte zu schreiben und in einem voreingestellten Zeitintervall zu wiederholen.

Ich habe nach Beispielen für das Kombinieren von Threads (und ist ein Thread auch die beste Lösung dafür?) Und Asyncio für diesen Zweck gesucht, konnte jedoch nichts finden, was mir helfen würde.

Alle Hinweise zum Einstieg sind sehr willkommen!