Airflow DAG 脚本在日志中打印值

Question

实际上我在 Airflow 触发它之前和在 DAG 脚本中传递 JSON {"Column": "ABC123"}

我在DAG脚本中写了如下代码

 variable1 = "['Column']"
 variable2 = variable1[3:6]

 print( {variable2} )

实际上我想在 Airflow 日志中将值打印为 123 但它没有在日志中打印...DAG 运行成功但无法在日志中打印我在触发 DAG 时传递给列的值

Answer 1

我用来在 Airflow GUI 中查看日志的是库 loggings，它已经在 Python.

中

您可以尝试使用，例如：logging.info(var2)

文档：https://docs.python.org/3/library/logging.html

PD：打印某事（使用基本打印）显示在我的 Airflow GUI 日志中，所以不确定这是否有帮助。