mirror of
https://github.com/datahub-project/datahub.git
synced 2025-06-27 05:03:31 +00:00
23 lines
715 B
Python
23 lines
715 B
Python
|
# read-modify-write requires access to the DataHubGraph (RestEmitter is not enough)
|
||
|
|
from datahub.ingestion.graph.client import DatahubClientConfig, DataHubGraph
|
||
|
|
|
||
|
|
gms_endpoint = "http://localhost:8080"
|
||
|
|
graph = DataHubGraph(DatahubClientConfig(server=gms_endpoint))
|
||
|
|
|
||
|
|
# Query multiple aspects from entity
|
||
|
|
query = """
|
||
|
|
mutation batchRemoveOwners {
|
||
|
|
batchRemoveOwners(
|
||
|
|
input: {
|
||
|
|
ownerUrns: ["urn:li:corpuser:jdoe"],
|
||
|
|
resources: [
|
||
|
|
{ resourceUrn:"urn:li:dataset:(urn:li:dataPlatform:hdfs,SampleHdfsDataset,PROD)"} ,
|
||
|
|
{ resourceUrn:"urn:li:dataset:(urn:li:dataPlatform:hive,fct_users_created,PROD)"} ,]
|
||
|
|
}
|
||
|
|
)
|
||
|
|
}
|
||
|
|
"""
|
||
|
|
result = graph.execute_graphql(query=query)
|
||
|
|
|
||
|
|
print(result)
|