新网创想网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

python获取ELK数据进行统计分析-创新互联

首先,我们现在kiban上面绘制自己需要统计出来的数据

中江ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为创新互联公司的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:028-86922220(备注:SSL证书合作)期待与您的合作!

python获取ELK数据进行统计分析

然后点击右上角inspect,将request的json格式复制

python获取ELK数据进行统计分析

粘贴到Dev Tools上面,这样会将我们需要的数据,已json的形式返回

python获取ELK数据进行统计分析

将请求的json格式保存下来,开始写py文件

from elasticsearch import Elasticsearch import datetime #初始化链接 es = Elasticsearch([{'host':'10.3.2.1','port':9200}]) #获取当前时间和7天前的UTC格式时间戳 last_7day=datetime.datetime.utcnow()-datetime.timedelta(days=6, hours=16) now_time=datetime.datetime.utcnow()+datetime.timedelta(hours=8) last_7day=last_7day.strftime('%Y-%m-%dT%H:%M:%S.%f%z') now_time=now_time.strftime('%Y-%m-%dT%H:%M:%S.%f%z') #定义DSL请求体 query_json={     "aggs": {         "2": {             "terms": {                 "field": "message.keyword",                 "size": 30,                 "order": {                     "_count": "desc"                 }             }         }     },     "size": 0,     "_source": {         "excludes": []     },     "stored_fields": [         "*"     ],     "script_fields": {},     "docvalue_fields": [         {             "field": "@timestamp",             "format": "date_time"         },         {             "field": "timestamp",             "format": "date_time"         }     ],     "query": {         "bool": {             "must": [                 {                     "query_string": {                         "query": "level:error",                         "analyze_wildcard": "true",                         "default_field": "*"                     }                 },                 {                     "range": {                         "@timestamp": {                             "gte": last_7day,                             "lte": now_time,                         }                     }                 }             ],             "filter": [],             "should": [],             "must_not": []         }     } } res=es.search(index='index-*', body=query_json) res=res['aggregations']['2']['buckets'] for i in res:     print(i)

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


新闻名称:python获取ELK数据进行统计分析-创新互联
标题URL:http://wjwzjz.com/article/ccpogs.html
在线咨询
服务热线
服务热线:028-86922220
TOP