python 丢HTTP要求给ElasticSearch并取回文件

Posted 2021-05-09

import json
import requests
ES_URL = "your es cluster url including index and _type like .../index1/doc_type"

query = {
  "size": 150,
    "query": {
        "bool": {
            "must": [
                {
                    "term": {
                        "cs_type.keyword": "sr"
                    }
                }
            ]
        }
    },
    "aggs": {
        "1": {
            "date_histogram": {
                "field": "refund",
                "interval": "100d"
            },
            "aggs": {
                "Refund": {
                    "sum": {
                        "field": "sr_info_sr_payback"
                    }
                }
            }
        }
    }
}

res = requests.post(ES_URL + "_search", data=json.dumps(query)).json()
if not res['timed_out']:
    docs = [i['_source'] for i in res['hits']['hits']]