在Airflow配置文件中将'id_format'属性改为正确的格式或在代码中手动设置正确的日志id格式。
在Airflow配置文件中进行配置: 找到Airflow的配置文件 airflow.cfg 中的 [logging] 部分,并将其中的 ‘id_format’ 属性改成正确的格式,例如: id_format = %s:%s:%s:%s
在代码中手动设置日志id格式: 可以在代码中手动设置正确的日志id格式,例如: from airflow.utils.log.logging_mixin import LoggingMixin
class MyTask(LoggingMixin): def init(self, task_id, *args, **kwargs): self.log_id = 'myapp:{task_id}'.format(task_id=task_id) super().init(*args, **kwargs)
这样,就可以确保Airflow中的应用程序日志id格式是正确的。