Airflow KubernetesPodOperator - использование значения ConfigMap в качестве переменной среды
У меня есть Kubernetes ConfigMap под названием
test
который содержит ключ с некоторым значением. Я хотел бы использовать значение этого ключа в переменной окружения.
import datetime
import os
from airflow import models
from airflow.contrib.kubernetes.volume import Volume
from airflow.contrib.kubernetes.volume_mount import VolumeMount
from airflow.contrib.operators import kubernetes_pod_operator
YESTERDAY = datetime.datetime.now() - datetime.timedelta(days=1)
cm_test = ['test']
volume_mount = VolumeMount('test',
mount_path='/config/',
sub_path=None,
read_only=False)
volume_config = {
'configMap': {
'name': 'test'
}
}
volume = Volume(name='test', configs=volume_config)
with models.DAG(
dag_id="test_env",
schedule_interval=datetime.timedelta(days=1),
start_date=YESTERDAY) as dag:
kubenetes_template_ex = kubernetes_pod_operator.KubernetesPodOperator(
task_id="test_env",
name="test_env",
namespace="foobar",
image="bash",
cmds=["printenv"],
arguments=[],
volumes=[volume],
volume_mounts=[volume_mount],
configmaps=cm_test,
env_vars={
'MY_ENV_VAR': '/config/foobar'
}
)
Что работает : ConfigMap доступен в смонтированном томе, поэтому я могу сделать
ls /config
и показан.
Что не работает : я хотел бы установить переменную среды со значением из
foobar
из смонтированной configmap. Текущий код не работает, так как буквальное строковое значение
/config/foobar
передается в env var.