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

取消查询

  • 功能说明:取消一个正在执行中的查询。
  • 方法定义:cancelExecute(workspaceId, response, timeout)
  • 参数说明:
    表1 cancelExecute参数说明

    参数名称

    参数类型

    是否必选

    描述

    workspaceId

    str

    必选

    用户创建的Fabric的工作空间的ID。

    response

    QueryResponse

    必选

    想要取消查询的请求体。

    timeout

    float

    可选

    请求超时时间。

  • 响应体说明:空响应体Response
  • 示例代码:
    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
    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)
    # 取消查询
    client.cancelExecute(workspace_id, query_resp)

相关文档