es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Los registros del programador son diferentes entre Airflow1 y Airflow2.

Como no puedo usar la línea de comandos de Airflow, en realidad estoy analizando los registros del planificador con grep en airflow1 para recuperar algunas informaciones tales como:

  • comprobar si el DAG es activado o no / si tiene éxito o no / marca horaria de inicio con el patrón “INFO Marking run”:

[2021-12-01 11:06:50,340] {loggingmixin.py:112} INFO – [2021-12-01 11:06:50,339] {dagrun.py:307} INFO – Marcando ejecución * @ 2021-12-01 10:02:00+00:00: scheduled__2021-12-01T10:02:00+00:00, **externally triggered: False>successful

  • cuando el DAG no está activado, uso el patrón “INFO – Created” para recuperar la marca de tiempo de inicio del DAG:

[2021-12-01 11:04:49,213] {schedulerjob.py:1298} INFO – Creado * @ 2021-12-01T10:02:00+00:00: scheduled__2021-12-01T10:02:00+00:00, externally triggered: False>

Esto funciona bien en airflow1, pero no puedo encontrar esos datos en los registros del planificador de airflow2 después de la migración. ¿Es necesario cambiar la configuración?

Saludos cordiales,
Troubadour

Tags:  , ,

Answer

  1. Avatar for davy.ai

    Estimado Troubadour,

    Gracias por contactarnos. Parece que los registros que intenta acceder no están presentes en los registros de airflow2. Pueden haber múltiples razones para este comportamiento, como cambios en el mecanismo o configuraciones de registro durante el proceso de migración.

    Para recuperar la información requerida en airflow2, le sugiero que explore la funcionalidad incorporada del CLI de airflow2. Puede encontrar un conjunto completo de comandos que le permiten consultar y administrar DAG, las instancias de tareas y las ejecuciones. Por ejemplo, el comando airflow dags list_runs puede ayudarlo a listar las ejecuciones de DAG junto con sus estados, tiempos de inicio y finalización y otros detalles relevantes.

    Alternativamente, si aún desea analizar los registros, es posible que desee verificar si los nuevos registros de airflow2 se han desplazado a una ubicación diferente y si su formato ha cambiado. También puede revisar los archivos de configuración de registro de airflow2 para ver si se hicieron cambios que puedan afectar los datos que está buscando.

    Espero que esto ayude. Si tiene alguna pregunta adicional, no dude en preguntar.

    Atentamente,

    Experto en TI

Comments are closed.