added cloud run SERVICE

Author: HyejiYu

airflow/HomePlus_dag.py

@@ -26,7 +26,7 @@
 
     @task
     def send_post_request_HOMEPLUS_task(category_id):
-        return send_post_request(category_id)
+        return send_post_request('HP', category_id)
 
     # TaskFlow API로 task 정의
     @task

airflow/Oasis_dag.py

@@ -26,7 +26,7 @@
 
     @task
     def send_post_request_OASIS_task():
-        return send_post_request()
+        return send_post_request('OA')
 
     # TaskFlow API로 task 정의
     @task

airflow/requirements/modules.py

@@ -29,9 +29,13 @@ def collect_task_results(**context):
     context['ti'].xcom_push(key='email_body', value=email_body)
 
 # HTTP POST 요청 함수
-def send_post_request(categoryId):
+def send_post_request(platform, categoryId):
     load_dotenv()
-    url = os.getenv("HOMEPLUS_SERVICE_URL")
+    url = ""
+    if platform == 'HP':
+        url = os.getenv("HOMEPLUS_SERVICE_URL")
+    elif platform == 'OA':
+        url = os.getenv("OASIS_SERVICE_URL")
     headers = {"Content-Type": "application/json"}
     data = json.dumps({"category_id": categoryId})
     response = requests.post(url, headers=headers, data=data)