Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
csst-dfs
csst-dfs-api-cluster
Commits
e348e72b
Commit
e348e72b
authored
Jul 21, 2023
by
Wei Shoulin
Browse files
qc status default 0
parent
891f2796
Changes
6
Hide whitespace changes
Inline
Side-by-side
csst_dfs_api_cluster/facility/level0.py
View file @
e348e72b
...
@@ -168,7 +168,7 @@ class Level0DataApi(object):
...
@@ -168,7 +168,7 @@ class Level0DataApi(object):
def
write
(
self
,
**
kwargs
):
def
write
(
self
,
**
kwargs
):
''' insert a level0 data record into database
''' insert a level0 data record into database
parameter kwargs:
parameter kwargs:
obs_id = [str]
obs_id = [str]
detector_no = [str]
detector_no = [str]
...
@@ -186,6 +186,7 @@ class Level0DataApi(object):
...
@@ -186,6 +186,7 @@ class Level0DataApi(object):
obs_type
=
get_parameter
(
kwargs
,
"obs_type"
),
obs_type
=
get_parameter
(
kwargs
,
"obs_type"
),
obs_time
=
get_parameter
(
kwargs
,
"obs_time"
),
obs_time
=
get_parameter
(
kwargs
,
"obs_time"
),
exp_time
=
get_parameter
(
kwargs
,
"exp_time"
),
exp_time
=
get_parameter
(
kwargs
,
"exp_time"
),
qc0_status
=
get_parameter
(
kwargs
,
"qc0_status"
,
0
),
detector_status_id
=
get_parameter
(
kwargs
,
"detector_status_id"
),
detector_status_id
=
get_parameter
(
kwargs
,
"detector_status_id"
),
filename
=
get_parameter
(
kwargs
,
"filename"
),
filename
=
get_parameter
(
kwargs
,
"filename"
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
)
file_path
=
get_parameter
(
kwargs
,
"file_path"
)
...
...
csst_dfs_api_cluster/facility/level1.py
View file @
e348e72b
...
@@ -229,7 +229,8 @@ class Level1DataApi(object):
...
@@ -229,7 +229,8 @@ class Level1DataApi(object):
prc_params
=
get_parameter
(
kwargs
,
"prc_params"
,
""
),
prc_params
=
get_parameter
(
kwargs
,
"prc_params"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
-
1
),
qc1_status
=
get_parameter
(
kwargs
,
"qc1_status"
,
0
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
0
),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
),
refs
=
get_parameter
(
kwargs
,
"refs"
,
{})
refs
=
get_parameter
(
kwargs
,
"refs"
,
{})
...
...
csst_dfs_api_cluster/hstdm/level2.py
View file @
e348e72b
...
@@ -149,7 +149,8 @@ class Level2DataApi(object):
...
@@ -149,7 +149,8 @@ class Level2DataApi(object):
file_type
=
get_parameter
(
kwargs
,
"file_type"
),
file_type
=
get_parameter
(
kwargs
,
"file_type"
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
-
1
),
qc2_status
=
get_parameter
(
kwargs
,
"qc2_status"
,
0
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
0
),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
)
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
)
)
)
...
...
csst_dfs_api_cluster/mbi/level2.py
View file @
e348e72b
...
@@ -258,7 +258,8 @@ class Level2DataApi(object):
...
@@ -258,7 +258,8 @@ class Level2DataApi(object):
data_type
=
get_parameter
(
kwargs
,
"data_type"
),
data_type
=
get_parameter
(
kwargs
,
"data_type"
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
-
1
),
qc2_status
=
get_parameter
(
kwargs
,
"qc2_status"
,
0
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
0
),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
)
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
)
)
)
...
...
csst_dfs_api_cluster/mbi/level2co.py
View file @
e348e72b
...
@@ -173,7 +173,8 @@ class Level2CoApi(object):
...
@@ -173,7 +173,8 @@ class Level2CoApi(object):
data_type
=
get_parameter
(
kwargs
,
"data_type"
),
data_type
=
get_parameter
(
kwargs
,
"data_type"
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
-
1
),
qc2_status
=
get_parameter
(
kwargs
,
"qc2_status"
,
0
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
0
),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
)
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
,
""
)
)
)
...
...
csst_dfs_api_cluster/sls/level2spectra.py
View file @
e348e72b
...
@@ -145,7 +145,8 @@ class Level2SpectraApi(object):
...
@@ -145,7 +145,8 @@ class Level2SpectraApi(object):
file_type
=
get_parameter
(
kwargs
,
"file_type"
),
file_type
=
get_parameter
(
kwargs
,
"file_type"
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
filename
=
get_parameter
(
kwargs
,
"filename"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
file_path
=
get_parameter
(
kwargs
,
"file_path"
,
""
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
-
1
),
qc2_status
=
get_parameter
(
kwargs
,
"qc2_status"
,
0
),
prc_status
=
get_parameter
(
kwargs
,
"prc_status"
,
0
),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
prc_time
=
get_parameter
(
kwargs
,
"prc_time"
,
format_datetime
(
datetime
.
now
())),
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
)
pipeline_id
=
get_parameter
(
kwargs
,
"pipeline_id"
)
)
)
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment