Cloud Composer - Получить Google пользователь - PullRequest
Новая
       7

Cloud Composer - Получить Google пользователь

0 голосов
/ 19 сентября 2018

Есть ли способ получить имя учетной записи Google, на котором запущены DAG, из определения DAG?Это будет очень полезно, чтобы отследить, какие пользователи использовали DAG.

Я вижу только: 

unixname    --> always airflow
owner       --> fixed in the dag definition

С уважением, Эдуардо

1 Ответ

0 голосов
/ 23 октября 2018

Возможно, поскольку группы доступности баз данных в Composer по сути являются объектами GCS.API GET объекта GCS сообщает, кто загрузил этот объект.Итак, вот один из возможных способов получения информации о владельце:

  1. Определите функцию user_lookup () в определении DAG.
  2. Реализация user_look () состоит из следующих шагов: a)получает текущий путь к файлу (например, os.path.basename (__ file__));б) на основании того, как объекты Composer GCS отображаются локально, определяет соответствующий путь к объекту GCS (например, gs: // {your-bucket} / object);c) считывает сведения об объекте GCS и возвращает object.owner.
  3. В определении DAG установите owner = user_lookup ().

Сообщите нам, работает ли вышеуказанное для вас.

...