엘라스틱 서치 시작하기 - 예제 (2025, 06)

C:\Users\Admin>cd C:\elasticsearch-9.0.3-windows-x86_64\elasticsearch-9.0.3\bin
C:\elasticsearch-9.0.3-windows-x86_64\elasticsearch-9.0.3>elasticsearch

C:~\elasticsearch-9.0.3\bin>elasticsearch-reset-password.bat -u elastic
This tool will reset the password of the [elastic] user to an autogenerated value.
The password will be printed in the console.
Please confirm that you would like to continue [y/N]y

Password for the [elastic] user successfully reset.
New value: 30Dzdl4dBkp-mSveC_s_

C:\Users\Admin\Desktop\elk_tutorials\elasticsearch-9.0.3\bin>elasticsearch-reset-password -u elastic -i
This tool will reset the password of the [elastic] user.
You will be prompted to enter the password.
Please confirm that you would like to continue [y/N]y

Enter password for [elastic]: 
passwords must be at least [6] characters long
Try again.
Enter password for [elastic]:
Re-enter password for [elastic]: 
Password for the [elastic] user successfully reset.

# For more configuration options see the configuration guide for Kibana in
# https://www.elastic.co/guide/index.html

# =================== System: Kibana Server ===================
# Kibana is served by a back end server. This setting specifies the port to use.
server.port: 5601

# Specifies the address to which the Kibana server will bind. IP addresses and host names are both valid values.
# The default is 'localhost', which usually means remote machines will not be able to connect.
# To allow connections from remote users, set this parameter to a non-loopback address.
server.host: "localhost"

...

# The Kibana server's name. This is used for display purposes.
server.name: "kibana"

# =================== System: Kibana Server (Optional) ===================
# Enables SSL and paths to the PEM-format SSL certificate and SSL key files, respectively.
# These settings enable SSL for outgoing requests from the Kibana server to the browser.
server.ssl.enabled: false
#server.ssl.certificate: /path/to/your/server.crt
#server.ssl.key: /path/to/your/server.key

# =================== System: Elasticsearch ===================
# The URLs of the Elasticsearch instances to use for all your queries.
elasticsearch.hosts: ["http://localhost:9200"]

# If your Elasticsearch is protected with basic authentication, these settings provide
# the username and password that the Kibana server uses to perform maintenance on the Kibana
# index at startup. Your Kibana users still need to authenticate with Elasticsearch, which
# is proxied through the Kibana server.
elasticsearch.username: "evan"
elasticsearch.password: "123456"

...

curl -u elastic:123456 -X PUT "http://localhost:9200/_security/user/evan" ^
  -H "Content-Type: application/json" ^
  -d "{\"roles\":[\"kibana_admin\", \"kibana_system\"]}"

@echo off
echo ================================
echo Checking Elasticsearch...
curl -u sara:230302 -s -o nul -w "%%{http_code}" http://localhost:9200 | findstr "200" > nul
if %errorlevel%==0 (
    echo Elasticsearch is running!
) else (
    echo Elasticsearch is NOT running!
)

echo.
echo ================================
echo Checking Kibana...
curl -u sara:230302 -s -o nul -w "%%{http_code}" http://localhost:5601/api/status | findstr "200" > nul
if %errorlevel%==0 (
    echo Kibana is running!
) else (
    echo Kibana is NOT running!
)

echo.
pause

#!/bin/bash

echo "==============================="
echo "Checking Elasticsearch..."
status_code=$(curl -u sara:230302 -s -o /dev/null -w "%{http_code}" http://localhost:9200)

if [ "$status_code" -eq 200 ]; then
    echo "Elasticsearch is running!"
else
    echo "Elasticsearch is NOT running!"
fi

echo
echo "==============================="
echo "Checking Kibana..."
status_code=$(curl -u sara:230302 -s -o /dev/null -w "%{http_code}" http://localhost:5601/api/status)

if [ "$status_code" -eq 200 ]; then
    echo "Kibana is running!"
else
    echo "Kibana is NOT running!"
fi

# 필요한 라이브러리들을 가져옵니다
import time                    # 시간 지연을 위한 라이브러리
import requests               # HTTP 요청을 위한 라이브러리
from bs4 import BeautifulSoup # HTML 파싱을 위한 라이브러리
from elasticsearch import Elasticsearch  # Elasticsearch 클라이언트

# Elasticsearch에 관리자 계정(elastic)으로 연결합니다
# localhost:9200은 Elasticsearch의 기본 주소입니다
es_admin = Elasticsearch("http://localhost:9200", basic_auth=("elastic", "123456"))
INDEX_NAME = "quotes"  # 저장할 인덱스 이름을 상수로 정의

# ✅ Step 1: 인덱스 생성 (이미 존재하면 생략)
# 인덱스가 존재하는지 확인하고, 없으면 새로 생성합니다
if not es_admin.indices.exists(index=INDEX_NAME):
    es_admin.indices.create(index=INDEX_NAME)  # 새 인덱스 생성
    print(f"✅ Index '{INDEX_NAME}' created.")
else:
    print(f"✅ Index '{INDEX_NAME}' already exists.")

# ✅ Step 2: 역할(Role) 생성 (quotes_writer)
# quotes 인덱스에 대한 읽기/쓰기 권한을 가진 역할을 생성합니다
try:
    es_admin.security.put_role(
        name="quotes_writer",  # 역할 이름
        body={
            "indices": [
                {
                    "names": [INDEX_NAME],  # 적용할 인덱스
                    "privileges": ["read", "write", "create_index", "auto_configure"]  # 권한 목록
                }
            ]
        }
    )
    print("✅ Role 'quotes_writer' created.")
except Exception as e:
    # 역할이 이미 존재하거나 생성에 실패한 경우 예외 처리
    print(f"⚠️ Role creation skipped or failed: {e}")

# ✅ Step 3: 사용자(User) 생성 (sara)
# sara라는 사용자를 생성하고 여러 역할을 부여합니다
try:
    es_admin.security.put_user(
        username="sara",  # 사용자명
        body={
            "password": "230302",  # 비밀번호
            "roles": ["kibana_admin", "kibana_system", "quotes_writer"],  # 부여할 역할들
            "full_name": "Sara"  # 전체 이름
        }
    )
    print("✅ User 'sara' created.")
except Exception as e:
    # 사용자가 이미 존재하거나 생성에 실패한 경우 예외 처리
    print(f"⚠️ User creation skipped or failed: {e}")

# ✅ Step 4: sara 계정으로 재연결
# 새로 생성한 sara 계정으로 Elasticsearch에 다시 연결합니다
es = Elasticsearch("http://localhost:9200", basic_auth=("sara", "230302"))

# ✅ Step 5: Quotes 수집 함수 정의
def get_quotes():
    """
    quotes.toscrape.com 웹사이트에서 명언들을 수집하는 함수
    
    Returns:
        list: 수집된 명언 요소들의 리스트
    """
    res = requests.get("http://quotes.toscrape.com")  # 웹사이트에 GET 요청
    soup = BeautifulSoup(res.text, "html.parser")     # HTML을 파싱
    return soup.select(".quote")                       # .quote 클래스를 가진 요소들을 선택

# ✅ Step 6: 30초마다 하나씩 저장
# 수집된 명언들을 가져옵니다
quotes = get_quotes()

# 각 명언을 순회하면서 Elasticsearch에 저장합니다
for i, q in enumerate(quotes):
    # 명언 데이터를 딕셔너리 형태로 구성합니다
    doc = {
        "text": q.select_one(".text").text.strip(),      # 명언 텍스트 추출
        "author": q.select_one(".author").text.strip(),  # 저자 이름 추출
        "tags": [tag.text for tag in q.select(".tag")]   # 태그들을 리스트로 추출
    }
    
    # Elasticsearch에 문서를 저장합니다
    res = es.index(index=INDEX_NAME, document=doc)
    print(f"[{i+1}] ✅ Saved to Elasticsearch: {res['_id']}")
    
    # 30초 대기 (다음 명언 저장 전)
    time.sleep(30)