全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
高性能时间序列数据库 HiTSDB

SDK快速入门

更新时间:2017-12-11 15:15:56

HiTSDB-Client SDK 快速入门

1. 数据写入

示例代码:

package com.aliyun.hitsdb.client.example;

import java.io.IOException;

import com.aliyun.hitsdb.client.HiTSDB;
import com.aliyun.hitsdb.client.HiTSDBClientFactory;
import com.aliyun.hitsdb.client.HiTSDBConfig;
import com.aliyun.hitsdb.client.value.request.Point;

public class TestWrite {
    public static void main(String[] args) throws InterruptedException, IOException {
        HiTSDBConfig config = HiTSDBConfig.address("example.hitsdb.com", 8242).config();

        HiTSDB tsdb = HiTSDBClientFactory.connect(config);

        // 构造数据并写入 HiTSDB
        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();
    }
}

2. 数据查询

示例代码:

package com.aliyun.hitsdb.client.example;

import java.io.IOException;
import java.util.List;

import com.aliyun.hitsdb.client.HiTSDB;
import com.aliyun.hitsdb.client.HiTSDBClientFactory;
import com.aliyun.hitsdb.client.HiTSDBConfig;
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 {
        HiTSDBConfig config = HiTSDBConfig.address("example.hitsdb.com", 8242).config();
        HiTSDB tsdb = HiTSDBClientFactory.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();
    }
}
本文导读目录