使用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文档的操作(上)---写入文档

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

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

    2024年01月16日
    浏览(11)
  • ES _bulk 批量操作用法

    ES _bulk 批量操作用法

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

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

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

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

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

    2024年02月12日
    浏览(11)
  • 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日
    浏览(6)
  • 【Elasticsearch】使用Python完成对ES的插入操作

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

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

    es使用java来批量创建文档和批量删除文档(基于es7.8)

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

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

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

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

    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日
    浏览(10)
  • SpringBoot操作ES进行各种高级查询(值得收藏)

    SpringBoot操作ES进行各种高级查询(值得收藏)

    创建SpringBoot项目,导入 ES 6.2.1 的 RestClient 依赖和 ES 依赖。在项目中直接引用 es-starter 的话会报容器初始化异常错误,导致项目无法启动。如果有读者解决了这个问题,欢迎留言交流 为容器定义 RestClient 对象 在 yml 文件中配置 eshost 调用相关 API 执行操作 创建操作索引的对象

    2024年02月03日
    浏览(11)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包