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]¶