如何在气流中导入Secret？

Question

我试图在 Airflow 中使用一个名为 Secrets 的模块将机密传递给 Airflow 中的 KubernetesOperator。它应该导入为 from airflow.contrib.kubernetes.secret import Secret

但是我遇到了一个错误 ModuleNotFoundError: No module named 'airflow.contrib.kubernetes'

我已经尝试安装 apache-airflow kubernetes 包 pip install apache-airflow[kubernetes] 但这没有帮助。

Answer 1

导入是：

from airflow.kubernetes.secret import Secret

注意 Airflow 中的 Secret class 只能引用 Kubernetes 中已经存在的 Secret。

如果您希望“通过”= 生成机密，那么它不会起作用。您首先必须在 Kubernetes 中创建它们。您可以使用 Kubernetes Python SDK 的 create_namespaced_secret 来执行此操作 - 请参阅 Using create_namespaced_secret API in Kubernetes Python client

如何在气流中导入Secret？

How to import Secret in airflow?

kubernetes

airflow

kubernetes-secrets