airflow.providers.cncf.kubernetes.callbacks¶

属性¶

client_type

类¶

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

模块内容¶

airflow.providers.cncf.kubernetes.callbacks.client_type[source]¶

class airflow.providers.cncf.kubernetes.callbacks.ExecutionMode[source]¶

基类: str, enum.Enum

执行模式的枚举类。

SYNC = 'sync'[source]¶

ASYNC = 'async'[source]¶

class airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback[source]¶

KubernetesPodOperator 回调方法。

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

static on_sync_client_creation(*, client, operator, **kwargs)[source]¶

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

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

static on_pod_manifest_created(*, pod_request, client, mode, operator, context, **kwargs)[source]¶

在 KPO 创建 V1Pod 清单后，但在 Pod 创建前调用此回调。

参数:

pod_request (kubernetes.client.V1Pod) – Kubernetes Pod 清单
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_pod_creation(*, pod, client, mode, operator, context, **kwargs)[source]¶

创建 Pod 后调用此回调。

参数:

pod (kubernetes.client.V1Pod) – 创建的 Pod。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_pod_starting(*, pod, client, mode, operator, context, **kwargs)[source]¶

当 Pod 启动时调用此回调。

参数:

pod (kubernetes.client.V1Pod) – 启动的 Pod。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_pod_completion(*, pod, client, mode, operator, context, **kwargs)[source]¶

当 Pod 完成时调用此回调。

参数:

pod (kubernetes.client.V1Pod) – 完成的 Pod。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_pod_teardown(*, pod, client, mode, operator, context, **kwargs)[source]¶

在所有 Pod 完成回调之后，但在 Pod 被删除之前调用此回调。

参数:

pod (kubernetes.client.V1Pod) – 完成的 Pod。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_pod_cleanup(*, pod, client, mode, operator, context, **kwargs)[source]¶

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

参数:

pod (kubernetes.client.V1Pod) – 完成的 Pod。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static on_operator_resuming(*, pod, event, client, mode, operator, context, **kwargs)[source]¶

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

参数:

pod (kubernetes.client.V1Pod) – Pod 的当前状态。
event (dict) – 从 Trigger 返回的事件。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。

static progress_callback(*, line, client, mode, **kwargs)[source]¶

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

参数:

line (str) – 读取的日志行。
client (client_type) – 可在此回调中使用的 Kubernetes 客户端。
mode (str) – 当前执行模式，它是 (sync, async) 中的一个。