diff --git a/airflow_monitor/actions.py b/airflow_monitor/actions.py index d383e7f..5e07d9a 100644 --- a/airflow_monitor/actions.py +++ b/airflow_monitor/actions.py @@ -53,6 +53,7 @@ class DataExporter: ) with os.fdopen(fd, "w", encoding="utf-8") as f: f.write(content) + os.chmod(tmp_path, 0o644) os.replace(tmp_path, str(path)) logger.debug( "File written: %s (%d bytes)", diff --git a/build.sh b/build.sh index 2be497e..9032814 100755 --- a/build.sh +++ b/build.sh @@ -333,6 +333,8 @@ for dir in "$STATE_DIR" "$LOG_DIR"; do else echo " Exists: $dir" fi + # Ensure zabbix agent can read data files + sudo chmod 755 "$dir" done # --- Step 6: Install systemd service --- diff --git a/zabbix/airflow-monitor.conf b/zabbix/airflow-monitor.conf index cfd0b6f..16bc0be 100644 --- a/zabbix/airflow-monitor.conf +++ b/zabbix/airflow-monitor.conf @@ -17,7 +17,7 @@ UserParameter=airflow.dag.problems,cat /var/lib/airflow-monitor/problems.json 2> # Количество проблемных DAG-ов (для простых триггеров) # Zabbix item: type=Zabbix agent, key=airflow.dag.problems.count, type of info=Numeric (unsigned) -UserParameter=airflow.dag.problems.count,python3 -c "import json,sys; print(len(json.load(open('/var/lib/airflow-monitor/problems.json'))))" 2>/dev/null || echo 0 +UserParameter=airflow.dag.problems.count,grep -o '"dag_id"' /var/lib/airflow-monitor/problems.json 2>/dev/null | wc -l # Heartbeat — epoch timestamp последнего успешного цикла # Zabbix item: type=Zabbix agent, key=airflow.monitor.heartbeat, type of info=Numeric (unsigned)