Commit 6be6c689 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

feat(client): add delete functionality for level0 and level1 data

- Added delete method in request module to support sending data with DELETE requests
- Implemented delete function in level0 module for removing raw data by dataset
- Implemented delete function in level1 module for removing processed data records
- Updated API endpoints to handle deletion requests with proper parameters
- Added documentation for new delete functions including arguments and return values
parent d0952d3d
Pipeline #10708 failed with stages
in 0 seconds
...@@ -60,10 +60,11 @@ def put(endpoint: str, data: Optional[dict] = None, timeout = os.getenv("CSST_DF ...@@ -60,10 +60,11 @@ def put(endpoint: str, data: Optional[dict] = None, timeout = os.getenv("CSST_DF
) )
@request_error_handler_decorator @request_error_handler_decorator
def delete(endpoint: str, timeout = os.getenv("CSST_DFS_REQUEST_TIMEOUT", None)) -> requests.Response: def delete(endpoint: str, data: Optional[dict] = None, timeout = os.getenv("CSST_DFS_REQUEST_TIMEOUT", None)) -> requests.Response:
return requests.delete( return requests.delete(
url = get_request_url(endpoint), url = get_request_url(endpoint),
headers = auth_header(), headers = auth_header(),
json = data,
timeout = timeout timeout = timeout
) )
......
...@@ -377,3 +377,17 @@ def new(data: dict) -> Result: ...@@ -377,3 +377,17 @@ def new(data: dict) -> Result:
""" """
return request.post("/api/level0/new", data) return request.post("/api/level0/new", data)
def delete(dataset: str, data_model: str = 'raw') -> Result:
"""
删除0级数据,用于仿真数据测试
Args:
dataset (str): 数据集
data_model (str): 数据模型
Returns:
Result: 操作的结果对象,包含操作是否成功以及相关的错误信息,成功返回数据对象
"""
return request.delete("/api/level0/delete", params = {"dataset": dataset, "data_model": data_model})
...@@ -343,4 +343,19 @@ def add_process(level1_id: str, ...@@ -343,4 +343,19 @@ def add_process(level1_id: str,
'message': message, 'message': message,
} }
utils.is_valid_datetime_format(prc_date) utils.is_valid_datetime_format(prc_date)
return request.post("/api/level1/prc", params) return request.post("/api/level1/prc", params)
\ No newline at end of file
def delete(dataset: str, batch_id: str, data_model: str) -> Result:
"""
删除1级数据处理记录
Args:
dataset (str): 数据集
batch_id (str): 批次ID
data_model (str): 数据模型
Returns:
Result: 操作的结果对象,包含操作是否成功以及相关的错误信息,成功返回数据对象
"""
return request.delete("/api/level1/delete", params = {"dataset": dataset, "batch_id": batch_id, "data_model": data_model})
\ No newline at end of file
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment