Как импортировать линию воздушного потока в атлас?

Question

Мне нравится это: https://airflow.apache.org/lineage.html

в моем airflow.cfg:

[lineage]
   backend = airflow.lineage.backend.atlas

[atlas]
  username = my_username
  password = my_password
  host = host
  port = 21000

Я запускаю образец DAG в ariflow, а затем встречаю ошибку следующим образом:

{init.py: 44} DEBUG - Невозможно импортировать airflow.lineage.backend.atlas, так как Модуль "airflow.lineage.backend" не определяет атрибут / класс "atlas"

кто-нибудь может мне помочь?

Answer 1

Я только что обновил эту часть. https://github.com/apache/airflow/blob/master/docs/lineage.rst#apache-atlas

Ты можешь попробовать

backend = airflow.lineage.backend.atlas.AtlasBackend

Любые отзывы приветствуются:)