diff --git a/dev/workflow/TK_Cust/ser_main/作业日志维护/maintain_logs.py b/dev/workflow/TK_Cust/ser_main/作业日志维护/maintain_logs.py new file mode 100644 index 0000000..755a6b8 --- /dev/null +++ b/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 + ) + diff --git a/dev/workflow/TK_Cust/ser_main/服务器维护/wf_dag_ser_main.py b/dev/workflow/TK_Cust/ser_main/服务器维护/wf_dag_ser_main.py index 96e8233..5bda871 100644 --- a/dev/workflow/TK_Cust/ser_main/服务器维护/wf_dag_ser_main.py +++ b/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