airflow.providers.apache.flink.operators.flink_kubernetes¶
類¶
在 Kubernetes 叢集中建立 flinkDeployment 物件。 |
模組內容¶
- class airflow.providers.apache.flink.operators.flink_kubernetes.FlinkKubernetesOperator(*, application_file, namespace=None, kubernetes_conn_id='kubernetes_default', api_group='flink.apache.org', api_version='v1beta1', in_cluster=None, cluster_context=None, config_file=None, plural='flinkdeployments', **kwargs)[source]¶
Bases:
airflow.models.BaseOperator在 Kubernetes 叢集中建立 flinkDeployment 物件。
另請參閱
有關如何使用此 Operator 的更多資訊，請參閱指南： FlinkKubernetesOperator
另請參閱
有關 Flink Deployment Object 的更多詳細資訊，請參閱參考： https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment
- 引數：:
application_file (str) – 將 Kubernetes ‘flinkDeployment’ 的 ‘custom_resource_definition’ 定義為 ‘.yaml’ 檔案路徑、‘.json’ 檔案路徑、YAML 字串或 JSON 字串。
namespace (str | None) – flinkDeployment 所在的 kubernetes 名稱空間
kubernetes_conn_id (str) – 用於連線 Kubernetes 叢集的 kubernetes 連線 ID。
api_group (str) – flinkDeployment 的 kubernetes api group
api_version (str) – flinkDeployment 的 kubernetes api version
in_cluster (bool | None) – 使用 in_cluster 配置執行 kubernetes 客戶端。
cluster_context (str | None) – 指向 kubernetes 叢集的上下文。當 in_cluster 為 True 時忽略。如果為 None，則使用當前上下文。
config_file (str | None) – Kubernetes 配置檔案的路徑。（模板化）如果未指定，預設值為
~/.kube/config
- template_fields: collections.abc.Sequence[str] = ('application_file', 'namespace')[source]¶
- template_ext: collections.abc.Sequence[str] = ('.yaml', '.yml', '.json')[source]¶