Skip to content
GitLab
Switch branch/tag
Find file Normal viewHistoryPermalink
test_facility_level2.py 2.22 KB
Newer Older
Wei Shoulin's avatar
level2  
Wei Shoulin committed
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64 
import os
import unittest
from astropy.io import fits
from csst_dfs_api.common.utils import to_table as to_fits_table
from csst_dfs_api.facility.level2 import Level2DataApi

class Level2DataTestCase(unittest.TestCase):

    def setUp(self):
        self.api = Level2DataApi()

    def test_find(self):
        recs = self.api.find(
            level1_id=1)
        print('find:', recs)

    def test_find_existed_brick_ids(self):
        recs = self.api.find_existed_brick_ids(data_type = "csst-msc-l1-phot")
        print('find_existed_brick_ids:', recs)        

    def test_catalog_query(self):
        result = self.api.catalog_query(
            sql = 'select x,y,A,B,PA,AB,E from csst_msc_l1_phot',
            limit = 2)
        print(result)
        if result.success and result['totalCount'] > 0:
            dt = to_fits_table(result)
            dt.pprint()

    # def test_get(self):
    #     rec = self.api.get(id = 1)
    #     print('get:', rec)

    # def test_update_proc_status(self):
    #     rec = self.api.update_proc_status(id = 1, status = 4)
    #     print('update_proc_status:', rec)

    # def test_update_qc2_status(self):
    #     rec = self.api.update_qc2_status(id = 1, status = 7)
    #     print('update_qc2_status:', rec)

    # def test_write(self):
    #     rec = self.api.write(
    #         level1_id= 1, 
    #         module_id = 'MSC',
    #         data_type = "csst-msc-l1-phot",
    #         prc_status = 3,
    #         prc_time = '2021-10-22 11:12:13',
    #         filename = "CSST_MSC_MS_SCIE_20240821005429_20240821005659_10160000004_12_L1_V01_CAT.fits",
    #         file_path = "/opt/temp/csst/msc/L2/CSST_MSC_MS_SCIE_20240821005429_20240821005659_10160000004_12_L1_V01_CAT.fits",
    #         pipeline_id = "P1"
    #         )
    #     print('write:', rec)
        # rec = self.api.write(
        #     level1_id= 1, 
        #     module_id = 'MSC',
        #     data_type = "csst-msc-xcat",
        #     prc_status = 3,
        #     prc_time = '2021-10-22 11:12:13',
        #     filename = "MSC_MS_XCAT_BRICK_156958.fits",
        #     file_path = "/opt/temp/csst/fits_file/L2/L2_DEMO/MSC_MS_XCAT_BRICK_156958.fits",
        #     pipeline_id = "P1"
        #     )
        # print('write:', rec)