Elasticsearch (python)

💻 python으로 Elasticsearch 사용

ES연결 및 인덱스 생성

• 연결

# ES 패키지 import
from elasticsearch import Elasticsearch

• 연결 및 확인

# es 연결
# localhost자리에 ip주소 가능
es = Elasticsearch('http://localhost:9200/'])

#연결 여부 확인
print('elasticsearch connected info \n',es.info())

• 인덱스 확인

# 전체 인덱스 확인(출력)
def allIndex():
	print(es.cat.indices())
    
# 예시) 전체 인덱스 확인 
allIndex()

• 인덱스 생성 삭제

# 인덱스 생성 함수
def make_index(es,index_name):
    es.indices.create(index=index_name)

# 예시) crawling이라는 인덱스 생성
make_index(es, 'crawling') 

# 인덱스 삭제 함수
def del_index(es, index_name):
    es.indices.delete(index=index_name)

# 예시) crawling이라는 인덱스 삭제
del_index(es, 'crawling') 

---

ES 데이터 확인

🚨 data return이 아닌 콘솔창 출력 확인용 데이터를 주고 받으려고 할 경우 함수 수정 필요

• data 저장

# data 저장 함수
# doc은 json형태
def save_data(es,index_name,  doc):
    es.index(index=index_name, body=doc)
    print('save_data success')

• data 갯수 확인

# 인덱스의 데이터 갯수
def count_data(es, index_name):
    num=es.count(index=index_name)
    print(num['count'])

# 예시) crawling인덱스의 데이터 갯수 출력
count_data(es, "crawling")

• data 조회

# 인덱스의 data 조회
from pprint import pprint
def get_data(es,index_name):
    data=es.search(index=index_name)
    pprint(data, indent=4)
    
# 예시) crawling인덱스의 data조회
get_data(es,"crawling")