本示例中，創(chuàng)建一個SlsQuickStart.java文件，并調(diào)用接口分別完成創(chuàng)建Project、創(chuàng)建Logstore、創(chuàng)建索引、寫入日志數(shù)據(jù)和查詢?nèi)罩緮?shù)據(jù)。示例如下：

import com.aliyun.openservices.log.common.Index;
import com.aliyun.openservices.log.common.LogContent;
import com.aliyun.openservices.log.common.LogItem;
import com.aliyun.openservices.log.common.LogStore;
import com.aliyun.openservices.log.common.QueriedLog;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.response.GetLogsResponse;
import com.aliyun.openservices.log.Client;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class SlsQuickStart {
    /**
     * 本示例從環(huán)境變量中獲取AccessKey ID和AccessKey Secret。
     */
    static String accessId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    static String accessKey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    /**
     * 日志服務(wù)的服務(wù)接入點。此處以杭州為例，其它地域請根據(jù)實際情況填寫。
     */
    static String host = "cn-hangzhou.log.aliyuncs.com";
    /**
     * 創(chuàng)建日志服務(wù)Client。
     */
    static Client client = new Client(host, accessId, accessKey);
    /**
     * // Project名稱。
     */
    static String projectName = "aliyun-test-gs-project";
    /**
     * Logstore名稱。
     */
    static String logstoreName = "aliyun-test-logstore";
    /**
     * 查詢語句。
     */
    static String query = "*| select * from " + logstoreName;

    /**
     * 創(chuàng)建Project。
     *
     * @throws LogException
     * @throws InterruptedException
     */
    static void createProject() throws LogException, InterruptedException {
        String projectDescription = "project description";
        System.out.println("ready to create project");
        client.CreateProject(projectName, projectDescription);
        System.out.println(String.format("create project %s success", projectName));
        TimeUnit.SECONDS.sleep(60 * 2);
    }

    /**
     * 創(chuàng)建Logstore。
     *
     * @throws LogException
     * @throws InterruptedException
     */
    static void createLogstore() throws LogException, InterruptedException {
        System.out.println("ready to create logstore");
        int ttlInDay = 3;     // 數(shù)據(jù)保存時間。如果配置為3650，表示永久保存。單位為天。
        int shardCount = 2;   // Shard數(shù)量。
        LogStore store = new LogStore(logstoreName, ttlInDay, shardCount);
        client.CreateLogStore(projectName, store);
        System.out.println(String.format("create logstore %s success", logstoreName));
        TimeUnit.SECONDS.sleep(60);
    }

    /**
     * 為Logstore創(chuàng)建索引。
     *
     * @throws LogException
     * @throws InterruptedException
     */
    static void createIndex() throws LogException, InterruptedException {
        System.out.println(String.format("ready to create index for %s", logstoreName));
        String logstoreIndex = "{\"line\": {\"token\": [\",\", \" \", \"'\", \"\\\"\", \";\", \"=\", \"(\", \")\", \"[\", \"]\", \"{\", \"}\", \"?\", \"@\", \"&\", \"<\", \">\", \"/\", \":\", \"\\n\", \"\\t\", \"\\r\"], \"caseSensitive\": false, \"chn\": false}, \"keys\": {\"dev\": {\"type\": \"text\", \"token\": [\",\", \" \", \"'\", \"\\\"\", \";\", \"=\", \"(\", \")\", \"[\", \"]\", \"{\", \"}\", \"?\", \"@\", \"&\", \"<\", \">\", \"/\", \":\", \"\\n\", \"\\t\", \"\\r\"], \"caseSensitive\": false, \"alias\": \"\", \"doc_value\": true, \"chn\": false}, \"id\": {\"type\": \"long\", \"alias\": \"\", \"doc_value\": true}}, \"log_reduce\": false, \"max_text_len\": 2048}";
        Index index = new Index();
        index.FromJsonString(logstoreIndex);
        client.CreateIndex(projectName, logstoreName, index);
        System.out.println(String.format("create index for %s success", logstoreName));
        TimeUnit.SECONDS.sleep(60);
    }

    /**
     * 向Logstore寫入數(shù)據(jù)。為了提高您系統(tǒng)的IO效率，請盡量不要直接使用該方式往日志服務(wù)中寫數(shù)據(jù)，此方式僅為功能舉例。在大數(shù)據(jù)、高并發(fā)場景下建議使用Aliyun Log Java Producer方式寫入日志數(shù)據(jù)。
     *
     * @throws LogException
     * @throws InterruptedException
     */
    static void pushLogs() throws LogException, InterruptedException {
        System.out.println(String.format("ready to push logs for %s", logstoreName));
        List<LogItem> logGroup = new ArrayList<LogItem>();
        for (int i = 0; i < 100; ++i) {
            LogItem logItem = new LogItem();
            logItem.PushBack("id", String.valueOf(i));
            logItem.PushBack("dev", "test_push");
            logGroup.add(logItem);
        }
        client.PutLogs(projectName, logstoreName, "", logGroup, "");
        System.out.println(String.format("push logs for %s success", logstoreName));
        TimeUnit.SECONDS.sleep(5);
    }

    /**
     * 通過SQL查詢?nèi)罩尽?     *
     * @throws LogException
     */
    static void queryLogs() throws LogException {
        System.out.println(String.format("ready to query logs from %s", logstoreName));
        // fromTime和toTime表示查詢?nèi)罩镜臅r間范圍，Unix時間戳格式。
        int fromTime = (int) (System.currentTimeMillis() / 1000 - 3600);
        int toTime = fromTime + 3600;
        GetLogsResponse getLogsResponse = client.GetLogs(projectName, logstoreName, fromTime, toTime, "", query);
        for (QueriedLog log : getLogsResponse.getLogs()) {
            for (LogContent mContent : log.mLogItem.mContents) {
                System.out.println(mContent.mKey + " : " + mContent.mValue);
            }
            System.out.println("********************");
        }
    }

    public static void main(String[] args) throws LogException, InterruptedException {
        /**
         *  創(chuàng)建Project。
         */
        createProject();
        /**
         * 創(chuàng)建Logstore。
         */
        createLogstore();
        /**
         * 創(chuàng)建索引。
         */
        createIndex();
        /**
         * 寫入日志數(shù)據(jù)。
         */
        pushLogs();
        /**
         * 查詢?nèi)罩尽?         */
        queryLogs();
    }
}