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]¶

派生此类时覆盖。