Simple Log Service:Use Simple Log Service SDK for Java to manage data shipping jobs

Query OSS or MaxCompute data shipping jobs

The following code provides an example on how to create a file named QuerySinkDemo.java. The file is used to query the configurations of a data shipping job in a specified 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 Simple Log Service endpoint. In this example, the Simple Log Service endpoint for the China (Hangzhou) region is used. Replace the parameter value with the actual endpoint. 
    private static final String endpoint = "http://cn-hangzhou.log.aliyuncs.com";
    // In this example, the AccessKey ID and AccessKey secret are obtained 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. Enter a name based on your business requirements. You must specify the name of an existing project. 
    private static final String project = "ali-test-project";
    // The name of the data shipping job. You can view the name of the data shipping job in the Basic Information section. 
    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 {
        // Query the data shipping job that is specified. 
        String jobConfig = getSinkExportJob();
        System.out.println("**********Query the configurations of the specified data shipping job**********");
        System.out.println(jobConfig);
        // Query all data shipping jobs. 
        listSinkExportJob();
        // Query all MaxCompute data shipping jobs. 
        List<String> odpsSinkList = getOdpsSinkExportJob();
        System.out.println("**********Query the configurations of all MaxCompute data shipping jobs**********");
        System.out.println(odpsSinkList);
        // Query all Object Storage Service (OSS) data shipping jobs. 
        List<String> ossSinkList = getOssSinkExportJob();
        System.out.println("**********Query the configurations of all OSS data shipping jobs**********");
        System.out.println(ossSinkList);
    }
}

Expected results:

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