Elasticsearch 读数据

Elasticsearch 读数据

def init_es():
    addr_list = [
        {'host': '10.30.114.144', 'port': 9200, "timeout": 500},
        {'host': '10.30.50.144', 'port': 9200, "timeout": 500},
        {'host': '10.30.134.144', 'port': 9200, "timeout": 500}
    ]
    es = Elasticsearch(addr_list, sniff_on_start=True)
    return es

def read_es(es, user_id, _index):
    # body = {"query": {"match": {"user_id": user_id}}}
    # body = {"query": {"ids": {"values": [user_id]}}}
    body = {
        "query": {
            "term": {
                "user_id.keyword": {
                    "value": user_id
                }
            }
        }
    }
    res = es.search(index=_index, size=1, sort="ts: desc", track_total_hits=False, body=body)
    return res['hits']['hits']