博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
使用Python往Elasticsearch插入数据
阅读量:7212 次
发布时间:2019-06-29

本文共 1073 字,大约阅读时间需要 3 分钟。

hot3.png

在这里,我使用Elasticsearch官方推荐elasticsearch第三方包来讲述插入数据的两种方法。

安装elasticsearch插件

pip install elasticsearch

1.index 

这是很简单的一个插入数据的方法,每条数据调用一个index方法,代码如下

rom datetime import datetimefrom elasticsearch import Elasticsearches = 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 datetimefrom elasticsearch import Elasticsearchimport elasticsearch.helpersimport randomes = 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 )

 

转载于:https://my.oschina.net/liuyuantao/blog/1573224

你可能感兴趣的文章
创成汇2019年参加创新创业大赛都能获得什么?
查看>>
vue双向数据绑定原理
查看>>
美研究最新生物活性玻璃 可消灭致命的细菌
查看>>
内部类
查看>>
Vue中数组赋值问题
查看>>
APK path is not specified for module
查看>>
Linux运维宝典:最常用的150个命令汇总
查看>>
使用RecycleView实现无限滚动的日历
查看>>
Golang Failpoint 的设计与实现
查看>>
小微贷是美团的上坡之路?
查看>>
js 将线性数据转为树形
查看>>
java B2B2C 源码 多级分销Springcloud多租户电子商城系统- 整合企业架构的技术点(二)...
查看>>
微信小程序
查看>>
区块链+金融
查看>>
阿里开发者招聘节 | 面试题14:如何实现两金额数据相加(最多小数点两位)...
查看>>
一些不错的文章
查看>>
Python爬虫常见面试题(二)
查看>>
【译】Web Components简介
查看>>
java生成缩略图类源码
查看>>
java虚拟机
查看>>