原文参考:https://blog.csdn.net/m0_54252387/article/details/125757573
1.我们导入的时候不需要新建,导入的时候表已经建好了,因此该文章中的表不再需要新建了,关键是如何写才能关联到原来的表,研究尝试了很多次:
写法如下:make_dataset_urn("postgres", "1级目录.2级目录.表名")
目录和表之间用" . "隔开即可。
2.删除血缘关系如何操作,其实也很简单:
将src_urns = []再执行一次即可。
add_data_lineage(
src_urns = [],
dest_urn = builder.make_dataset_urn("postgres", "zy.dwd.zyac_xxx"),
emitter = rest_emitter
)