Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3
En esta página, se muestra cómo usar Secret Manager para almacenar las conexiones y secretos de Airflow de forma segura.
Configura Secret Manager para tu entorno
En esta sección, se explica cómo configurar Secret Manager para que puedes usar Secrets con tu entorno de Cloud Composer.
Habilita la API de Secret Manager
Console
Enable the Secret Manager API.
gcloud
Enable the Secret Manager API:
gcloud services enable secretmanager.googleapis.com
Configura el control de acceso
Debes configurar el control de acceso para que Airflow pueda acceder a los secretos almacenados en Secret Manager.
Para ello, la cuenta de servicio que accede a los Secrets debe tener un rol con
el permiso secretmanager.versions.access
Por ejemplo, el rol de Administrador y descriptor de acceso a secretos incluye este permiso.
Puedes otorgar este rol Nivel secreto, proyecto, organización o carpeta.
Usa una de las siguientes opciones:
(Recomendado) Otorga este rol a la cuenta de servicio de tu entorno.
Anula la cuenta de servicio en la que Airflow accede a Secret Manager.
- Otorga este rol a una cuenta de servicio.
- Configura el parámetro
gcp_key_path
delbackend_kwargs
Opción de configuración de Airflow para apuntar a un archivo JSON con las credenciales de la cuenta de servicio.
Habilita y configura el backend de Secret Manager
Anula la siguiente opción de configuración de Airflow:
Sección Clave Valor secrets
backend
airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend
Para agregar parámetros de configuración opcionales, anula la siguiente opción de configuración de Airflow:
Sección Clave Valor secrets
backend_kwargs
Consulta la siguiente descripción. El valor
backend_kwargs
es la representación JSON del objetobackend_kwargs
con los siguientes campos:connections_prefix
: Es el prefijo del nombre del secreto que se debe leer para que se pueda hacer lo siguiente: get Connections. El valor predeterminado esairflow-connections
.variables_prefix
: Es el prefijo del nombre del secreto que se debe leer para obtener los datos. variables. El valor predeterminado esairflow-variables
.gcp_key_path
: Es la ruta de acceso al archivo JSON de credenciales de Google Cloud (si no se proporciona, se usará la cuenta de servicio predeterminada).gcp_keyfile_dict
: Diccionario JSON de credenciales de Google Cloud. Mutuamente exclusivos congcp_key_path
.sep
: Separador que se usa para concatenarconnections_prefix
yconn_id
. El valor predeterminado es-
.project_id
: Es el ID del proyecto de Google Cloud en el que se almacenan los secretos.
Por ejemplo, el valor de
backend_kwargs
puede ser:{"project_id": "<project id>", "connections_prefix":"example-connections", "variables_prefix":"example-variables", "sep":"-"}
Agrega conexiones y variables en Secret Manager
Crea secretos siguiendo los pasos que se describen en Crea secretos y versiones.
Variables
- Debe usar el formato
[variables_prefix][sep][variable_name]
. - El valor predeterminado para
[variables_prefix]
esairflow-variables
. - El separador predeterminado
[sep]
es-
Por ejemplo, si el nombre de la variable es example-var
, el nombre del secreto es airflow-variables-example-var
.
Nombres de las conexiones
- Debe usar el formato
[connection_prefix][sep][connection_name]
. - El valor predeterminado para
[connection_prefix]
esairflow-connections
. - El separador predeterminado
[sep]
es-
Por ejemplo, si el nombre de la conexión es exampleConnection
, el nombre del secreto es airflow-connections-exampleConnection
.
Valores de conexión
Debe usar Representación del URI. Por ejemplo,
postgresql://login:secret@examplehost:9000
El URI debe estar codificado como URL (codificado como porcentaje). Por ejemplo, una contraseña que tiene un símbolo de espacio debe estar codificada como URL de la siguiente manera:
postgresql://login:secret%20password@examplehost:9000
.
Airflow tiene un método útil para generar URIs de conexión. Se encuentra disponible un ejemplo de cómo codificar una URL compleja con extras de JSON en la documentación de Airflow.
Usa Secret Manager con Cloud Composer
Cuando recuperas variables y conexiones, Cloud Composer verifica Secret Manager primero. Si no se encuentra la variable o la conexión solicitada, Cloud Composer verifica las variables de entorno y la base de datos de Airflow.
Leer variables con plantillas de Jinja
Puedes usar Secret Manager para leer variables con las plantillas Jinja para los campos del operador con plantillas (que se resuelven en el momento de la ejecución).
Para el secreto airflow-variables-secret_filename
:
file_name = '{{var.value.secret_filename}}'
Cómo leer variables con operadores personalizados y devoluciones de llamada
También puedes usar Secret Manager para leer variables en operadores o métodos de devolución de llamada de los operadores. La lectura de variables desde DAG puede afectar de forma negativa el rendimiento, por lo que se recomienda el uso de plantillas de Jinja si deseas usar variables en tus DAG.
Por ejemplo, para el secreto airflow-variables-secret_filename
:
from airflow.models.variable import Variable
file_name = Variable.get('secret_filename')
Leer conexiones
A menos que escribas un operador personalizado, rara vez necesitas acceder directamente a las conexiones. La mayoría de los hooks reciben el nombre de conexión como su parámetro de creación de instancias, y deben recuperar las conexiones del backend del secreto automáticamente cuando se ejecutan las tareas.
Leer las conexiones directamente puede ser útil cuando escribes tu propio hook.
Por ejemplo, para la conexión airflow-connections-exampleConnection
:
from airflow.hooks.base_hook import BaseHook
exampleConnection = BaseHook.get_connection('exampleConnection')
BaseHook.get_connection
muestra un objeto Connection
. Es posible obtener la representación de string de URI de una conexión como esta:
exampleConnectionUri = BaseHook.get_connection('exampleConnection').get_uri()