#!/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_ data",
'_source': d
}
for d in package
]
elasticsearch.helpers.bulk( es, actions )
继续阅读与本文标签相同的文章
上一篇 :
Java基础-Java的语法规范
下一篇 :
谷歌《机器学习速成课程》学习摘要
-
nginx的安装与配置
2026-05-26栏目： 教程
-
html页面导出word文档
2026-05-26栏目： 教程
-
Linux安装防火墙
2026-05-26栏目： 教程
-
Linux设置静态IP
2026-05-26栏目： 教程
-
Linux修改本地时间
2026-05-26栏目： 教程