From c6ff8a1bde45d7aeab45c14494a01fcb34abcdf5 Mon Sep 17 00:00:00 2001 From: sinkyoungdeok Date: Tue, 21 May 2024 23:25:37 +0900 Subject: [PATCH] =?UTF-8?q?[KAN-79]=20MYSQL=20->=20ES=20=EB=8F=99=EA=B8=B0?= =?UTF-8?q?=ED=99=94=20=EB=B0=B0=EC=B9=98=20=EC=9E=91=EC=97=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- csv-to-es.py | 2 +- mysql-to-es.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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():