Skip to content

API-based Open Lineage Log Store Integration Connector

Connector details

Overview

The API-based OpenLineage Log Store integration connector calls an OpenLineage compliant API to store open lineage events that have been published to the Lineage Integrator OMIS instance where this connector is running.

Figure 1

Figure 1: Operation of the API-based OpenLineage log store integration connector

Configuration

This connector uses the Lineage Integrator OMIS running in the Integration Daemon.

This is its connection definition to use on the administration commands that configure the API Integrator OMIS.

Connection configuration

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
{
   "connection" : 
                { 
                    "class" : "Connection",
                    "qualifiedName" : "Egeria:IntegrationConnector:Lineage:APIBasedOpenLineageLogStore Connection",
                    "connectorType" : 
                    {
                        "class" : "ConnectorType",
                        "connectorProviderClassName" : "org.odpi.openmetadata.adapters.connectors.integration.lineage.APIBasedOpenLineageLogStoreProvider"
                    },
                    "endpoint" :
                    {
                        "class" : "Endpoint",
                        "address" : "{{logStoreURL}}"
                    }
                }
}
  • Replace {{logStoreURL}} with the URL of the destination API.
Back to top