Commit 0c9aab19 authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent 989d80b2
...@@ -3,34 +3,34 @@ from textwrap import dedent ...@@ -3,34 +3,34 @@ from textwrap import dedent
import pendulum import pendulum
from airflow.operators.bash import BashOperator from airflow.operators.bash import BashOperator
from airflow import DAG from airflow import DAG
from data import gasan_data from data/gasan_data import gasanData
local_tz = pendulum.timezone("Asia/Seoul") local_tz = pendulum.timezone("Asia/Seoul")
print(gasan_data.gasanData) print(gasanData)
# gasan 데이터 선언 # gasan 데이터 선언
gasan_data = [ # gasan_data = [
{ # {
"ip": "10.231.130.110", # "ip": "10.231.130.110",
"serialNum": "7D0B3C9PAGFCF3C", # "serialNum": "7D0B3C9PAGFCF3C",
"camName": "dt_lab_1" # "camName": "dt_lab_1"
}, # },
{ # {
"ip": "10.231.130.111", # "ip": "10.231.130.111",
"serialNum": "7D0B3C9PAG8D150", # "serialNum": "7D0B3C9PAG8D150",
"camName": "dt_lab_2" # "camName": "dt_lab_2"
}, # },
{ # {
"ip": "10.231.130.112", # "ip": "10.231.130.112",
"serialNum": "7D0B3C9PAGBB838", # "serialNum": "7D0B3C9PAGBB838",
"camName": "dt_lab_3" # "camName": "dt_lab_3"
}, # },
{ # {
"ip": "10.231.130.113", # "ip": "10.231.130.113",
"serialNum": "7D0B3C9PAG17F50", # "serialNum": "7D0B3C9PAG17F50",
"camName": "dt_lab_4" # "camName": "dt_lab_4"
}, # },
] # ]
with DAG( with DAG(
'batch_test', 'batch_test',
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment