更新时间:2026-01-06 GMT+08:00
分享

删除OBS结果集文件

  • 功能说明:删除一个指定语句执行后在OBS产生的结果集文件。
  • 方法定义:deleteResult(statement, timeout)
  • 参数说明:
表1 deleteResult参数说明

参数名称

参数类型

是否必选

描述

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)

相关文档