Loading csst_common/data_manager.py +2 −3 Original line number Diff line number Diff line Loading @@ -201,9 +201,6 @@ class CsstMsDataManager: self.n_jobs = 18 # DFS APIs # self.l1api = Level1DataApi() # aXe self.set_env() Loading @@ -220,6 +217,7 @@ 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") # DFS APIs self.dfs_L0DataApi = Level0DataApi() self.dfs_L1DataApi = Level1DataApi() self.dfs_L0PrcApi = Level0PrcApi() # level0到level1的处理过程记录 Loading Loading @@ -572,6 +570,7 @@ class CsstMsDataManager: dfs_mode=True, dfs_node="pml"): """ Initialize CsstMsDataManager from DFS. """ records = Level0DataApi().find(obs_id=obs_id) # query DFS print(f"{records['totalCount']} records obtained!") tbl = Table([_.__dict__ for _ in records["data"]]) tbl.sort(["detector_no", "obs_type"]) Loading Loading
csst_common/data_manager.py +2 −3 Original line number Diff line number Diff line Loading @@ -201,9 +201,6 @@ class CsstMsDataManager: self.n_jobs = 18 # DFS APIs # self.l1api = Level1DataApi() # aXe self.set_env() Loading @@ -220,6 +217,7 @@ 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") # DFS APIs self.dfs_L0DataApi = Level0DataApi() self.dfs_L1DataApi = Level1DataApi() self.dfs_L0PrcApi = Level0PrcApi() # level0到level1的处理过程记录 Loading Loading @@ -572,6 +570,7 @@ class CsstMsDataManager: dfs_mode=True, dfs_node="pml"): """ Initialize CsstMsDataManager from DFS. """ records = Level0DataApi().find(obs_id=obs_id) # query DFS print(f"{records['totalCount']} records obtained!") tbl = Table([_.__dict__ for _ in records["data"]]) tbl.sort(["detector_no", "obs_type"]) Loading