2019独角兽企业重金招聘Python工程师标准>>>

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

安装elasticsearch插件

pip install elasticsearch

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

rom datetime import datetime
from 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 datetime
from elasticsearch import Elasticsearch
import elasticsearch.helpers
import 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

使用Python往Elasticsearch插入数据相关推荐

  1. python向es写入大量数据_使用Python-elasticsearch-bulk批量快速向elasticsearch插入数据_李谦的博客-CSDN博客...

    from elasticsearch import Elasticsearch from elasticsearch import helpers import pymysql import time ...

  2. python将ElasticSearch索引数据读入pandas dataframe实战

    python将ElasticSearch索引数据读入pandas dataframe实战 # 导入基础包和库 import pandas as pdpd.set_option('display.max ...

  3. python连接elasticsearch查询数据

    python连接elasticsearch获取数据 原文:https://blog.csdn.net/ziqiaowang/article/details/54972279 # -*- encodin ...

  4. 已解决Python向数据库插入数据的字符串中含有单引号或双引号报错

    已解决Python向数据库插入数据的字符串中含有单引号或双引号报错:(102, b"Incorrect syntax near 'S'.DB-Lib error message 20018, ...

  5. Python连接mysql,插入数据时不报错,但是没有插入进去

    Python连接mysql,插入数据时不报错,但是没有插入进去在connect方法中,设置 autocommit =True conn=pymysql.connect(host=host_db,use ...

  6. python操作mysql插入数据

    python操作mysql插入数据 首先安装pymysql这个库 pycharm连接数据库 操作mysql语句 连接数据库 插入数据 由于有时候,数据存在excel表格中,需要借助python去读取数 ...

  7. Python Elasticsearch 插入数据

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

  8. python使用elasticsearch维护数据_使用Python对ElasticSearch获取数据及操作

    #!/usr/bin/env python#-*- coding: utf-8 -*- """@Time : 2018/7/4 @Author : LiuXueWen @ ...

  9. python 定义一个插入数据(可以插入到每个表中)通用的方法

    前提置要: 想要写一个方法,这个方法是插入数据到数据表的方法,只需要提供表名称,字段名称,还有插入的值,只要调用这个方法就可以自动帮助你插入数据 以下是不断实践优化出来 原本的插入数据库中的代码应该是 ...

最新文章

  1. 安装Oracle 10g sys,system 密码忘记设置解决办法
  2. Maven的简单使用
  3. FCN 学习: Semantic Segmentation
  4. 史上最快消息内核——ZeroMQ
  5. win10一直卡在自动修复_分享:win10自动修复过程中无法正确启动怎么办?
  6. Maven学习(三)-----Maven本地资源库
  7. 聊天宝解散罗永浩退出;三大运营商回应提速降费;天猫 iPhone XS 最高降 2000 | 极客头条...
  8. 从SDE库文件手工删除SDE图层(转载)
  9. t470键盘拆解_Thinkpad 二手T470笔记本拆解|支持双硬盘|拆机教程
  10. MATLAB 输出当前时间
  11. 技术至简-8:调制解调到底是什么样的数学运算?---从时域和频域两个角度看调制解调的本质
  12. 基于不确定性量化的非精确概率可靠性理论
  13. 360木马查杀后mysql数据不能启动
  14. 苹果手机10秒解除锁屏_苹果密码忘了不想刷机怎么办_苹果手机10秒解除锁屏
  15. 服务器虚拟成多人同时使用,同一台云服务器多人同时登录吗
  16. 智能音箱背后的自然语言理解和知识图谱技术
  17. asp.net 文件操作
  18. 隐藏微信小程序左上角的返回或home按钮 wx.hideHomeButton
  19. linux进去vi编辑器执行c语言代码,VI编辑器的使用与Linux操作系统下C语言的使用...
  20. caida的测量工具scamper

热门文章

  1. Linux系统--CentOS 7.6.1810 安装 fping 3.15
  2. UVa 1605 - Building for UN
  3. git在跟踪bug中的使用
  4. 【更新至2.0】cnbeta 根据评论数提取热喷新闻的js脚本
  5. C常量指针 与指针常量区别
  6. LG电子计划到2010年实现利润翻番
  7. django+nginx+uwsgi项目部署文档整理
  8. Oracle设置和修改system和scott的口令,并且如何连接到system和scott模式下
  9. C# 关闭当前窗口打开另一窗口
  10. macbook linux 双系统,MacBook Air 安装 Ubuntu 双系统