更新时间:2026-01-06 GMT+08:00
删除OBS结果集文件
- 功能说明:删除一个指定语句执行后在OBS产生的结果集文件。
- 方法定义:deleteResult(statement, timeout)
- 参数说明:
|
参数名称 |
参数类型 |
是否必选 |
描述 |
|---|---|---|---|
|
statement |
Statement |
必选 |
需要删除结果集的语句Statement。 |
|
timeout |
float |
可选 |
超时时间。 |
- 响应体说明:该接口无响应体返回
- 示例代码:
import os from fabricsql.SQLClient import FabricSQLClient from fabricsql.SQLRequests import SessionRequest, QueryRequest # AK/SK属于敏感信息,推荐通过环境变量方式获取,避免直接明文编码在程序中 endpoint = 'xxxxxxxxxxxxxx' accessKey = 'xxxxxxxxxxxxxx' secretKey = 'xxxxxxxxxxxxxxx' workspace_id = 'xxxxxxxxxxxxx' client = FabricSQLClient(ep,ak ,sk) # 创建一个Session请求,填入必要信息 s = SessionRequest() s.endpoint_id = endpoint_id s.instance_id = instance_id s.catalog = catalog #创建一个Session,获取session_id每一个Statement结构体代表一个单SQL语句的执行结果 session = client.createSession(workspace_id, s) session_id = session.session_id # 创建一个SQL请求 q = QueryRequest() q.statement = "select * from a" q.session_id = session_id #下发请求,返回一个请求响应 query_resp = client.executeQuery(workspace_id, q) #根据该请求响应,轮询请求结果 while True: statement_set = client.getSummary(workspace_id, query_resp, get_schema=False) if statement_set.status == "SUCCESSFUL" or statement_set.status == "FAIL": break #等待2s后轮询 time.sleep(2) # 删除结果集文件 for statement in statement_set.statements: client.deleteResult(statement)