SynapseLivyReliableHttpClient 类

经过自定义的用于与 Livy 服务通信的 http 客户端。

继承

builtins.object

SynapseLivyReliableHttpClient

构造函数

SynapseLivyReliableHttpClient(base_url: str)

参数

base_url

方法

delete_session	删除会话。
get_all_session_logs	获取给定会话的所有日志。
get_executors	获取给定应用程序的所有活动执行程序。
get_job_by_id	获取给定作业的状态。
get_jobs	获取给定应用程序的所有作业。
get_session	发送 GET 请求以获取会话状态。
get_stage_attempt_by_id	获取给定尝试的状态。
get_stage_by_id	获取给定阶段的所有尝试。
get_stages	获取给定应用程序的所有阶段。
get_statement	发送 GET 请求以获取语句状态。
post_session	发送 POST 请求来创建新会话。
post_statement	发送 POST 请求来运行语句。
reset_session_timeout	重置会话超时，使会话在另一个超时期间保持活动状态。

delete_session

删除会话。

delete_session(session_id: str)

参数

session_id

str

必需

会话 ID

get_all_session_logs

获取给定会话的所有日志。

get_all_session_logs(session_id: str)

参数

session_id

str

必需

会话 ID

get_executors

获取给定应用程序的所有活动执行程序。

get_executors(session_id: str, app_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

get_job_by_id

获取给定作业的状态。

get_job_by_id(session_id: str, app_id: str, job_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

job_id

str

必需

作业 ID

get_jobs

获取给定应用程序的所有作业。

get_jobs(session_id: str, app_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

get_session

发送 GET 请求以获取会话状态。

get_session(session_id: str, detailed: bool = False)

参数

session_id

str

必需

会话 ID

detailed

bool

默认值: False

是否需要详细的响应

get_stage_attempt_by_id

获取给定尝试的状态。

get_stage_attempt_by_id(session_id: str, app_id: str, stage_id: str, attempt_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

stage_id

str

必需

阶段 ID

attempt_id

str

必需

尝试 ID

get_stage_by_id

获取给定阶段的所有尝试。

get_stage_by_id(session_id: str, app_id: str, stage_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

stage_id

str

必需

阶段 ID

get_stages

获取给定应用程序的所有阶段。

get_stages(session_id: str, app_id: str)

参数

session_id

str

必需

会话 ID

app_id

str

必需

应用程序 ID

get_statement

发送 GET 请求以获取语句状态。

get_statement(session_id: str, statement_id: str)

参数

session_id

str

必需

会话 ID

statement_id

str

必需

语句 ID

post_session

发送 POST 请求来创建新会话。

post_session(properties: dict)

参数

properties

dict

必需

新会话的会话属性

post_statement

发送 POST 请求来运行语句。

post_statement(session_id: str, data)

参数

session_id

str

必需

会话 ID

data

必需

要运行的代码，以及种类（又称为语言）

reset_session_timeout

重置会话超时，使会话在另一个超时期间保持活动状态。

reset_session_timeout(session_id: str)

参数

session_id

str

必需

会话 ID