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

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

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

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

将请求的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://hbruida.cn/article/ccpogs.html