本节为您介绍如何使用Connection对象的方法管理实例上的进程和当前图集上的任务。

每个示例主要展示如何使用所列方法。点击完整示例查看完整代码示例。

进程

所有嬴图GQL查询（使用write()方法执行的算法除外）都作为进程运行。进程完成后，其结果会立刻返回给客户端，但不会被存储。

top()

获取实例中所有正在运行和正在停止的进程。

参数：

• RequestConfig（可选）：配置请求。

返回值：

• List<Process>：实例中的全部进程列表。

// 获取实例中所有正在运行和正在终止的进程

List<Process> processList = client.top();
for (Process process : processList) {
    System.out.println(process.getProcessId() + " " + process.getProcessUql());
}

a_0_539_2 n({_uuid > 300}).e()[:3].n() as p RETURN p{*} LIMIT 500

kill()

终止实例中正在进行的进程。

参数：

• String：待终止的进程ID；设定为*时终止全部进程。
• RequestConfig（可选）：配置请求。

返回值：

• Response：请求的结果。

// 获取实例中所有正在运行和正在终止的进程并终止所有进程

List<Process> processList = client.top();
for (Process process : processList) {
    System.out.println(process.getProcessId() + " " + process.getProcessUql());
}
Response response = client.kill("*"); 
System.out.println(response.getStatus().getErrorCode());

a_0_540_2 n({_uuid > 300}).e()[:3].n() as p RETURN p{*} LIMIT 500
SUCCESS

任务

使用write()方法执行的算法作为任务运行。这些任务存储在算法运行的图集里，直至任务被删除。

showTask()

获取当前图集的任务。

参数：

• ShowTask（可选）：配置如何获取任务，包括id:String，name:String和status:TaskStatus（若同时设置了id和name，将优先使用id获取任务）；如果忽略，将获取全部任务。
• RequestConfig（可选）：配置请求。

返回值：

• List<Task>：图集中的全部任务列表。

RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraphName("miniCircle");

// 在图集miniCircle上运行一个算法任务

Response response = client.uql("algo(degree).params({order: 'desc'}).write({file:{filename: 'degree_all'}})", requestConfig);
String taskID = (String) response.alias("_task").asTable().getRows().get(0).get(0);
Thread.sleep(3000);

// 获取以上任务

ShowTask showTask = new ShowTask();
showTask.setId(taskID);
//showTask.setName("degree");
showTask.setStatus(TaskStatus.DONE);

List<Task> taskList = client.showTask(showTask, requestConfig);
for (Task task : taskList) {
    System.out.println("Task ID: " + task.getTaskInfo().getTaskId());
    System.out.println("Server ID: " + task.getTaskInfo().getServerId());
    System.out.println("Algo Name: " + task.getTaskInfo().getAlgoName());
    System.out.println("Task Params: " + task.getParam().toString());
    System.out.println("Task Result: " + task.getResult().toString());
}

Task ID: 54240
Server ID: 3
Algo Name: degree
Task Params: {order=desc}
Task Result: {total_degree=590.000000, avarage_degree=1.940789, result_files=degree_all}

clearTask()

从当前图集清除（删除）任务。状态为COMPUTING和WRITING的任务无法被清除。

参数：

• ClearTask（可选）：配置清除任务，包括id:Integer，name:String和status:TaskStatus（若同时设置了id和name，将优先使用id清除任务）；如果忽略，将清除全部任务。
• RequestConfig（可选）：配置请求。

返回值：

• Response：请求的结果。

RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraphName("miniCircle");

// 在图集miniCircle上运行一个算法任务

Response response = client.uql("algo(degree).params({order: 'desc'}).write({file:{filename: 'degree_all'}})", requestConfig);
String id = (String) response.alias("_task").asTable().getRows().get(0).get(0);
Integer taskID = Integer.parseInt(id);
Thread.sleep(3000);

// 清除以上任务

ClearTask clearTask = new ClearTask();
clearTask.setId(taskID);
//clearTask.setName("degree");
clearTask.setStatus(TaskStatus.DONE);

Response response1 = client.clearTask(clearTask, requestConfig);
System.out.println("Task " + taskID + " cleared: " + response1.getStatus().getErrorCode());

Task 54242 cleared: SUCCESS

stopTask()

终止当前图集里状态为COMPUTING的任务。

参数：

• String：待终止的任务ID；设定为*时终止全部任务。
• RequestConfig（可选）：配置请求。

返回值：

• Response：请求的结果。

RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraphName("Ad_Click");

// 在图集Ad_Click上运行一个算法任务

Response response = client.uql("algo(louvain).params({phase1_loop_num: 20, min_modularity_increase: 0.001}).write({file:{filename_community_id: 'communityID'}})", requestConfig);
String taskId = (String) response.get(0).asTable().getRows().get(0).get(0);

// 终止以上任务并打印错误代码

Response response1 = client.stopTask(taskId, requestConfig);
System.out.println("Task " + taskId + " stopped: " + response1.getStatus().getErrorCode());

// 获取以上终止的任务
ShowTask showTask = new ShowTask();
showTask.setId(taskId);
showTask.setStatus(TaskStatus.STOP);

Thread.sleep(3000);

List<Task> taskList = client.showTask(showTask, requestConfig);
for (Task task : taskList) {
    System.out.println("Task ID: " + task.getTaskInfo().getTaskId());
    System.out.println("Server ID: " + task.getTaskInfo().getServerId());
    System.out.println("Algo Name: " + task.getTaskInfo().getAlgoName());
    System.out.println("Task Params: " + task.getParam().toString());
    System.out.println("Task Result: " + task.getResult().toString());
}

Task 54248 stopped: SUCCESS
Task ID: 54248
Server ID: 3
Algo Name: louvain
Task Params: {phase1_loop_num=20, min_modularity_increase=0.001}
Task Result: {community_count=1228589, modularity=0.647601}

完整示例

package com.ultipa.www.sdk.api;

import com.ultipa.sdk.connect.Connection;
import com.ultipa.sdk.connect.conf.RequestConfig;
import com.ultipa.sdk.connect.conf.UltipaConfiguration;
import com.ultipa.sdk.connect.driver.UltipaClientDriver;
import com.ultipa.sdk.connect.request.ShowTask;
import com.ultipa.sdk.operate.entity.*;
import com.ultipa.sdk.operate.enums.TaskStatus;
import com.ultipa.sdk.operate.response.Response;
import java.util.List;

public class Main {
    public static void main(String[] args) {
        // 设置连接
        UltipaConfiguration myConfig = UltipaConfiguration.config()
            // URI示例： .hosts("mqj4zouys.us-east-1.cloud.ultipa.com:60010")
            .hosts("192.168.1.85:60611,192.168.1.87:60611,192.168.1.88:60611")
            .username("<username>")
            .password("<password>");

        UltipaClientDriver driver = null;
        try {
            // 建立与数据库的连接
            driver = new UltipaClientDriver(myConfig);
            Connection client = driver.getConnection();

            Thread.sleep(3000);
          
            RequestConfig requestConfig = new RequestConfig();
            requestConfig.setGraphName("miniCircle");

            // 在图集miniCircle上运行一个算法任务

            Response response = client.uql("algo(degree).params({order: 'desc'}).write({file:{filename: 'degree_all'}})", requestConfig);
            String taskID = (String) response.alias("_task").asTable().getRows().get(0).get(0);
            Thread.sleep(3000);

            // 获取以上任务

            ShowTask showTask = new ShowTask();
            showTask.setId(taskID);
            //showTask.setName("degree");
            showTask.setStatus(TaskStatus.DONE);

            List<Task> taskList = client.showTask(showTask, requestConfig);
            for (Task task : taskList) {
                System.out.println("Task ID: " + task.getTaskInfo().getTaskId());
                System.out.println("Server ID: " + task.getTaskInfo().getServerId());
                System.out.println("Algo Name: " + task.getTaskInfo().getAlgoName());
                System.out.println("Task Params: " + task.getParam().toString());
                System.out.println("Task Result: " + task.getResult().toString());
            }
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }
    }
}