diff --git a/csst_common/data_manager.py b/csst_common/data_manager.py index d883415e884760101cf12f56dce57281032dd7f2..6a00d0b27936eb1ae926936d84c78e22af707877 100644 --- a/csst_common/data_manager.py +++ b/csst_common/data_manager.py @@ -11,6 +11,7 @@ Modified-History: 2022-10-26, Bo Zhang, reconstruct CsstMsDataManager, deprecate CsstMbiDataManager 2022-10-28, Bo Zhang, added CsstMsDataManager.query_rc(), dm.dfs_mode, dm.node 2022-11-06, Bo Zhang, deleted CsstMbiDataManager + 2022-11-20, Bo Zhang, added DFS APIs """ import glob import os @@ -19,6 +20,10 @@ from typing import Union from astropy.io import fits from astropy.table import Table +from csst_dfs_api.msc.calmerge import CalMergeApi +from csst_dfs_api.msc.level0 import Level0DataApi +from csst_dfs_api.msc.level0prc import Level0PrcApi +from csst_dfs_api.msc.level1 import Level1DataApi from .dfs import gaia_query_from_dfs from .logger import get_logger @@ -214,6 +219,11 @@ class CsstMsDataManager: self.logger_mod = get_logger(name="CSST L1 Module Logger", filename=os.path.join(dir_l1, log_mod)) self.logger_mod.info("logger_mod initialized") + self.dfs_L1DataApi = Level0DataApi() + self.dfs_L1DataApi = Level1DataApi() + self.dfs_L0PrcApi = Level0PrcApi() # level0到level1的处理过程记录 + self.dfs_CalApi = CalMergeApi() # 参考文件合并文件操作API + def set_env(self): """ set environment variables """ if os.uname()[1] == "dandelion": @@ -262,8 +272,8 @@ class CsstMsDataManager: # parse info _telescope, _instrument, _survey, _imagetype, \ - _exp_start, _exp_stop, _exp_id, \ - _detector, *_l0_post, _ext = re.split(r"[_.]", fps_img[0]) + _exp_start, _exp_stop, _exp_id, \ + _detector, *_l0_post, _ext = re.split(r"[_.]", fps_img[0]) _exp_start = int(_exp_start) _exp_stop = int(_exp_stop)