使用Java SDK管理投递任务

本示例以华东1（杭州）的公网Endpoint为例，其公网Endpoint为https://cn-hangzhou.log.aliyuncs.com。如果您通过与Project同地域的其他阿里云产品访问日志服务，请使用内网Endpointhttps://cn-hangzhou-intranet.log.aliyuncs.com。关于日志服务支持的地域与Endpoint的对应关系，请参见服务入口。

查询OSS/MaxCompute投递任务

本示例展示如何创建一个QuerySinkDemo.java文件，用于查询目标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 {
    // 设置日志服务的服务接入点。此处以杭州为例，其他地域请根据实际情况填写。
    private static final String endpoint = "http://cn-hangzhou.log.aliyuncs.com";
    // 本示例从环境变量中获取AccessKey ID和AccessKey Secret。
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    // 输入Project名称，请您根据实际情况填写。请从已创建项目中获取Project名称。
    private static final String project = "ali-test-project";
    // 输入投递任务名称。您可以投递任务的基础信息区域查看任务名称。
    private static final String jobName = "ali-test-job";

    // 创建日志服务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 {
        // 查看指定投递任务。
        String jobConfig = getSinkExportJob();
        System.out.println("**********查看指定投递任务配置**********");
        System.out.println(jobConfig);
        // 查看所有投递任务。
        listSinkExportJob();
        // 查看MaxCompute所有投递任务。
        List<String> odpsSinkList = getOdpsSinkExportJob();
        System.out.println("**********查看MaxCompute所有投递任务配置**********");
        System.out.println(odpsSinkList);
        // 查看OSS所有投递任务。
        List<String> ossSinkList = getOssSinkExportJob();
        System.out.println("**********查看OSS所有投递任务配置**********");
        System.out.println(ossSinkList);
    }
}

预期结果如下：

**********查看指定投递任务配置**********
{
    "configuration": {
    ......
        "fromTime": 1,
        "instanceType": "Standard",
        "logstore": "ali-test-logstore",
    ......
    "state": "Enabled",
    "status": "RUNNING",
    "type": "Export"
}
**********查看MaxCompute所有投递任务配置**********
[{
    "configuration": {
    ......
    "status": "RUNNING",
    "type": "Export"
}, {
    "configuration": {
    ......
    "state": "Enabled",
    "status": "STOPPED",
    "type": "Export"
}]
**********查看OSS所有投递任务配置**********
[{
    "configuration": {
    ......
        "fromTime": 0,
        "instanceType": "Standard",
        "logstore": "ali-test-logstore",
    ......
    "state": "Enabled",
    "status": "RUNNING",
    "type": "Export"
}]