diff --git a/csv-to-es.py b/csv-to-es.py index b090e5a..2999d6f 100644 --- a/csv-to-es.py +++ b/csv-to-es.py @@ -10,7 +10,7 @@ index_name = f"restaurant_{now.strftime('%Y_%m_%d_%H-%M')}" # Elasticsearch 클라이언트 설정 -es = Elasticsearch("http://localhost:9200") +es = Elasticsearch("http://es-singlenode:9200") # 새 인덱스 생성 및 매핑 설정 if not es.indices.exists(index=index_name): diff --git a/mysql-to-es.py b/mysql-to-es.py index 7cd59f4..aee2c1d 100644 --- a/mysql-to-es.py +++ b/mysql-to-es.py @@ -11,7 +11,7 @@ } # Elasticsearch connection parameters -es = Elasticsearch(['http://localhost:9200']) +es = Elasticsearch(['http://es-singlenode:9200']) def fetch_restaurant_data():