建議： 使用 TSDB SDK 之前，建議您先閱讀名詞解釋和《HTTP API 參考》對 TSDB 的基本概念和 API 的使用說明進行了解。

寫入數據

本段介紹如何使用 SDK 寫入數據。操作前提是您已創建出 TSDB 對象。

Point 類為 TSDB 的時間點類。您可以使用 TSDB 對象的 put 方法將 Point 數據寫入 TSDB 數據庫。

示例代碼

每秒寫入一個 Point（時間點）數據：

package com.aliyun.hitsdb.client.example;
import java.io.IOException;
import com.aliyun.hitsdb.client.TSDB;
import com.aliyun.hitsdb.client.TSDBClientFactory;
import com.aliyun.hitsdb.client.TSDBConfig;
import com.aliyun.hitsdb.client.value.request.Point;
public class TestWrite {
    public static void main(String[] args) throws InterruptedException, IOException {
        // 創建 TSDB 對象
        TSDBConfig config = TSDBConfig.address("example.hitsdb.com", 8242).config();
        TSDB tsdb = TSDBClientFactory.connect(config);
        // 構造數據并寫入 TSDB
        for (int i = 0; i < 3600; i++) {
            Point point = Point.metric("test").tag("V", "1.0").value(System.currentTimeMillis(), 123.4567).build();
            Thread.sleep(1000);  // 1秒提交1次
            tsdb.put(point);
        }
        // 安全關閉客戶端，以防數據丟失。
        System.out.println("關閉");
        tsdb.close();
    }
}

查詢數據

本段介紹如何使用 SDK 讀取數據。操作前提是您已創建出 TSDB 對象。

Query 類為 TSDB 的查詢類，即于查詢條件。查詢數據前需要先構造出查詢條件。您可以使用 TSDB 對象的 query 方法查詢符合查詢條件的數據。

示例代碼

查詢一小時的數據：

package com.aliyun.hitsdb.client.example;
import java.io.IOException;
import java.util.List;
import com.aliyun.hitsdb.client.TSDB;
import com.aliyun.hitsdb.client.TSDBClientFactory;
import com.aliyun.hitsdb.client.TSDBConfig;
import com.aliyun.hitsdb.client.value.request.Query;
import com.aliyun.hitsdb.client.value.request.SubQuery;
import com.aliyun.hitsdb.client.value.response.QueryResult;
import com.aliyun.hitsdb.client.value.type.Aggregator;
public class TestRead {
    public static void main(String[] args) throws IOException {
        // 創建 TSDB 對象
        TSDBConfig config = TSDBConfig.address("example.hitsdb.com", 8242).config();
        TSDB tsdb = TSDBClientFactory.connect(config);
        // 構造查詢條件并查詢數據。
        long now = System.currentTimeMillis();
        // 查詢一小時的數據
        Query query = Query.timeRange(now - 3600 * 1000, now)
                .sub(SubQuery.metric("test").aggregator(Aggregator.NONE).tag("V", "1.0").build()).build();
        // 查詢數據
        List<QueryResult> result = tsdb.query(query);
        // 打印輸出
        System.out.println(result);
        // 安全關閉客戶端，以防數據丟失。
        tsdb.close();
    }
}