更新时间: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)