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 Object 的更多詳細資訊，請參閱參考文檔： 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')[原始碼]¶