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 __init__(self,hosts,index,type): self.es =