SynapseSession 类

参考

SynapseSession 类包装 LivySession 并添加一些特定于 Synapse 的会话处理。

继承: sparkmagic.livyclientlib.livysession.LivySession

SynapseSession

构造函数

SynapseSession(subscription_id: str, resource_group: str, workspace: str, sparkpool: str, properties: dict, timeout: int, ipython_display: hdijupyterutils.ipythondisplay.IpythonDisplay, amlwslocation: str)

参数

subscription_id

resource_group

workspace

sparkpool

properties

timeout

ipython_display

amlwslocation

方法

can_submit	检查我们能否在此会话中提交作业。
delete	删除会话。
execute	执行一些 Spark 代码。
get_spark_ui_url	获取 Spark UI 的 URL。
get_synapse_app_url	获取 Synapse Spark 应用程序的 URL。
mark_timeout	将会话标记为超时会话，以允许其超时。
refresh_status_and_info	刷新会话的最新状态。
show_meta	在笔记本中显示会话元数据。
start	启动会话。
wait_for_idle	等待会话进入空闲状态。同时休眠。这将重写父方法。超时可以是“无”，这将取决于 Synapse 来管理会话生命周期。

can_submit

检查我们能否在此会话中提交作业。

can_submit()

delete

删除会话。

delete()

execute

执行一些 Spark 代码。

execute(code: str, kind)

参数

code: str

必需

要执行的 Spark 代码

kind: str

必需

代码的 Spark 语言，支持的语言包括：spark (Scala)、pyspark、csharp 和 sql

get_spark_ui_url

获取 Spark UI 的 URL。

get_spark_ui_url()

get_synapse_app_url

获取 Synapse Spark 应用程序的 URL。

get_synapse_app_url()

mark_timeout

将会话标记为超时会话，以允许其超时。

mark_timeout()

refresh_status_and_info

刷新会话的最新状态。

refresh_status_and_info()

show_meta

在笔记本中显示会话元数据。

show_meta()

start

启动会话。

start(timeout=None)

参数

timeout

默认值: None

wait_for_idle

等待会话进入空闲状态。同时休眠。这将重写父方法。超时可以是“无”，这将取决于 Synapse 来管理会话生命周期。

wait_for_idle(seconds_to_wait=None)

参数

seconds_to_wait