更多操作 您还可以对已创建的定时作业进行以下操作。 表2 相关操作 操作名称 操作步骤 停用定时作业 在定时作业列表中，单击定时作业所在行“启用”列的，当变为时，表示已停用该作业。 启用定时作业 在定时作业列表中，单击定时作业所在行“启用”列的，当变为时，表示已启用该作业。 查看执行历史 在定时作业列表中，单击定时作业所在行“操作”列的“执行历史”，进入“作业清单”页面查看执行历史。 编辑定时作业 在定时作业列表中，单击定时作业所在行“操作”列的“编辑”。 编辑定时作业信息，单击“保存”。 启用中的作业不支持编辑，要停用作业后才能编辑。 删除定时作业 在定时作业列表中，单击定时作业所在行“操作”列的“删除”。 单击“确定”。 启用中的作业不支持删除，要停用作业后才能删除。

URI GET /v3/classrooms/{classroom_id}/jobs 表1 路径参数 参数 是否必选 参数类型 描述 classroom_id 是 String 课堂ID 最小长度：32 最大长度：32 表2 Query参数 参数 是否必选 参数类型 描述 member_id 是 String 用户ID 最小长度：32 最大长度：32 offset 否 Integer 信息记录的起始编号 最小值：1 最大值：1000 limit 否 Integer 每页包含的信息记录数 最小值：1 最大值：100

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 jobs Array of MemberJobCard objects 课堂下作业列表信息 total Integer 学生作业总数 表5 MemberJobCard 参数 参数类型 描述 name String 作业名称 average_score String 作业均分(作业有均分该字段才返回) score Integer 作业得分(作业有分数该字段才返回) send_time String 作业下发时间, 日期格式：yyyy-MM-dd HH:mm:ss last_submit_time String 作业最后一次提交时间, 日期格式：yyyy-MM-dd HH:mm:ss 状态码： 400 表6 响应Body参数 参数 参数类型 描述 error_code String 异常错误码 error_msg String 异常错误描述 状态码： 403 表7 响应Body参数 参数 参数类型 描述 error_code String 异常错误码 error_msg String 异常错误描述 状态码： 500 表8 响应Body参数 参数 参数类型 描述 error_code String 异常错误码 error_msg String 异常错误描述

响应示例 状态码： 200 OK { "jobs" : [ { "name" : "作业", "average_score" : "99", "score" : 100, "send_time" : "2019-12-12 12:00:00", "last_submit_time" : "2019-12-12 12:00:00" } ], "total" : 1} 状态码： 400 Bad Request { "error_code" : "CM.0003", "error_msg" : "请求参数有误"} 状态码： 403 Forbidden { "error_code" : "CM.0001", "error_msg" : "请求被拒绝访问"} 状态码： 500 Internal Server Error { "error_code" : "CM.0000", "error_msg" : "服务内部错误"}

响应示例 状态码： 200 OK { "status" : "SUC CES S", "entities" : { "server_group_id" : "a59d008e-4bad-4bf3-9b17-6cc25e7da483" }, "job_id" : "0000000062db92d70162db9d200f000a", "job_type" : "createProtectionGroupNoCG", "begin_time" : "2018-04-19T01:55:30.443Z", "end_time" : "2018-04-19T01:55:45.493Z", "error_code" : null, "fail_reason" : null}

状态码 状态码 描述 200 OK 400 Bad Request 401 Unauthorized 403 Forbidden 405 Method Not Allowed 406 Not Acceptable 407 Proxy Authentication Required 408 Request Timeout 409 Conflict 500 Internal Server Error 501 Not Implemented 502 Bad Gateway 503 Service Unavailable 504 Gateway Timeout

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 status String Job的状态。 SUCCESS：成功。 RUNNING：运行中。 FAIL：失败。 INIT：正在初始化。 枚举值： SUCCESS RUNNING FAIL INIT entities JobEntities object Job操作的对象。 job_id String Job ID。 job_type String Job的类型。createProtectionGroupNoCG：创建保护组。deleteProtectionGroupNoCG：删除保护组。startProtectionGroupNoCG ：保护组开始保护。reprotectProtectionGroupNoCG ：保护组重保护。stopProtectionGroupNoCG ：保护组停止保护。failoverProtectionGroupNoCG ：保护组故障切换。reverseProtectionGroupNoCG：保护组切换。createProtectedInstanceNoCG：创建保护实例。deleteProtectedInstanceNoCG：删除保护实例。attachReplicationPairNew：保护实例挂载复制对。detachReplicationPairNew：保护实例卸载复制对。addNicNew：保护实例添加网卡。deleteNicNew：保护实例删除网卡。resizeProtectedInstanceNew：保护实例变更规格。createReplicationPairNoCG：创建复制对。deleteReplicationPairNoCG：删除复制对。expandReplicationPairNew：复制对扩容。createDisasterRecoveryDrill：创建容灾演练。deleteDisasterRecoveryDrill：删除容灾演练。 begin_time String 开始时间。默认格式为："yyyy-MM-dd'T'HH:mm:ss.SSSZ"，例："2019-04-01T12:00:00.000Z"。 end_time String 结束时间。默认格式为："yyyy-MM-dd'T'HH:mm:ss.SSSZ"，例："2019-04-01T12:00:00.000Z"。 error_code String Job执行失败时的错误码。 fail_reason String Job执行失败时的错误原因。 表4 JobEntities 参数 参数类型 描述 replication_pair_id String 复制对ID volume_ids String 组成复制对的云硬盘ID server_group_id String 保护组ID protected_instance_id String 保护实例ID native_server_id String 容灾站点服务器ID nic_id String 网卡ID sub_jobs Array of SubJobParams objects 子Job信息 表5 SubJobParams 参数 参数类型 描述 status String Job的状态。 SUCCESS：成功。 RUNNING：运行中。 FAIL：失败。 INIT：正在初始化。 枚举值： SUCCESS RUNNING FAIL INIT entities SubJobEntities object Job操作的对象。 job_id String Job ID。 job_type String Job的类型。createProtectionGroupNoCG：创建保护组。deleteProtectionGroupNoCG：删除保护组。startProtectionGroupNoCG ：保护组开始保护。reprotectProtectionGroupNoCG ：保护组重保护。stopProtectionGroupNoCG ：保护组停止保护。failoverProtectionGroupNoCG ：保护组故障切换。reverseProtectionGroupNoCG：保护组切换。createProtectedInstanceNoCG：创建保护实例。deleteProtectedInstanceNoCG：删除保护实例。attachReplicationPairNew：保护实例挂载复制对。detachReplicationPairNew：保护实例卸载复制对。addNicNew：保护实例添加网卡。deleteNicNew：保护实例删除网卡。resizeProtectedInstanceNew：保护实例变更规格。createReplicationPairNoCG：创建复制对。deleteReplicationPairNoCG：删除复制对。expandReplicationPairNew：复制对扩容。createDisasterRecoveryDrill：创建容灾演练。deleteDisasterRecoveryDrill：删除容灾演练。 begin_time String 开始时间。默认格式为："yyyy-MM-dd'T'HH:mm:ss.SSSZ"，例："2019-04-01T12:00:00.000Z"。 end_time String 结束时间。默认格式为："yyyy-MM-dd'T'HH:mm:ss.SSSZ"，例："2019-04-01T12:00:00.000Z"。 error_code String Job执行失败时的错误码。 fail_reason String Job执行失败时的错误原因。 表6 SubJobEntities 参数 参数类型 描述 replication_pair_id String 复制对ID volume_ids String 组成复制对的云硬盘ID server_group_id String 保护组ID protected_instance_id String 保护实例ID native_server_id String 容灾站点服务器ID nic_id String 网卡ID 状态码： 400 表7 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表8 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 401 表9 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表10 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 403 表11 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表12 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 405 表13 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表14 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 406 表15 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表16 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 407 表17 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表18 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 408 表19 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表20 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 409 表21 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表22 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 500 表23 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表24 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 501 表25 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表26 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 502 表27 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表28 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 503 表29 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表30 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码 状态码： 504 表31 响应Body参数 参数 参数类型 描述 error ErrorInfo object 失败返回结构 表32 ErrorInfo 参数 参数类型 描述 message String 错误信息 code String 错误码

URI GET /ges/v1.0/{project_id}/graphs/{graph_name}/jobs/{job_id}/status?offset=offset&limit=limit 表1 路径参数 参数 是否必选 类型 说明 project_id 是 String 项目ID。获取方法请参见获取项目ID。 job_id 是 String Job ID。 offset 否 Integer 本次查询偏移量，默认为0。 limit 否 Integer 本次查询返回最大数量(最大100000)，默认为100000。

响应参数 表2 响应Body参数说明 参数 类型 说明 errorMessage String 系统提示信息。 执行成功时，字段可能为空。 执行失败时，用于显示错误信息。 errorCode String 系统提示信息。 执行成功时，字段可能为空。 执行失败时，用于显示错误码。 status String 查询成功时返回任务状态，包括以下四种状态： pending：等待中。 running：运行中。 success：成功。 failed：失败。 查询失败时字段为空。 data Object 算法运行的结果。查询失败时字段为空。 表3 data参数说明 参数 类型 说明 vertices List 点上关联的算法结果。 edges List 边上关联的算法结果。 outputs Object 其他输出结果。 data_return_size Integer 本次查询返回结果数量。 data_offset Integer 本次查询返回结果偏移量。 data_total_size Integer 异步任务产生的结果数据总量。

响应示例 状态码： 200 成功响应示例 Http Status Code: 200 { "data": { "outputs": { "data_return_size": 2, "vertices": [ { "id": "Sarah", "label": "user", "properties": { "Occupation": [ "other or not specified" ], "Name": [ "莎拉" ], "Zip-code": [ "55105" ], "Gender": [ "F" ], "Age": [ "18-24" ] } }, { "id": "Sidney", "label": "user", "properties": { "Occupation": [ "writer" ], "Name": [ "西德尼" ], "Zip-code": [ "85296" ], "Gender": [ "M" ], "Age": [ "18-24" ] } } ], "data_offset": 0, "data_total_size": 19 } }, "status": "success" }

数据规划 发布者Job使用自定义算子每秒钟产生10000条数据。 数据包含两个属性：分别是Int和String类型。 配置文件。 nettyconnector.registerserver.topic.storage：设置NettySink的IP、端口及并发度信息在第三方注册服务器上的路径（必填），例如： nettyconnector.registerserver.topic.storage: /flink/nettyconnector nettyconnector.sinkserver.port.range：设置NettySink的端口范围（必填），例如： nettyconnector.sinkserver.port.range: 28444-28943 nettyconnector.ssl.enabled：设置NettySink与NettySource之间通信是否SSL加密（默认为false），例如： nettyconnector.ssl.enabled: true nettyconnector.sinkserver.subnet：设置网络所属域，例如： nettyconnector.sinkserver.subnet: 10.162.0.0/16 安全认证配置： Zookeeper的SASL认证，依赖“flink-conf.yaml”中有关HA的相关配置，具体配置请参见配置管理Flink。 SSL的keystore、truststore、keystore password、truststore password以及password等也使用“flink-conf.yaml”的相关配置，具体配置请参见加密传输。 接口说明。 注册服务器接口 注册服务器用来保存NettySink的IP、端口以及并发度信息，以便NettySource连接使用。为用户提供以下接口： public interface RegisterServerHandler { /** * 启动注册服务器 * @param configuration Flink的Configuration类型 */ void start(Configuration configuration) throws Exception; /** *注册服务器上创建Topic节点（目录） * @param topic topic节点名称 */ void createTopicNode(String topic) throw Exception; /** *将信息注册到某个topic节点（目录）下 * @param topic 需要注册到的目录 * @param registerRecord 需要注册的信息 */ void register(String topic, RegisterRecord registerRecord) throws Exception; /** *删除topic节点 * @param topic 待删除topic */ void deleteTopicNode(String topic) throws Exception; /** *注销注册信息 *@param topic 注册信息所在的topic *@param recordId 待注销注册信息ID */ void unregister(String topic, int recordId) throws Exception; /** * 查寻信息 * @param 查询信息所在的topic *@recordId 查询信息的ID */ RegisterRecord query(String topic, int recordId) throws Exception; /** * 查询某个Topic是否存在 * @param topic */ Boolean isExist(String topic) throws Exception; /** *关闭注册服务器句柄 */ void shutdown() throws Exception; 工程基于以上接口提供了ZookeeperRegisterHandler供用户使用。 NettySink算子 Class NettySink(String name, String topic, RegisterServerHandler registerServerHandler, int numberOfSubscribedJobs) name：为本NettySink的名称。 topic：为本NettySink产生数据的Topic，每个不同的NettySink（并发度除外）必须使用不同的TOPIC，否则会引起订阅混乱，数据无法正常分发。 registerServerHandler：为注册服务器的句柄。 numberOfSubscribedJobs：为订阅本NettySink的作业数量，该数量必须是明确的，只有当所有订阅者都连接上NettySink，NettySink才发送数据。 NettySource算子 Class NettySource(String name, String topic, RegisterServerHandler registerServerHandler) name：为本NettySource的名称，该NettySource必须是唯一的（并发度除外），否则，连接NettySink时会出现冲突，导致无法连接。 topic：订阅的NettySink的topic。 registerServerHandler：为注册服务器的句柄。 NettySource的并发度必须与NettySink的并发度相同，否则无法正常创建连接。

数据规划 发布者Job使用自定义算子每秒钟产生10000条数据 数据包含两个属性：分别是Int和String类型 配置文件 nettyconnector.registerserver.topic.storage：设置NettySink的IP、端口及并发度信息在第三方注册服务器上的路径（必填），例如： nettyconnector.registerserver.topic.storage: /flink/nettyconnector nettyconnector.sinkserver.port.range：设置NettySink的端口范围（必填），例如： nettyconnector.sinkserver.port.range: 28444-28943 nettyconnector.sinkserver.subnet：设置网络所属域，例如： nettyconnector.sinkserver.subnet: 10.162.0.0/16 接口说明 注册服务器接口 注册服务器用来保存NettySink的IP、端口以及并发度信息，以便NettySource连接使用。为用户提供以下接口： public interface RegisterServerHandler { /** * 启动注册服务器 * @param configuration Flink的Configuration类型 */ void start(Configuration configuration) throws Exception; /** *注册服务器上创建Topic节点（目录） * @param topic topic节点名称 */ void createTopicNode(String topic) throw Exception; /** *将信息注册到某个topic节点（目录）下 * @param topic 需要注册到的目录 * @param registerRecord 需要注册的信息 */ void register(String topic, RegisterRecord registerRecord) throws Exception; /** *删除topic节点 * @param topic 待删除topic */ void deleteTopicNode(String topic) throws Exception; /** *注销注册信息 *@param topic 注册信息所在的topic *@param recordId 待注销注册信息ID */ void unregister(String topic, int recordId) throws Exception; /** * 查询信息 * @param 查询信息所在的topic *@recordId 查询信息的ID */ RegisterRecord query(String topic, int recordId) throws Exception; /** * 查询某个Topic是否存在 * @param topic */ Boolean isExist(String topic) throws Exception; /** *关闭注册服务器句柄 */ void shutdown() throws Exception; 工程基于以上接口提供了ZookeeperRegisterHandler供用户使用。 NettySink算子 Class NettySink(String name, String topic, RegisterServerHandler registerServerHandler, int numberOfSubscribedJobs) name：为本NettySink的名称。 topic：为本NettySink产生数据的Topic，每个不同的NettySink（并发度除外）必须使用不同的TOPIC，否则会引起订阅混乱，数据无法正常分发。 registerServerHandler：为注册服务器的句柄。 numberOfSubscribedJobs：为订阅本NettySink的作业数量，该数量必须是明确的，只有当所有订阅者都连接上NettySink，NettySink才发送数据。 NettySource算子 Class NettySource(String name, String topic, RegisterServerHandler registerServerHandler) name：为本NettySource的名称，该NettySource必须是唯一的（并发度除外），否则，连接NettySink时会出现冲突，导致无法连接。 topic：订阅的NettySink的topic。 registerServerHandler：为注册服务器的句柄。 NettySource的并发度必须与NettySource的并发度相同，否则无法正常创建连接。

响应示例 状态码： 200 成功响应示例 Http Status Code: 200 { "result": "success" } 状态码： 400 失败响应示例 HttpStatusCode: 400 { "errorMessage": "Graph [ {project_id} -movie1] does not exist, please check project_id and graph_name.", "errorCode": "GES.8000", "result": "failed" }

请求示例 请求示例1：取消已经提交的某个作业。 DELETE http://{SERVER_URL}/ges/v1.0/{project_id}/hyg/{graph_name}/jobs/{job_id} 请求示例2：取消全部排队中的作业。 DELETE http://{SERVER_URL}/ges/v1.0/{project_id}/hyg/{graph_name}/jobs SERVER_URL：图的访问地址，取值请参考业务面API使用限制。

URI GET /ges/v1.0/{project_id}/graphs/{graph_name}/jobs/status?limit={limit}&offset={offset} 表1 路径参数 参数 是否必选 类型 说明 project_id 是 String 项目ID。获取方法请参见获取项目ID。 offset 否 Integer 本次查询偏移量，默认为0。 job_id 是 String Response对应的任务Job ID。 limit 否 Integer 本次查询返回最大数量(最大100000)，默认为100000。