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)[源代码]¶
基类：
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 应用程序资源名称
namespace (str | None) – flinkDeployment 所在的 Kubernetes 命名空间
kubernetes_conn_id (str) – Kubernetes 集群的 kubernetes 连接
attach_log (bool) – 确定是否应将驱动程序 pod 的日志附加到传感器日志
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')[源代码]¶