本文章以Django框架配置为例，主要功能使用了cmanaha的代码，做了些自己项目的适配 原理就是继承logging.Handler重写emit，实现日志刷入ES的逻辑 其中个人感觉设计的比较好的地方是引入了多线程的定时器和锁，通过列表容器实现批量刷入ES，这里也用到了ES的Bulk方法...

最初平台上要记录用户操作记录的地方也不是很多，我就放到MySQL中了，随着平台的功能越来越多，发现写关系型数据库太累了，也不便于扩展。查询效率也不高，就想到了ES 这里针对ES做了一次封装，为了更好的去使用他 Python #!/usr/bin/e...

上一篇文章 我们介绍了：Python获取CoinMarketCap的token交易信息 本文章我们就实战一下：获取的实时交易信息放到elasticsearch这种时间序列数据存储里 Python from elasticsearch import Elasticsearch import elasticsearch.helper...

官方的示例已经非常清楚了，这里为什么还要再封装次呢，其实是为了调用、维护更方便。 我这里使用的是7.0.2的版本，需要注意的是6与7在search时参数会有一些区别 Python #!/usr/bin/env python # -*- coding: utf-8 -*- # @Author ...