如何将自己的日志(log)添加到自动生成的Apache Airflow日志(log)中？任何打印语句都不会登录到那里，所以我想知道如何添加日志(log)，以便它也显示在UI上？
如何将自己的日志(log)添加到自动生成的Apache Airflow日志(log)中？任何打印语句都不会登录到那里，所以我想知道如何添加日志(log)，以便它也显示在UI上？
我认为您可以通过使用日志(log)模块和信任配置来解决这个问题.
比如:
import ...
dag = ...
def print_params_fn(**kwargs):
import logging
logging.info(kwargs)
return None
print_params = PythonOperator(task_id="print_params",
python_callable=print_params_fn,
provide_context=True,
dag=dag)