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)[源码]¶
基类:
airflow.models.BaseOperator
在 Kubernetes 集群中创建 flinkDeployment 对象。
参见
有关如何使用此操作符的更多信息,请查看指南:FlinkKubernetesOperator
参见
有关 Flink Deployment 对象的更多详细信息,请查看参考资料:https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment
- 参数
application_file (str) – 将 ‘flinkDeployment’ 的 Kubernetes ‘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')[源码]¶
- template_ext: collections.abc.Sequence[str] = ('.yaml', '.yml', '.json')[源码]¶