获取Spark Session的所有代码块的执行状态。

调试

您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。

请求参数

名称 类型 是否必选 示例值 描述
Action String 是 ListSparkStatements

系统规定参数。取值：ListSparkStatements。
JobId String 是 j202106071620hangzhou00000000001

Spark作业的ID。

返回数据

名称 类型 示例值 描述
RequestId String C2AB7692-B9EF-4A50-BCFF-0DC5B6F080E8

请求的唯一标识ID。
Statements Array of Statements

代码块执行结果的列表。
Code String print(2 + 2)

提交执行的代码块。
CompletedTime Long 1623033200754

执行完成的毫秒级时间戳。
Id Integer 2

代码块的唯一ID。
Output String {\"status\":\"ok\",\"execution_count\":1,\"data\":{\"text/plain\":\"4\"}}

代码块的执行结果，执行结果是一个JSON格式的字符串，其结构如下。

  • status：执行状态。
  • execution_count：当前执行到此代码块的哪一行。
  • data：代码执行结果。
Progress Float 1

当前执行进度，是一个浮点数，代表执行的百分比，‘1’代表100%执行完成。
StartedTime Long 1623033200750

代码块开始执行的毫秒级时间戳。
State String running

代码块的执行状态，可能的状态有：

  • waiting：等待执行。
  • running：正在执行。
  • available：执行完成。
  • error：执行失败。
  • cancelling：尝试终止。
  • cancelled：已经终止执行。

示例

请求示例

http(s)://[Endpoint]/?Action=ListSparkStatements
&JobId=j202106071620hangzhou00000000001
&<公共请求参数>

正常返回示例

XML格式 

<RequestId>C2AB7692-B9EF-4A50-BCFF-0DC5B6F080E8</RequestId>
<Statements>
    <Progress>1</Progress>
    <CompletedTime>1623033200078</CompletedTime>
    <State>available</State>
    <Output>{"status":"ok","execution_count":0,"data":{"text/plain":"&lt;pyspark.sql.session.SparkSession object at 0x7f5e4a550390&gt;"}}</Output>
    <StartedTime>1623033200077</StartedTime>
    <Id>0</Id>
    <Code>spark</Code>
</Statements>
<Statements>
    <Progress>1</Progress>
    <CompletedTime>1623033200754</CompletedTime>
    <State>available</State>
    <Output>{"status":"ok","execution_count":1,"data":{"text/plain":"4"}}</Output>
    <StartedTime>1623033200753</StartedTime>
    <Id>1</Id>
    <Code>print(2 + 2)
</Code>
</Statements>

JSON格式 

{
  "RequestId": "C2AB7692-B9EF-4A50-BCFF-0DC5B6F080E8",
  "Statements": [
    {
      "Progress": 1,
      "CompletedTime": 1623033200078,
      "State": "available",
      "Output": "{\"status\":\"ok\",\"execution_count\":0,\"data\":{\"text/plain\":\"<pyspark.sql.session.SparkSession object at 0x7f5e4a550390>\"}}",
      "StartedTime": 1623033200077,
      "Id": 0,
      "Code": "spark"
    },
    {
      "Progress": 1,
      "CompletedTime": 1623033200754,
      "State": "available",
      "Output": "{\"status\":\"ok\",\"execution_count\":1,\"data\":{\"text/plain\":\"4\"}}",
      "StartedTime": 1623033200753,
      "Id": 1,
      "Code": "print(2 + 2)\n"
    }
  ]
}

错误码

访问错误中心查看更多错误码。