Use the Java SDK to manage data shipping jobs

In this example, the public Simple Log Service endpoint for the China (Hangzhou) region is used. Endpoint: https://cn-hangzhou.log.aliyuncs.com.

If you want to access Simple Log Service from other Alibaba Cloud services that reside in the same region as your project, you can use the internal Simple Log Service endpoint, which is https://cn-hangzhou-intranet.log.aliyuncs.com.

For more information about the supported regions and endpoints of Simple Log Service, see Endpoint.

Query OSS or MaxCompute data shipping jobs

The following sample code in QuerySinkDemo.java queries the configurations of a data shipping job in a specific project.

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.*;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.*;
import com.aliyun.openservices.log.response.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
public class QuerySinkDemo {
    // The endpoint of Simple Log Service. This example uses the endpoint of the China (Hangzhou) region. Replace the value with the actual endpoint.
    private static final String endpoint = "http://cn-hangzhou.log.aliyuncs.com";
    // This example obtains the AccessKey ID and AccessKey Secret from environment variables.
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    // The name of the project. Replace this with your actual project name.
    private static final String project = "ali-test-project";
    // The name of the data shipping job. You can view the job name in the job's basic information.
    private static final String jobName = "ali-test-job";
    // Create a Simple Log Service client.
    private static final Client client = new Client(endpoint, accessKeyId, accessKeySecret);
    private static String getSinkExportJob() throws LogException {
        GetJobResponse getJobResponse = client.getJob(new GetJobRequest(project, jobName));
        Job job = getJobResponse.getJob();
        return JSONObject.toJSONString(job);
    }
    private static List<Export> listSinkExportJob() throws LogException {
        ListExportResponse listExportResponse = client.listExport(new ListExportRequest(project));
        return listExportResponse.getResults();
    }
    private static List<String> getOdpsSinkExportJob() throws LogException {
        List<String> odpsSinkList = new ArrayList<>();
        List<Export> listExports = listSinkExportJob();
        for (Export job:listExports) {
            DataSink type = job.getConfiguration().getSink();
            Map<String, Object> map = JSONObject.parseObject(JSONArray.toJSONString(type));
            Object sinkType = map.get("type");
            if (sinkType.equals("AliyunODPS")) {
                odpsSinkList.add(JSONArray.toJSONString(job));
            }
        }
        return odpsSinkList;
    }
    private static List<String> getOssSinkExportJob() throws LogException {
        List<String> ossSinkList = new ArrayList<>();
        List<Export> listExports = listSinkExportJob();
        for (Export job:listExports) {
            DataSink type = job.getConfiguration().getSink();
            Map<String, Object> map = JSONObject.parseObject(JSONArray.toJSONString(type));
            Object sinkType = map.get("type");
            if (sinkType.equals("AliyunOSS")) {
                ossSinkList.add(JSONArray.toJSONString(job));
            }
        }
        return ossSinkList;
    }
    public static void main(String[] args) throws LogException {
        // View the specified data shipping job.
        String jobConfig = getSinkExportJob();
        System.out.println("**********View the configuration of the specified data shipping job**********");
        System.out.println(jobConfig);
        // View all data shipping jobs.
        listSinkExportJob();
        // View all MaxCompute data shipping jobs.
        List<String> odpsSinkList = getOdpsSinkExportJob();
        System.out.println("**********View the configurations of all MaxCompute data shipping jobs**********");
        System.out.println(odpsSinkList);
        // View all OSS data shipping jobs.
        List<String> ossSinkList = getOssSinkExportJob();
        System.out.println("**********View the configurations of all OSS data shipping jobs**********");
        System.out.println(ossSinkList);
    }
}

The following result is expected:

**********View the configuration of the specified data shipping job**********
{
    "configuration": {
    ......
        "fromTime": 1,
        "instanceType": "Standard",
        "logstore": "ali-test-logstore",
    ......
    "state": "Enabled",
    "status": "RUNNING",
    "type": "Export"
}
**********View the configurations of all MaxCompute data shipping jobs**********
[{
    "configuration": {
    ......
    "status": "RUNNING",
    "type": "Export"
}, {
    "configuration": {
    ......
    "state": "Enabled",
    "status": "STOPPED",
    "type": "Export"
}]
**********View the configurations of all OSS data shipping jobs**********
[{
    "configuration": {
    ......
        "fromTime": 0,
        "instanceType": "Standard",
        "logstore": "ali-test-logstore",
    ......
    "state": "Enabled",
    "status": "RUNNING",
    "type": "Export"
}]