使用Python往Elasticsearch插入数据
2017-11-14 00:00
363 查看
在这里,我使用Elasticsearch官方推荐
安装elasticsearch插件
1.index
这是很简单的一个插入数据的方法,每条数据调用一个
2.bulk
一次性插入多条数据的方法
elasticsearch第三方包来讲述插入数据的两种方法。
安装elasticsearch插件
pip install elasticsearch
1.index
这是很简单的一个插入数据的方法,每条数据调用一个
index方法,代码如下
rom datetime import datetime from elasticsearch import Elasticsearch es = Elasticsearch( "localhost:9200" ) data = { "@timestamp" : datetime.now().strftime( "%Y-%m-%dT%H:%M:%S.000+0800" ), "name" : "英语", "count" : "10" } es.index( index="textbook", doc_type="book", body=data )
2.bulk
一次性插入多条数据的方法
from datetime import datetime from elasticsearch import Elasticsearch import elasticsearch.helpers import random es = Elasticsearch( "localhost:9200" ) package = [] for i in range( 10 ): row = { "@timestamp":datetime.now().strftime( "%Y-%m-%dT%H:%M:%S.000+0800" ), "name" : "英语"+str(i), "count" : random.randint( 1, 100 ) } package.append( row ) actions = [ { '_op_type': 'index', '_index': "textbook", //index '_type': "book", //type '_source': d } for d in package ] elasticsearch.helpers.bulk( es, action )
相关文章推荐
- 使用Python往Elasticsearch插入数据
- Python MySQLdb 使用utf-8 编码插入中文数据
- python使用MySQLdb向mySQL批量插入数据的方法
- python数据库操作常用功能使用详解(创建表/插入数据/获取数据)
- Python中使用MySQLdb插入数据中文及变量问题
- Python MySQLdb 使用utf-8 编码插入中文数据
- Python MySQLdb 使用utf-8 编码插入中文数据
- python数据库操作常用功能使用详解(创建表/插入数据/获取数据)
- docker(7):使用python 连接数据库,插入并查询数据--link
- 面面观 | 使用python 连接数据库,插入并查询数据--link
- 使用python操作elasticsearch实现监控数据及kibana分析
- (冲突)Python中使用pymysql插入中文数据问题
- python 使用 mysqldb 批量插入数据
- 使用python向MySQL数据库中插入数据时报错UnicodeEncodeError的解决办法
- 使用Python操作Elasticsearch数据索引的教程
- 使用Python创建MySQL数据库实现字段动态添加以及动态的插入数据
- Python3.4下使用pymysql插入数据后没有反应的问题
- elasticsearch 重建索引 使用python迁移索引数据 reindex
- 实时数据之python操作elasticsearch监控数据插入图表分析
- 使用Python进行Elasticsearch数据索引