Saltar a contenido

job-monitor-adf

Monitor de Azure Data Factory para ATHENAS. Dos jobs en un paquete (monitor_adf):

Job Catalogo Comando Programacion
adf_pipelines_monitor L23 python -m monitor_adf pipelines [--desde AAAA-MM-DD] [--dry-run] 0 7 * * *
adf_monitor_ir_nodes L24 python -m monitor_adf ir-nodes [--dry-run] 5 * * * *
  • L23 carga en ods.adf_monitor_* las corridas de pipelines y triggers, las actividades, las estadisticas de las Copy y el estado de los Integration Runtimes.
  • L24 guarda el estado de cada nodo del IR y avisa por Telegram cuando un nodo cae y cuando se recupera.

Instalacion

python3.11 -m venv .venv && .venv/bin/pip install .
cp .env.example .env   # completar; no se versiona
Solo lee de Azure (API de administracion) y escribe en ATHENAS. No escribe archivos: el estado de L23 es el MAX(RunStart) de sus tablas.

Desarrollo

pip install -e ".[dev]" && pytest && ruff check .
python tools/verify_equivalence.py <ruta a code/activo/PY_ADF_PIPELINES_MONITOR> --mutaciones
Operacion: ver RUNBOOK.md. Reglas y cambios respecto al original: AGENTS.md.

Fuente: repositorio job-monitor-adf, versión a3d350b. Página generada con tools/publicar_docs.py.