ElasticSearch-bulk批量操作增删改查(python实现)
bulk有哪些类型的操作可以执行呢?#1.bulk的语法是怎样的呢?每一个操作要两个json串语法如下{action:{metadata}}{data}#2.bulk的操作有以下几种 1delete删除一个文档只要1个json串就可以了 2createPUT/index/type/id/_create强制创建 3index普通的put操作可以是创建文档也可以是全量替换文档 4update执行的partial update操作tips:bulk api对json的语法有严格的要求每个json串不能换行只能放一行同时一个json串和一个json串之间必须有一个换行基于python实现批量增删改查操作fromelasticsearchimportElasticsearchfromelasticsearchimporthelpers esElasticsearch(hostsip:port)bulk_list[{_op_type:delete,_index:test_index,_type:test_type,_id:3,},{_op_type:create,_index:test_index,_type:test_type,_id:12,_source:{test_field:test12}},{_op_type:index,_index:test_index,_type:test_type,_id:2,_source:{test_field:replaced test2}},{_op_type:update,_index:test_index,_type:test_type,_id:1,_retry_on_conflict:3,doc:{test_field2:bulk test1}}]resulthelpers.bulk(es,bulk_list)print(result)# 返回结果如下,表示4条语句执行成功(4,[])基于kibana实现批量增删改查操作POST/_bulk{delete:{_index:test_index,_type:test_type,_id:3}}{create:{_index:test_index,_type:test_type,_id:12}}{test_field:test12}{index:{_index:test_index,_type:test_type,_id:2}}{test_field:replaced test2}{update:{_index:test_index,_type:test_type,_id:1,_retry_on_conflict:3}}{doc:{test_field2:bulk test1}}POST/test_index/_bulk{delete:{_type:test_type,_id:3}}{create:{_type:test_type,_id:12}}{test_field:test12}{index:{_type:test_type}}{test_field:auto-generate id test}{index:{_type:test_type,_id:2}}{test_field:replaced test2}{update:{_type:test_type,_id:1,_retry_on_conflict:3}}{doc:{test_field2:bulk test1}}POST/test_index/test_type/_bulk{delete:{_id:3}}{create:{_id:12}}{test_field:test12}{index:{}}{test_field:auto-generate id test}{index:{_id:2}}{test_field:replaced test2}{update:{_id:1,_retry_on_conflict:3}}{doc:{test_field2:bulk test1}} bulk操作中任意一个操作失败是不会影响其他的操作的但是在返回结果里会告诉你异常日志

相关新闻

数据中心液冷技术:高效散热与节能解决方案

数据中心液冷技术:高效散热与节能解决方案

1. 算力基建浪潮下的数据中心温控困局去年夏天,某大型互联网公司的数据中心因为空调系统故障导致服务器过热宕机,直接造成每小时数百万的经济损失。这个真实案例暴露出传统风冷技术在算力爆发式增长背景下的力不从心。随着AI训练、科学计算等高性能计算需…

2026/7/28 19:54:23 阅读更多
物联网安全:SE050安全元件与PIC18F87J50的硬件加密方案

物联网安全:SE050安全元件与PIC18F87J50的硬件加密方案

1. 物联网安全现状与SE050的定位在智能家居、工业4.0等场景中,设备身份伪造、数据篡改、中间人攻击等安全威胁日益突出。传统MCU方案通常依赖软件加密库,存在密钥泄露风险。恩智浦的EdgeLock SE050安全元件(Secure Element)正是为…

2026/7/28 19:54:23 阅读更多
封装mysql SDK

封装mysql SDK

/*测试代码 char**results; char**field new char*[4]; field[0] new char[64]; field[1] new char[64]; field[2] new char[64]; field[3] NULL; char*sn "sn_id"; char*name "name"; char*electricity "request_count"; strcpy_s(fiel…

2026/7/28 19:54:23 阅读更多
IP地址与子网掩码计算:网络排错与规划的必备基本功

IP地址与子网掩码计算:网络排错与规划的必备基本功

1. 从一次真实的网络故障说起:为什么IP计算是基本功那天下午,整个办公室的网络突然变得奇慢无比,部分同事甚至完全无法访问内部的文件服务器。作为团队里对网络稍有了解的人,我被叫去帮忙。初步排查,路由器和交换机指示…

2026/7/29 4:56:04 阅读更多
步进电机驱动器核心参数解析与实战选型指南

步进电机驱动器核心参数解析与实战选型指南

1. 项目概述:从“会转”到“转得好”的必经之路提起步进电机,很多搞过单片机、玩过3D打印机或者DIY过一些小装置的朋友肯定不陌生。它最大的特点就是“听话”——给一个脉冲,它就转一个固定的角度,开环控制,结构简单&a…

2026/7/29 4:46:03 阅读更多