diff --git a/datahub/metadata/metaversion/metadata_comparator.py b/datahub/metadata/metaversion/metadata_comparator.py index 0f37374..6cf8b77 100644 --- a/datahub/metadata/metaversion/metadata_comparator.py +++ b/datahub/metadata/metaversion/metadata_comparator.py @@ -14,7 +14,7 @@ from common.futool.core.fu_collection import list_diff, list_intersection, is_no from common.futool.core.fu_lang import str_md5 -class MetaDataComparator(metaclass=abc.ABCMeta): +class MetadataComparator(metaclass=abc.ABCMeta): def __init__(self, version_1: int, version_2: int, source_id_1, source_id_2=None): """ @@ -185,7 +185,7 @@ class MetaDataComparator(metaclass=abc.ABCMeta): return compare_result -class SameSourceComparator(MetaDataComparator): +class SameSourceComparator(MetadataComparator): """ 同库比较 """ @@ -197,7 +197,7 @@ class SameSourceComparator(MetaDataComparator): return super()._do_compare() -class DiffSourceComparator(MetaDataComparator): +class DiffSourceComparator(MetadataComparator): """ 不同库比较 """ diff --git a/datahub/metadata/metaversion/metadata_compare_task.py b/datahub/metadata/metaversion/metadata_compare_task.py new file mode 100644 index 0000000..6892492 --- /dev/null +++ b/datahub/metadata/metaversion/metadata_compare_task.py @@ -0,0 +1,59 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- +# @Time : 2023/5/21 16:49 +# @Author : old tom +# @File : metadata_compare_task.py +# @Project : futool-tiny-datahub +# @Desc : 版本比较任务管理 +from common.futool.core.fu_lang import str_md5 + + +class MetadataCompareTaskManage(object): + """ + 版本比较任务管理 + """ + + def __init__(self, version_code_1, version_code_2, source_id_1, source_id_2=None): + """ + 初始化任务 + :param version_code_1: 版本号1 + :param version_code_2: 版本号2 + :param source_id_1: 数据源1 + :param source_id_2: 数据源2 + """ + self.version_code_1 = version_code_1 + self.version_code_2 = version_code_2 + self.source_id_1 = source_id_1 + self.compare_task_type = 'same' + if source_id_2: + self.source_id_2 = source_id_2 + self.compare_task_type = 'diff' + + def _compare_id_gen(self): + """ + 生成任务ID + :return: + """ + pass + + def create_task(self): + """ + 创建任务 + :return: + """ + pass + + def finish_task(self): + """ + 结束任务 + :return: + """ + pass + + def has_finished(self, compare_id): + """ + 判断任务是否结束 + :param compare_id: + :return: + """ + pass diff --git a/datahub/metadata/metaversion/versiondao/__init__.py b/datahub/metadata/metaversion/versiondao/__init__.py new file mode 100644 index 0000000..e539b19 --- /dev/null +++ b/datahub/metadata/metaversion/versiondao/__init__.py @@ -0,0 +1,7 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- +# @Time : 2023/5/21 16:58 +# @Author : old tom +# @File : __init__.py.py +# @Project : futool-tiny-datahub +# @Desc :