airflow.providers.edge3.models.edge_logs¶

类¶

EdgeLogsModel

Edge Worker 在远程站点运行作业时临时收集的日志。

模块内容¶

class airflow.providers.edge3.models.edge_logs.EdgeLogsModel(dag_id, task_id, run_id, map_index, try_number, log_chunk_time, log_chunk_data)[source]¶

基类: airflow.models.base.Base, airflow.utils.log.logging_mixin.LoggingMixin

Edge Worker 在远程站点运行作业时临时收集的日志。

由于 Edge Worker 在大多数情况下拥有本地文件系统，而 Web UI 无法访问读取远程站点的文件，因此 Edge Worker 会将正在运行作业的日志增量块发送到中心站点。由于日志存储后端在大多数云场景下无法追加日志，因此此表被用作接收缓冲区。在任务完成后，可以将日志刷新到任务日志处理器。

因此，日志数据是按块收集的，并且仅是临时的。

__tablename__ = 'edge_logs'[source]¶

dag_id[source]¶

task_id[source]¶

run_id[source]¶

map_index[source]¶

try_number[source]¶

log_chunk_time[source]¶

log_chunk_data[source]¶