How to integrate Astronomer/OpenLineage

Have more questions? Submit a request

To integrate Astronomer/OpenLineage with Atlan, review the order of operations and then complete the following steps.

Create an API token in Atlan

Before running the workflow, you will need to create an API token in Atlan.

Select the source in Atlan

To select Astronomer/OpenLineage as your source, from within Atlan:

  1. In the top right of any screen, click New and then click New workflow.
  2. From the filters along the top, click Orchestrator.
  3. From the list of packages, select Astronomer Airflow Assets and then click Setup Workflow.

Configure the integration in Atlan

To configure the Astronomer/OpenLineage connection, from within Atlan:

  1. For Host, enter the URL of your Astronomer Airflow UI.
  2. (Optional) For Port, enter the port number for your Astronomer Airflow UI.
  3. For Enable OpenLineage Events, click Yes to enable the processing of OpenLineage events or click No to disable it. If disabled, new events will not be processed in Atlan.
  4. For Connection Name, provide a connection name that represents your source environment. For example, you might use values like production,development,gold, or analytics.
  5. (Optional) To change the users who are able to manage this connection, change the users or groups listed under Connection Admins.
    🚨 Careful! If you do not specify any user or group, no one will be able to manage the connection β€” not even admins.
  6. To run the workflow, at the bottom of the screen, click the Run button.

Configure the integration in Astronomer

πŸ’ͺ Did you know? You will need the Atlan API token and connection name to configure the integration in Astronomer. This will allow Astronomer to connect with the OpenLineage API and send events to Atlan.

Astronomer has a built-in OpenLineage integration. You will need to use environment variables in Astronomer to set custom values for the integration with Atlan.

To configure Astronomer to send OpenLineage events to Atlan:

  1. Open your Astronomer console and select a workspace.
  2. In the left menu under Workspace, click Deployments and then select a deployment.
  3. On your deployment page, click the Variables tab.
  4. On the Variables page, click the Edit variables button.
  5. Add the following environment variable keys and corresponding values:
    • OPENLINEAGE_URL: points to the service that will consume OpenLineage events β€” for example, https://<instance>.atlan.com/events/openlineage/airflow-astronomer/.
    • OPENLINEAGE_API_KEY: set the API token generated in Atlan.
    • OPENLINEAGE_NAMESPACE: set the connection name as exactly configured in Atlan.
  6.  Click Update Environment Variables to save your changes. It can take up to two minutes for new variables to be applied to your deployment.

Once the orchestrator has completed running, you will see Airflow DAGs and tasks along with lineage from OpenLineage events in Atlan! πŸŽ‰

Related articles

Was this article helpful?
0 out of 0 found this helpful