add workflow 服务器维护,dev

dev/workflow/TK_Cust/ser_main/作业日志维护/maintain_logs.py

@@ -0,0 +1,10 @@
+#!/usr/bin/env python3
+
+from maintain_log import delDir
+
+if __name__ == '__main__':
+    "删除日志，保留1个月内做过修改的日志"
+    delDir(
+        "/data/airflow/logs/",30
+    )
+

dev/workflow/TK_Cust/ser_main/服务器维护/wf_dag_ser_main.py

@@ -49,14 +49,14 @@ retries=3,
 dag=dag)
 
 
-uds_maintain_log = SSHOperator(
+uds_maintain_logs = SSHOperator(
 ssh_hook=sshHook,
-task_id='uds_maintain_log',
-command='python /data/airflow/etl/CTL/maintain_log.py >>/data/airflow/logs/maintain.log',
-params={'my_param':"uds_maintain_log"},
+task_id='uds_maintain_logs',
+command='python /data/airflow/etl/CTL/maintain_logs.py ',
+params={'my_param':"uds_maintain_logs"},
 depends_on_past=False, 
 retries=3, 
 dag=dag)
 
-uds_maintain_data_file >> uds_maintain_log
-uds_maintain_log >> task_failed 
+uds_maintain_data_file >> uds_maintain_logs
+uds_maintain_logs >> task_failed