Update app.py

app.py

@@ -12,21 +12,12 @@ from concurrent.futures import ThreadPoolExecutor
 import os
 import tempfile
 from datetime import datetime
-from dotenv import load_dotenv  # dotenv 추가
 
-# .env 파일의 환경 변수를 로드합니다.
-load_dotenv()
-
-# 환경 변수에서 API 키와 시크릿 키를 불러옵니다.
 BASE_URL = "https://api.searchad.naver.com"
-API_KEY = os.environ.get("NAVER_API_KEY")
-SECRET_KEY = os.environ.get("NAVER_SECRET_KEY")
+API_KEY = "010000000046604df3a0f6abf4c52824e0d5835c5cbeae279ced8b2bb9007b3cc566b190c7"
+SECRET_KEY = "AQAAAABGYE3zoPar9MUoJODVg1xczNEcSuIBi66wWUy4p4gs/Q=="
 CUSTOMER_ID = 2666992
 
-# 환경 변수에서 클라이언트 ID와 시크릿을 불러옵니다.
-CLIENT_ID = os.environ.get("NAVER_CLIENT_ID")
-CLIENT_SECRET = os.environ.get("NAVER_CLIENT_SECRET")
-
 class NaverAPI:
     def __init__(self, base_url, api_key, secret_key, customer_id):
         self.base_url = base_url
@@ -66,25 +57,20 @@ class NaverAPI:
         return response.json()
 
 def get_blog_count(keyword):
-    # 클라이언트 ID와 시크릿을 환경 변수에서 불러옵니다.
-    client_id = CLIENT_ID
-    client_secret = CLIENT_SECRET
+    client_id = "421ZKFMM5TS1xmvsF7C0"
+    client_secret = "h47UQHAOGV"
     encText = urllib.parse.quote(keyword)
     url = "https://openapi.naver.com/v1/search/blog?query=" + encText
     request = urllib.request.Request(url)
     request.add_header("X-Naver-Client-Id", client_id)
     request.add_header("X-Naver-Client-Secret", client_secret)
-    try:
-        response = urllib.request.urlopen(request)
-        rescode = response.getcode()
-        if rescode == 200:
-            response_body = response.read()
-            data = json.loads(response_body.decode('utf-8'))
-            return data['total']
-        else:
-            return 0
-    except Exception as e:
-        print(f"Error fetching blog count for keyword '{keyword}': {e}")
+    response = urllib.request.urlopen(request)
+    rescode = response.getcode()
+    if rescode == 200:
+        response_body = response.read()
+        data = json.loads(response_body.decode('utf-8'))
+        return data['total']
+    else:
         return 0
 
 def get_keywords_data_chunk(chunk):
@@ -102,16 +88,13 @@ def get_monthly_search_volumes(keywords):
     with ThreadPoolExecutor(max_workers=5) as executor:
         futures = [executor.submit(get_keywords_data_chunk, keywords[i:i+chunk_size]) for i in range(0, len(keywords), chunk_size)]
         for future in futures:
-            try:
-                data = future.result()
-                if 'keywordList' in data:
-                    all_data.extend(data['keywordList'])
-            except Exception as e:
-                print(f"Error fetching keywords data chunk: {e}")
+            data = future.result()
+            if 'keywordList' in data:
+                all_data.extend(data['keywordList'])
 
     if not all_data:
-        return [("Error", "데이터가 반환되지 않았거나 API 응답이 유효하지 않습니다.", "", "", "")]  # 블로그 문서 수 칼럼 추가
-
+        return [("Error", "No data returned or invalid response from API", "", "", "")]  # 블로그 문서 수 칼럼 추가
+    
     results = []
     unique_keywords = set()
     for item in all_data:
@@ -136,13 +119,9 @@ def get_monthly_search_volumes(keywords):
     with ThreadPoolExecutor(max_workers=5) as executor:
         blog_futures = [executor.submit(get_blog_count_parallel, result[0]) for result in results]
         for i, future in enumerate(blog_futures):
-            try:
-                keyword, blog_count = future.result()
-                results[i] = (results[i][0], results[i][1], results[i][2], results[i][3], blog_count)
-            except Exception as e:
-                print(f"Error fetching blog count for keyword '{results[i][0]}': {e}")
-                results[i] = (results[i][0], results[i][1], results[i][2], results[i][3], "Error")
-
+            keyword, blog_count = future.result()
+            results[i] = (results[i][0], results[i][1], results[i][2], results[i][3], blog_count)
+    
     return results
 
 def save_to_excel(results, keyword):