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 物件。
See also
For more information on how to use this operator, take a look at the guide: FlinkKubernetesOperator
See also
For more detail about Flink Deployment Object have a look at the reference: 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 群組
api_version (str) – flinkDeployment 的 Kubernetes API 版本
in_cluster (bool | None) – 以 in-cluster 配置執行 Kubernetes 客戶端。
cluster_context (str | None) – 指向 Kubernetes 集群的上下文。當 in_cluster 為 True 時忽略。如果為 None，則使用 current-context。
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]¶