He construido con éxito unMicroservicio RESTful con Python asyncio y aiohttp que escucha un evento POST para recopilar eventos en tiempo real de varios alimentadores.

Luego construye una estructura en memoria para almacenar en caché las últimas 24 horas de eventos en una estructura anulada defaultdict / deque.

Ahora me gustaría revisar periódicamente esa estructura en el disco, preferiblemente usando pickle.

Dado que la estructura de la memoria puede ser> 100 MB, me gustaría evitar retrasar el procesamiento de mi evento entrante por el tiempo que tarda en verificar la estructura.

Prefiero crear una copia de instantánea (por ejemplo, copia profunda) de la estructura y luego tomarme mi tiempo para escribirla en el disco y repetirla en un intervalo de tiempo preestablecido.

He estado buscando ejemplos sobre cómo combinar hilos (¿y es un hilo incluso la mejor solución para esto?) Y asyncio para ese propósito, pero no pude encontrar algo que me ayudara.

¡Cualquier sugerencia para comenzar es muy apreciada!