Apache Atlas to Airflow

 

 

https://airflow.apache.org/docs/stable/lineage.html

Lineage — Airflow Documentation

 

 

https://pypi.org/project/atlasclient/

atlasclient

 

 

from atlasclient.client import Atlas
client = Atlas('xxx.xxx.xxx.xxx', port=21000, username='admin', password='admin')
# client.entity_guid(<guid>).status
params = {'typeName': 'DB', 'attrName': 'name', 'attrValue': 'Logging', 'offset': '1', 'limit':'10'}
search_results = client.search_attribute(**params)
for s in search_results:
    for e in s.entities:
         print(e.name)
         print(e.guid)