mirror of
https://github.com/datahub-project/datahub.git
synced 2025-07-04 07:34:44 +00:00
18 lines
510 B
Python
18 lines
510 B
Python
|
import datahub.emitter.mce_builder as builder
|
||
|
|
from datahub.emitter.rest_emitter import DatahubRestEmitter
|
||
|
|
|
||
|
|
# Construct a lineage object.
|
||
|
|
lineage_mce = builder.make_lineage_mce(
|
||
|
|
[
|
||
|
|
builder.make_dataset_urn("bigquery", "upstream1"),
|
||
|
|
builder.make_dataset_urn("bigquery", "upstream2"),
|
||
|
|
],
|
||
|
|
builder.make_dataset_urn("bigquery", "downstream"),
|
||
|
|
)
|
||
|
|
|
||
|
|
# Create an emitter to the GMS REST API.
|
||
|
|
emitter = DatahubRestEmitter("http://localhost:8080")
|
||
|
|
|
||
|
|
# Emit metadata!
|
||
|
|
emitter.emit_mce(lineage_mce)
|