airflow.providers.apache.flink.sensors.flink_kubernetes¶

類¶

FlinkKubernetesSensor

檢查 Kubernetes 叢集中的 flinkDeployment 物件。

模組內容¶

class airflow.providers.apache.flink.sensors.flink_kubernetes.FlinkKubernetesSensor(*, application_name, attach_log=False, namespace=None, kubernetes_conn_id='kubernetes_default', api_group='flink.apache.org', api_version='v1beta1', plural='flinkdeployments', **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

檢查 Kubernetes 叢集中的 flinkDeployment 物件。

另請參閱

有關 Flink Deployment 物件的更多詳細資訊，請參閱以下參考資料：https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment

引數:

application_name (str) – flink Application 資源名稱
namespace (str | None) – flinkDeployment 所在的 Kubernetes 名稱空間
kubernetes_conn_id (str) – 到 Kubernetes 叢集的 Kubernetes 連線
attach_log (bool) – 確定是否應將驅動程式 pod 的日誌附加到 sensor 日誌
api_group (str) – flinkDeployment 的 Kubernetes API 組
api_version (str) – flinkDeployment 的 Kubernetes API 版本
plural (str) – Kubernetes API 自定義物件複數

template_fields: collections.abc.Sequence[str] = ('application_name', 'namespace')[source]¶

FAILURE_STATES = ('MISSING', 'ERROR')[source]¶

SUCCESS_STATES = ('READY',)[source]¶

application_name[source]¶

attach_log = False[source]¶

namespace = None[source]¶

kubernetes_conn_id = 'kubernetes_default'[source]¶

hook[source]¶

api_group = 'flink.apache.org'[source]¶

api_version = 'v1beta1'[source]¶

plural = 'flinkdeployments'[source]¶

poke(context)[source]¶

派生此類時覆蓋。