#airflow
Вопрос:
Как мне декодировать значение столбца conf таблицы dag_run, чтобы я мог прочитать значение столбца conf из таблицы
Спасибо
Комментарии:
1. Нужно ли вам явно запрашивать базу данных метастора для вашего варианта использования? Не могли бы вы подробнее объяснить необходимость прямого запроса к базе данных? Возможно, включите свой код DAG для большего контекста? Воздушный поток предоставляет
DagRunобъект как часть встроенного макроса и доступен через шаблоны Jinja.2. У нас запланированы dag, которые запускают другую dag с параметрами conf в формате JSON. Нам нужно разработать процесс для чтения таблицы метастора ariflow : таблица dag_run содержит данные столбца, и я вижу, что значение закодировано в таблице. Я пытаюсь найти способы, как мы можем декодировать значение conf и посмотреть, какие параметры передаются для каждого выполнения dag. Знаете ли вы, можно ли это сделать на уровне sql или на python? Я согласен с любым вариантом