• 主页
• airflow.providers.cncf.kubernetes
• airflow.providers.cncf.kubernetes.callbacks

airflow.providers.cncf.kubernetes.callbacks

模块内容

类

ExecutionMode	执行模式的枚举类。
KubernetesPodOperatorCallback	KubernetesPodOperator 回调方法。

属性

client_type

airflow.providers.cncf.kubernetes.callbacks.client_type

class airflow.providers.cncf.kubernetes.callbacks.ExecutionMode

基类: str, enum.Enum

执行模式的枚举类。

SYNC = 'sync'

ASYNC = 'async'

class airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback

KubernetesPodOperator 回调方法。

目前，回调方法在异步模式下不会被调用，此支持将在未来添加。

static on_sync_client_creation(*, client, **kwargs)

在创建同步客户端后调用此回调。

参数

client (kubernetes.client.CoreV1Api) – 创建的 kubernetes.client.CoreV1Api 客户端。

static on_pod_creation(*, pod, client, mode, **kwargs)

在创建 Pod 后调用此回调。

参数

• pod (kubernetes.client.V1Pod) – 创建的 Pod。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

static on_pod_starting(*, pod, client, mode, **kwargs)

当 Pod 启动时调用此回调。

参数

• pod (kubernetes.client.V1Pod) – 启动的 Pod。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

static on_pod_completion(*, pod, client, mode, **kwargs)

当 Pod 完成时调用此回调。

参数

• pod (kubernetes.client.V1Pod) – 完成的 Pod。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

static on_pod_cleanup(*, pod, client, mode, **kwargs)

在清理/删除 Pod 后调用此回调。

参数

• pod (kubernetes.client.V1Pod) – 完成的 Pod。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

static on_operator_resuming(*, pod, event, client, mode, **kwargs)

从延迟状态恢复 KubernetesPodOperator 时调用此回调。

参数

• pod (kubernetes.client.V1Pod) – Pod 的当前状态。

• event (dict) – 从触发器返回的事件。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

static progress_callback(*, line, client, mode, **kwargs)

调用此回调以处理 Pod 容器日志。

参数

• line (str) – 读取的日志行。

• client (client_type) – 可在回调中使用的 Kubernetes 客户端。

• mode (str) – 当前执行模式，它是 (sync, async) 之一。

上一个 下一个

此条目是否有帮助？