Update batch_test.py

batch_test.py

@@ -20,16 +20,23 @@ with DAG(
     tags=['test'],
     catchup=False,
 ) as dag:
-    # gasan 작업 병렬처리
-    post_gasan_tasks = []
+    # (Task1) 헬스체크
+    health_check = BashOperator(
+        task_id='health_check',
+        bash_command="curl -X GET -v http://10.231.238.224:30999/api/v1/core/health \'-H accept: application/json\'"
+    )
 
-    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"]),
-        )
+    # (Task2) gasan 작업 병렬처리
+    # post_gasan_tasks = []
 
-        post_gasan_tasks.append(post_gasan_task)
+    # 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"]),
+    #     )
+
+    #     post_gasan_tasks.append(post_gasan_task)
 
     # 작업 순서 정의
-    post_gasan_tasks
+    # post_gasan_tasks
+    health_check