breezy-portugal-43538
10/14/2022, 10:24 AMfamous-florist-7218
10/14/2022, 10:48 AMdatahub-rest
package first.
from datahub.metadata.schema_classes import (
ChangeTypeClass
)
import datahub.emitter.mce_builder as builder
from datahub.emitter.mcp import MetadataChangeProposalWrapper
from datahub.emitter.rest_emitter import DatahubRestEmitter
from datahub.metadata.com.linkedin.pegasus2avro.dataset import DatasetProperties
new_dataset_properties = DatasetProperties(
customProperties=None,
externalUrl='<http://your-url>',
name='your-name',
qualifiedName='qualifiedName',
description='your-description',
uri='<http://your-uri>',
tags='custom-tags'
)
mcp = MetadataChangeProposalWrapper(
entityType="dataset",
aspectName="datasetProperties",
changeType=ChangeTypeClass.UPSERT,
entityUrn=builder.make_dataset_urn_with_platform_instance(
platform="your-platform",
name="your-dataset",
platform="<<optional>>your-instance"
),
aspect=new_dataset_properties,
)
# Create an emitter to the GMS REST API.
emitter = DatahubRestEmitter("<http://localhost:8080>")
# Emit metadata!
emitter.emit_mcp(mcp)
breezy-portugal-43538
10/14/2022, 11:06 AM