Merge pull request #82 from zizzic/develop_young_ho_for_fix

very small fix for json structure
zizzic · Feb 23, 2024 · 836c708 · 836c708
2 parents b2b5e4e + 1c57150
commit 836c708
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/dags/game/game_ccu_to_s3.py b/dags/game/game_ccu_to_s3.py
@@ -65,6 +65,7 @@ def get_ccu():
 # 3. API 응답들이 담긴 리스트를 JSON으로 저장
 @task
 def save_to_json(data):
+    data = {"raw_game_ccu": data}
     result = json.dumps(data, ensure_ascii=False)
 
     return result

diff --git a/dags/game/game_comment_to_s3.py b/dags/game/game_comment_to_s3.py
@@ -73,6 +73,7 @@ def get_ratings_task():
 # 3. API 응답들이 담긴 리스트를 JSON으로 저장
 @task
 def save_to_json(data):
+    data = {"raw_game_review": data}
     result = json.dumps(data, ensure_ascii=False)
 
     return result

diff --git a/dags/game/game_price_to_s3.py b/dags/game/game_price_to_s3.py
@@ -85,6 +85,7 @@ def get_price():
 # 3. API 응답들이 담긴 리스트를 JSON으로 저장
 @task
 def save_to_json(data):
+    data = {"raw_game_price": data}
     result = json.dumps(data, ensure_ascii=False)
 
     return result

diff --git a/dags/game/game_rating_to_s3.py b/dags/game/game_rating_to_s3.py
@@ -103,6 +103,7 @@ def get_ratings_task():
 # 3. API 응답들이 담긴 리스트를 JSON으로 저장
 @task
 def save_to_json(data):
+    data = {"raw_game_rating": data}
     result = json.dumps(
         data, ensure_ascii=False
     )  # API 응답들이 담긴 리스트를 JSON으로 저장