您现在的位置是：首页 > 文章详情

Elasticsearch批量导入数据脚本（python）

日期：2018-08-10点击：640收藏

#!/usr/local/bin/python2.7 //确定你的python版本

from datetime import datetime

from elasticsearch import Elasticsearch

import elasticsearch.helpers

import random

import time

es = Elasticsearch( "192.168.76.**:9200" ) //es的地址与端口

metrics = ['business.biz.real.bm.fileCount','business.biz.real.bm.contFailCount','business.biz.real.bm.updateCount','business.biz.real.bm.uInCount',

'business.biz.real.bm.uNotCount','business.biz.real.bm.downTime','business.biz.real.bm.ocrTime','business.biz.real.bm.elleTime',

'business.biz.real.bm.contTime','business.biz.real.bm.updateTime','business.biz.real.bm.contErrCount']

package = []

for i in range( 1 ):

for j in metrics:

now = datetime.now()

timeStamp = time.time()

timeNow = datetime.now().strftime("%Y-%m-%dT%H:%M:%S.000Z")

row = {

"@timestamp": timeNow,

"endpoint" : "0"+str(random.randint(0, 9))+"0"+str(random.randint(0, 9))+"0"+str(random.randint(0, 9)),

"metric" : j,

"step" : 0,

"timestamp" : long(timeStamp),

"value" : int(1),

"tags": "uid"+str(random.randint(0, 10000000))

}

package.append( row )

actions = [

{

'_op_type': 'index',

'_index': "argus",

'_type': "ibam_business_dynamic_metadata",

'_source': d

}

for d in package

]

elasticsearch.helpers.bulk( es, actions )

原文链接：https://yq.aliyun.com/articles/624360

关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

Java分享

Elasticsearch批量导入数据脚本（python）

Java编程解密-Dubbo负载均衡与集群容错机制

Java进阶-LinkedHashMap 底层分析

相关文章

文章评论

文章二维码

点击排行

推荐阅读

最新文章