airflow.providers.apache.flink.operators.flink_kubernetes¶

类¶

FlinkKubernetesOperator

在 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.providers.common.compat.sdk.BaseOperator

在 Kubernetes 集群中创建 flinkDeployment 对象。

另请参阅

有关如何使用此运算符的更多信息，请参阅指南： FlinkKubernetesOperator

另请参阅

欲了解 Flink Deployment 对象的更多细节，请查看参考文档： https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment

参数:

application_file (str) – 将 Kubernetes 的 custom_resource_definition of flinkDeployment 定义为 .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]¶

ui_color = '#f4a460'[source]¶

application_file[source]¶

namespace = None[source]¶

kubernetes_conn_id = 'kubernetes_default'[source]¶

api_group = 'flink.apache.org'[source]¶

api_version = 'v1beta1'[source]¶

plural = 'flinkdeployments'[source]¶

in_cluster = None[source]¶

cluster_context = None[source]¶

config_file = None[source]¶

property hook: airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook[source]¶

property client: kubernetes.client.CoreV1Api[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

有关更多上下文，请参考 get_template_context。