ElasticSearch-bulk批量操作增刪改查(python實現(xiàn))
bulk有哪些類型的操作可以執(zhí)行呢?#1.bulk的語法是怎樣的呢?每一個操作要兩個json串語法如下{action:{metadata}}{data}#2.bulk的操作有以下幾種 1delete刪除一個文檔只要1個json串就可以了 2createPUT/index/type/id/_create強制創(chuàng)建 3index普通的put操作可以是創(chuàng)建文檔也可以是全量替換文檔 4update執(zhí)行的partial update操作tips:bulk api對json的語法有嚴格的要求每個json串不能換行只能放一行同時一個json串和一個json串之間必須有一個換行基于python實現(xiàn)批量增刪改查操作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條語句執(zhí)行成功(4,[])基于kibana實現(xiàn)批量增刪改查操作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操作中任意一個操作失敗是不會影響其他的操作的但是在返回結果里會告訴你異常日志

相關新聞

數(shù)據(jù)中心液冷技術:高效散熱與節(jié)能解決方案

數(shù)據(jù)中心液冷技術:高效散熱與節(jié)能解決方案

1. 算力基建浪潮下的數(shù)據(jù)中心溫控困局去年夏天,某大型互聯(lián)網(wǎng)公司的數(shù)據(jù)中心因為空調系統(tǒng)故障導致服務器過熱宕機,直接造成每小時數(shù)百萬的經濟損失。這個真實案例暴露出傳統(tǒng)風冷技術在算力爆發(fā)式增長背景下的力不從心。隨著AI訓練、科學計算等高性能計算需…

2026/7/28 19:54:23 閱讀更多
物聯(lián)網(wǎng)安全:SE050安全元件與PIC18F87J50的硬件加密方案

物聯(lián)網(wǎng)安全:SE050安全元件與PIC18F87J50的硬件加密方案

1. 物聯(lián)網(wǎng)安全現(xiàn)狀與SE050的定位在智能家居、工業(yè)4.0等場景中,設備身份偽造、數(shù)據(jù)篡改、中間人攻擊等安全威脅日益突出。傳統(tǒng)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 閱讀更多
python爬取貝殼中二手房的數(shù)據(jù)

python爬取貝殼中二手房的數(shù)據(jù)

前言:通過代碼爬取貝殼中二手房的數(shù)據(jù),以此給更多需要了解爬蟲或者二手房信息的人提供便利。 第一部分:爬取地址 1.1貝殼首頁地址 jiujiang.ke.com 第二部分:爬取數(shù)據(jù) 2.1輸入要爬多少頁 int(input(輸入一共要多少頁&#xf…

2026/7/29 4:26:03 閱讀更多
學習日記 7.28

學習日記 7.28

在機器學習的學習之路上,線性回歸和邏輯回歸是兩塊重要的基石。今天我們將通過兩個實戰(zhàn)案例,從理論到代碼,全面掌握這兩種算法的應用:案例一:多元線性回歸 —— 根據(jù)體重和年齡預測血壓收縮壓;案例二&#…

2026/7/29 4:26:03 閱讀更多
AI數(shù)字人口播訓練全周期,從唇形同步誤差<0.3幀到通過抖音AIGC白名單認證

AI數(shù)字人口播訓練全周期,從唇形同步誤差<0.3幀到通過抖音AIGC白名單認證

更多請點擊: https://intelliparadigm.com 第一章:AI數(shù)字人口播訓練全周期概覽 AI數(shù)字人口播訓練是一項融合語音合成、表情驅動、語義理解與多模態(tài)對齊的系統(tǒng)性工程,其全周期涵蓋數(shù)據(jù)準備、模型微調、驅動策略設計、實時渲染優(yōu)化及效果評估五…

2026/7/29 4:26:03 閱讀更多
嵌入式設備與云端安全連接方案及優(yōu)化技巧

嵌入式設備與云端安全連接方案及優(yōu)化技巧

1. 項目背景與硬件選型解析當我們需要在嵌入式設備與云端建立安全連接時,硬件平臺的選擇直接影響著整個系統(tǒng)的性能和可靠性。這個項目中選用的A5000顯卡和TM4C123GH6PZ微控制器組合,恰好覆蓋了從邊緣計算到云端協(xié)同的全鏈路需求。NVIDIA RTX A5000作為專…

2026/7/29 4:16:02 閱讀更多