Update bc-mart.py

bc-mart.py

@@ -4,7 +4,7 @@ import pendulum
 from airflow.operators.bash import BashOperator
 from airflow import DAG
 from airflow.models import Variable
-from data.gasan_data import gasanData   # import gasan data
+from data.mart_data import martData   # import mart data
 from fail_alert import fail_alert   # 실패 시 Teams 알림 발송
 
 # set timezone
@@ -19,7 +19,7 @@ with DAG(
         #'on_failure_callback': fail_alert
         'on_success_callback': fail_alert
     },
-    description='dag for gasan batch jobs',
+    description='dag for mart batch jobs',
     schedule_interval='*/1 * * * *',
     start_date=datetime(2022, 5, 13, tzinfo=local_tz),
     tags=['test'],
@@ -33,11 +33,11 @@ with DAG(
         ),
     )
 
-    # (Task2) gasan 작업 병렬처리
-    post_gasan_tasks = []
+    # (Task2) mart 작업 병렬처리
+    post_mart_tasks = []
 
-    for i, data in enumerate(gasanData):
-        post_gasan_task = BashOperator(
+    for i, data in enumerate(martData):
+        post_mart_task = BashOperator(
             task_id='post_gasan'+str(i+1),
             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"), 
@@ -49,7 +49,7 @@ with DAG(
             ),
         )
 
-        post_gasan_tasks.append(post_gasan_task)
+        post_mart_tasks.append(post_mart_task)
 
     # 작업 순서 정의
-    health_check >> post_gasan_tasks
+    health_check >> post_mart_tasks