Update batch_test.py

batch_test.py

@@ -35,12 +35,12 @@ def fail_alert(context):
         context.get('task_instance').task_id, 
         context.get('task_instance').dag_id,
         context.get('exception'),
-        context.get('task_instance').log_url.replace("localhost:8080", "10.231.238.224:31258")
+        context.get('task_instance').log_url.replace("localhost:8080", Variable.get("AIRFLOW_WEB_URL"))
     )
 
     alert = BashOperator(
         task_id='fail_alert',
-        bash_command="curl -d \'{data}\' -H \"Content-Type: Application/JSON\" -X POST https://lottegroup.webhook.office.com/webhookb2/2ed9f7fc-4c60-4d2d-a61c-aa50c0075564@dc742f86-8941-4de1-8d2c-d2dfef93cfe8/IncomingWebhook/1047eeaf7bde45a08e5ccb4d6c80f08d/d7352368-8126-4827-aab7-4a62b0b5abc2".format(data=context_data)
+        bash_command="curl -d \'{data}\' -H \"Content-Type: Application/JSON\" -X POST {teams_url}".format(data=context_data, teams_url=Variable.get("TEAMS_WEBHOOKS_URL"))
     )
     return alert.execute(context=context)
 
@@ -70,7 +70,7 @@ with DAG(
     for i, data in enumerate(gasanData):
         post_gasan_task = BashOperator(
             task_id='post_gasan'+str(i+1),
-            bash_command="curl -X \'POST\' \'http://10.231.238.224:30999/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"test\", \"pw\": \"test\", \"ip\": \"%s\", \"serialNum\": \"%s\", \"camName\": \"%s\"}\'" %(data["ip"], data["serialNum"], data["camName"]),
+            bash_command="curl -X \'POST\' \'%s/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"%s\", \"%s\": \"test\", \"ip\": \"%s\", \"serialNum\": \"%s\", \"camName\": \"%s\"}\'" %(Variable.get("INF_API_URL"), Variable.get("INF_API_ID"), Variable.get("INF_API_PW")data["ip"], data["serialNum"], data["camName"]),
         )
 
         post_gasan_tasks.append(post_gasan_task)