生活随笔
收集整理的這篇文章主要介紹了
Python Elasticsearch 插入数据
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
index
這是很簡單的一個插入數據的方法，每條數據調用一個index方法，代碼如下
from datetime import datetime
from elasticsearch import Elasticsearches = Elasticsearch(
"localhost:9200" )
data = {
"@timestamp" : datetime.now().strftime(
"%Y-%m-%dT%H:%M:%S.000+0800" )，
"http_code" :
"404",
"count" :
"10"
}es.
index(
index=
"http_code", doc_type=
"error_code", body=data )
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" ),
"http_code" :
"404",
"count" : random.randint(
1,
100 )}
package.
append( row )actions = [{
'_op_type':
'index',
'_index':
"http_code",
'_type':
"error_code",
'_source': d}
for d in
package
] elasticsearch.helpers.bulk( es, action )
《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀
總結
以上是生活随笔為你收集整理的Python Elasticsearch 插入数据的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
