[ElasticSearch] 쓰기와 조회의 구분

import time
import pprint

from elasticsearch import Elasticsearch


es = Elasticsearch()

result = es.search(index=NAME, body={"query": {"match": {"_id": "BLAH"}}})["hits"]
if result["total"]["value"]:
    pprint.pprint(result["hits"][0]["_source"]["state"])

STATE = "STATE1"
# STATE = "STATE2"

print(
    es.update(
        index=NAME,
        body={"doc": {"state": STATE}},
        id="BLAH",
    )
)

start_time = time.time()

while True:
    result = es.search(index=NAME, body={"query": {"match": {"_id": "BLAH"}}})["hits"]
    if result["total"]["value"] and result["hits"][0]["_source"]["state"] == STATE:
        pprint.pprint(result["hits"][0]["_source"]["state"])
        end_time = time.time()
        print(end_time - start_time)
        break

PoC(Proof of Concept) 코드다

ES는 기본적으로 완전 실시간 동기화 형태가 아니기 때문에 위와 같이 update 이후 바로 조회를 시도하면 update가 성공했음에도 동일한 값이 나올 수 있다.

굳이 억지로 하려면 위와 같이 할 수 있지만 0.X초만 소요되더라도 치명적이다. 물론 비동기적으로 처리하면 가능하겠지만 기본적으로 분리해서 구현하는게 맞는 것 같다는 생각이 든다.

이래서 es랑 kibana랑 분리한 것도 있는건가?(물론 그건 아니겠지만)

암튼 아무리 api에서 찾아봐도 없어서 그냥 정리용으로 올림!

'ARCHIVED'
{'_index': 'test_index', '_type': '_doc', '_id': 'BLASH', '_version': 13, 'result': 'updated', '_shards': {'total': 2, 'successful': 1, 'failed': 0}, '_seq_no': 12, '_primary_term': 1}
'ARCHIVED'