我已经使用Python asyncio和aiohttp 成功构建了一个RESTful微服务,它监听POST事件以从各种馈送器收集实时事件.
然后,它构建一个内存中结构,以便在嵌套的defaultdict/deque结构中缓存最后24h的事件.
现在我想定期检查该结构到光盘,最好使用泡菜.
由于内存结构可能> 100MB,我想避免在检查结构所需的时间内阻止我的传入事件处理.
我宁愿创建结构的快照拷贝(例如深度拷贝),然后花时间将其写入磁盘并在预设的时间间隔内重复.
我一直在寻找关于如何组合线程的例子(并且是一个线程甚至是最好的解决方案吗?)和asyncio用于那个目的但找不到能帮助我的东西.
任何开始使用的指针都非常感谢!