airflow.providers.apache.flink.sensors.flink_kubernetes¶
类¶
检查 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]¶