今天小编就为大家分享一篇python消费kafka数据批量插入到es的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

1、es的批量插入 这是为了方便后期配置的更改，把配置信息放在logging.conf中 用elasticsearch来实现批量操作，先安装依赖包，sudo pip install Elasticsearch2 from elasticsearch import Elasticsearch class ImportEsData: logging.config.fileConfig(logging.conf) logger = logging.getLogger(msg) def _