首先，我们现在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许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
