使用python对ES进行批量操作

这篇具有很好参考价值的文章主要介绍了使用python对ES进行批量操作。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

在kibana中进行批量操作: 

python批量写入es数据库,ElasticSearch,elasticsearch,bulk

使用python代码进行对es进行批量操作

示例代码:

from elasticsearch import Elasticsearch

es = Elasticsearch(hosts='http://127.0.0.1:9200')
# print(es)

doc = [
    {"create": {"_index": "test_index", "_id": "5"}},
    {"doc": {"name": "张三", "id": "1"}},
    {"update": {"_index": "test_index", "_id": "2"}},
    {"doc": {"name": "李四666", "id": "2"}},
    {"update": {"_index": "test_index", "_id": "3"}},
    {"doc": {"name": "王五666", "id": "3"}},
    {"delete": {"_index": "test_index", "_id": "4"}},
]
res = es.bulk(index="test_index", body=doc)
print(res)

运行结果:

python批量写入es数据库,ElasticSearch,elasticsearch,bulk

案例一:

python读取mysql数据写入ES:

参考博文:https://www.jianshu.com/p/c0e42121f054

python 批量导入mysql数据到Elastic Search_追逐时光的博客-CSDN博客 

参考博文:

Python简单实现与ElasticSearch交互插入数据_IT之一小佬的博客-CSDN博客_python 插入es文章来源地址https://www.toymoban.com/news/detail-645615.html

到了这里,关于使用python对ES进行批量操作的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Elasticsearch(五)--ES文档的操作(上)---写入文档

    使用ES构建搜索引擎时需要经常对文档进行操作,除了简单的单条文档操作,有时还需要进行批量操作。我们这章主要学习ES文档的增删改的操作,由于涉及到的代码量会比较多,所以分为3篇文章分别说明文档的这个三个操作。那么我们对文档操作的学习除了在kibana客户端之

    2024年01月16日
    浏览(36)
  • ES: 数据增,删,改,批量操作

    1 指定id 新增 _id =1 新增一条. 此命令重复执行,就是更新id=1的数据 2 不指定id 新增 _id是随机的字符串 此命令重复执行,就是不断新增 3  指定id更新 更新整个文档, 和新增一样 4 按照id,更新文档中部分字段 5 按照id, 使用脚本更新部分字段,支持参数param,支持 拼接更新 6 按照id,

    2024年02月02日
    浏览(28)
  • ES _bulk 批量操作用法

    es 的 bulk 操作,是用来批量发送请求,或者理解为批量操作的。 支持4种操作 bulk 支持多种操作,如下 create 、 index 、 update 、 delete 。 create 如果文档不存在就创建,但如果文档存在就返回错误 index 如果文档不存在就创建,如果文档存在就更新 update 更新一个文档,如果文档

    2024年02月03日
    浏览(33)
  • 【es数据库】python 使用Elasticsearch数据库

    Elasticsearch是一个开源的高扩展性搜索引擎,它可以快速地存储、搜索和分析大量的数据。 使用Python语言和Elasticsearch,可以轻松地创建和操作“数据库”和“数据库表”,而且具备分布式和高扩展性的特点,适用于大规模数据存储与搜索场景。 ES是一种文档数据库,它并不像

    2024年02月12日
    浏览(30)
  • python读取、写入以及删除es数据

    最近这段时间被es所困扰,庆幸最终学会了python操作es,怕以后忘记了,把代码放出来: 1.python读取es数据 2.python删除es数据: 3.python读取txt文档,再写入数据:

    2024年02月12日
    浏览(39)
  • python flat_map字典写入es

    [root@master pyflink]# cat test.txt  aaaaa 111111 bbbbb 222222 ccccc 333333 ddddd 444444 eeeee 555555 [root@master pyflink]# cat test.py  # -*- coding: utf-8 -*- from pyflink.datastream import StreamExecutionEnvironment from pyflink.datastream.functions import  MapFunction, RuntimeContext, KeyedProcessFunction from abc import ABC, abstractmethod from pyfl

    2024年02月09日
    浏览(75)
  • 【Elasticsearch】使用Python完成对ES的插入操作

    1.Python搭建Flask服务,编写ES脚本。 2.通过Java调用Python接口,完成对ES的插入操作。 Elasticsearch 7.16.0 ESObject是一个模板,其中有很多其他的函数。通过Java调用,还可以实现很多操作,如删除、查询等。

    2024年02月15日
    浏览(41)
  • es使用java来批量创建文档和批量删除文档(基于es7.8)

    批量操作实际就是执行 bulk命令 先引入pom依赖: 创建User类 3、然后在名为user的索引里,插入多条数据,在main方法里进行测试: 打印结果是: 下面执行postman进行查询 http://127.0.0.1:9200/user/_search : 下面对指定的id进行批量删除: 执行结果是:

    2024年02月13日
    浏览(37)
  • Java对es进行简单操作

    Java对es进行添加操作 java实现删除 对指定字段进行修改 upsert修改用法:修改文章存在,执行修改,不存在则执行插入

    2024年02月12日
    浏览(34)
  • Filebeat入门及使用-5 读取nginx日志,写入ES,并用kibana展示

    1 安装nginx, 并找到nginx的日志目录,步骤3要使用 2 配置Filebeat的module,在Filebeat中,有大量的module,如mysql,kafka,redis,nginx等,可以简化我们的配置,方便使用。 查看Filebeat支持模块 命令:./filebeat modules list 启动Nginx模块 启动命令:./filebeat modules enable nginx 禁用命令:./fi

    2023年04月12日
    浏览(38)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包