#!/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 )
