Eu construí com sucesso umMicrosserviço RESTful com Python assíncio e aiohttp que escuta um evento POST para coletar eventos em tempo real de vários alimentadores.

Em seguida, ele cria uma estrutura na memória para armazenar em cache as últimas 24 horas de eventos em uma estrutura defaultdict / deque aninhada.

Agora eu gostaria de checar periodicamente essa estrutura para o disco, de preferência usando pickle.

Como a estrutura da memória pode ter mais de 100 MB, gostaria de evitar atrasar o processamento do evento recebido pelo tempo que leva para verificar a estrutura.

Prefiro criar uma cópia de instantâneo (por exemplo, cópia em profundidade) da estrutura e, em seguida, demorar algum tempo para gravá-la no disco e repetir em um intervalo de tempo predefinido.

Eu tenho procurado por exemplos de como combinar threads (e ainda é a melhor solução para isso?) E assíncrono para esse fim, mas não consegui encontrar algo que me ajudasse.

Quaisquer sugestões para começar são muito apreciadas!