Query unfinished OceanBase cluster tasks

This topic describes how to query all unfinished cluster tasks in an OceanBase cluster by using obshell-sdk-go.

Considerations

• Make sure that OceanBase Shell (obshell) runs normally.

• Make sure that the node corresponding to the client instance that you use belongs to the cluster to be queried.

Sample code

The sample code for synchronous task execution is as follows:

package main

import (
    "github.com/oceanbase/obshell-sdk-go/services"
)

func main() {
    var err error // Handle errors in the production environment.
    
    // Create a client instance, with the IP address of "10.10.10.1" and the port number of 2886.
    // Enter the root@sys password "****" for the cluster.
    client, err := services.NewClientWithPassword("10.10.10.1", 2886, "***")

    // Obtain all unfinished cluster tasks.
    dags, err := client.V1().GetClusterUnfinishedDags()
}

References

• For more information about the API operation, see QueryUnfinishedObTasks.

• For more information about how to call the API operation by using obshell-sdk-python, see Query unfinished OceanBase cluster tasks.