airflow.providers.edge3.models.edge_worker¶

异常¶

EdgeWorkerVersionException

表示核心组件与 Edge Site 之间的版本不匹配。

类¶

`EdgeWorkerState`	Edge Worker 实例的状态。
`EdgeWorkerModel`	一个 Edge Worker 实例，用于报告状态和健康状况。

函数¶

`set_metrics`(worker_name, state, jobs_active, ...)	设置 edge worker 的指标。
`reset_metrics`(worker_name)	重置 worker 的指标。
`request_maintenance`(worker_name, maintenance_comment)	将维护请求写入数据库。
`exit_maintenance`(worker_name[, session])	将退出维护状态写入数据库。
`remove_worker`(worker_name[, session])	从数据库中移除离线或已不存在的 worker。
`change_maintenance_comment`(worker_name, ...[, session])	在数据库中写入维护注释。

模块内容¶

exception airflow.providers.edge3.models.edge_worker.EdgeWorkerVersionException[source]¶

基类: airflow.exceptions.AirflowException

表示核心组件与 Edge Site 之间的版本不匹配。

class airflow.providers.edge3.models.edge_worker.EdgeWorkerState[source]¶

基类: str, enum.Enum

Edge Worker 实例的状态。

STARTING = 'starting'[source]¶: Edge Worker 正在初始化。

RUNNING = 'running'[source]¶: Edge Worker 正在活动地运行任务。

IDLE = 'idle'[source]¶: Edge Worker 处于活动状态并等待任务。

TERMINATING = 'terminating'[source]¶: Edge Worker 正在完成工作并停止。

OFFLINE = 'offline'[source]¶: Edge Worker 已关闭。

UNKNOWN = 'unknown'[source]¶: 一段时间内没有收到 worker 的心跳信号，Edge Worker 可能已宕机。

MAINTENANCE_REQUEST = 'maintenance request'[source]¶: 已请求 worker 进入维护模式。worker 收到此请求后将暂停获取作业。

MAINTENANCE_PENDING = 'maintenance pending'[source]¶: Edge worker 已收到维护请求，正在等待作业完成。作业完成后将进入“维护模式”。

MAINTENANCE_MODE = 'maintenance mode'[source]¶: Edge worker 处于维护模式。它在线，但暂停获取作业。

MAINTENANCE_EXIT = 'maintenance exit'[source]¶: 请求 worker 退出维护模式。worker 收到此状态后将取消暂停并获取新作业。

OFFLINE_MAINTENANCE = 'offline maintenance'[source]¶: worker 在维护模式下关闭。重新启动时将处于维护模式。

class airflow.providers.edge3.models.edge_worker.EdgeWorkerModel(worker_name, state, queues, first_online=None, last_update=None, maintenance_comment=None)[source]¶

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

一个 Edge Worker 实例，用于报告状态和健康状况。

__tablename__ = 'edge_worker'[source]¶

worker_name[source]¶

state[source]¶

maintenance_comment[source]¶

first_online[source]¶

last_update[source]¶

jobs_active[source]¶

jobs_taken[source]¶

jobs_success[source]¶

jobs_failed[source]¶

sysinfo[source]¶

属性 queues: list[str] | None[source]¶

返回存储在 queues 字段中的队列列表。

属性 sysinfo_json: dict[source]¶

将新队列添加到 queues 字段。

remove_queues(remove_queues)[source]¶

从 queues 字段中移除队列。

update_state(state)[source]¶

更新 state 字段。

airflow.providers.edge3.models.edge_worker.set_metrics(worker_name, state, jobs_active, concurrency, free_concurrency, queues)[source]¶

设置 edge worker 的指标。

重置 worker 的指标。

airflow.providers.edge3.models.edge_worker.reset_metrics(worker_name)[source]¶

将维护请求写入数据库。

airflow.providers.edge3.models.edge_worker.request_maintenance(worker_name, maintenance_comment, session=NEW_SESSION)[source]¶

将退出维护状态写入数据库。

airflow.providers.edge3.models.edge_worker.exit_maintenance(worker_name, session=NEW_SESSION)[source]¶

从数据库中移除离线或已不存在的 worker。

airflow.providers.edge3.models.edge_worker.remove_worker(worker_name, session=NEW_SESSION)[source]¶

在数据库中写入维护注释。