Happywzy

TDengine客户端安装

发表于 2021-10-29 分类于 TDengine

下载服务端对应版本的客户端

客户端下载

windows客户端使用

安装TDengine-client-2.2.1.1-Windows-x64.exe
默认安装目录C:\TDengine
修改C:\TDengine\cfg\taos.cfg中firstEp
window机器修改C:\Windows\System32\drivers\etc\hosts,添加集群节点的hostname.
桌面双击运行Taos shell,执行taos.exe进入终端.

TDengine单机体验

发表于 2021-10-29 分类于 TDengine

# docker安装
docker run -d --name tdengine tdengine/tdengine
# 进入容器
docker exec -it tdengine /bin/bash
# 容器内执行命令
taosdemo
# 上述命令运行结束,进入tdengine终端
taos

taosdemo命令将在数据库 test 下面自动创建一张超级表 meters，该超级表下有 1 万张表，表名为 “d0” 到 “d9999”，每张表有 1 万条记录，每条记录有 (ts, current, voltage, phase) 四个字段，时间戳从 “2017-07-14 10:40:00 000” 到 “2017-07-14 10:40:09 999”，每张表带有标签 location 和 groupId，groupId 被设置为 1 到 10， location 被设置为 “beijing” 或者 “shanghai”。

taosdemo命令本身带有很多选项，配置表的数目、记录条数等等，请执行 taosdemo –help详细列出

-- 查看数据库。
show databases;
-- 查看超级表
use test;
show stables;
-- 查看表，限制输出十条
select * from test.t0 limit 10;
-- 查看 d0 表的标签值
select groupid, location from test.d0;
-- 查询超级表下记录总条数
select count(*) from test.meters;
-- 查询1亿条记录的平均值、最大值、最小值等
select avg(current), max(voltage), min(phase) from test.meters;
-- 查询location="beijing"的记录总条数
select count(*) from test.meters where location="beijing";
-- 查询groupId=10的所有记录的平均值、最大值、最小值等
select avg(current), max(voltage), min(phase) from test.meters where groupId=10;
-- 对表d10按10s进行平均值、最大值和最小值聚合统计
select avg(current), max(voltage), min(phase) from test.d10 interval(10s);

springboot集成swagger

发表于 2021-10-27

引入依赖

<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger2</artifactId>
    <version>2.9.2</version>
</dependency>
<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger-ui</artifactId>
    <version>2.9.2</version>
</dependency>

配置

@Configuration
@EnableSwagger2
public class SwaggerConfig {
    @Bean
    public Docket createRestApi(){
        return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo())
                .select()
                .apis(RequestHandlerSelectors.any())
                .paths(PathSelectors.any()).build();
    }

    private ApiInfo apiInfo(){
        return new ApiInfoBuilder()
                .title("Demo API Doc")
                .description("This is a restful api document of Demo.")
                .version("1.0")
                .build();
    }
}

访问UI

http://localhost:17070/swagger-ui.html

常用注解：

@Api()用于类；
表示标识这个类是swagger的资源
@ApiOperation()用于方法；
表示一个http请求的操作
- @ApiParam()用于方法，参数，字段说明；
表示对参数的添加元数据（说明或是否必填等）
- @ApiModel()用于类
表示对类进行说明，用于参数用实体类接收
@ApiModelProperty()用于方法，字段
表示对model属性的说明或者数据操作更改
@ApiIgnore()用于类，方法，方法参数
表示这个方法或者类被忽略
@ApiImplicitParam() 用于方法
表示单独的请求参数
@ApiImplicitParams()用于方法，包含多个 @ApiImplicitParam

示例

@RestController
@RequestMapping("/xxtest")
@Api(tags = "这里修改大类的名字", description = "这里修改大类的描述")
public class SysRoleController {

    @ApiImplicitParams({
        @ApiImplicitParam(name = "Authorization", value = "请求Header的名称", required = true, dataType = "String",paramType = "header"),
    })
    @ApiOperation(value = "修改接口的描述")
    @PostMapping("/test")
    public Response add(@RequestParam(value = "name") @ApiParam(value = "这里写参数名字") String name) {
        return roleService.add(name);
    }

    @ApiImplicitParams({
        @ApiImplicitParam(name = "Authorization", value = "认证Token", required = true, dataType = "String",paramType = "header"),
        @ApiImplicitParam(name = "name", value = "也可以在这里写参数的名称", dataType = "integer",paramType = "query"),
    })
    @ApiOperation(value = "修改接口的描述")
    @PostMapping("/test")
    public Response add(@RequestParam(value = "name") String name) {
        return roleService.add(name);
    }
}

@ApiModel(description = "测试实体")
public class TestEntity {
    @ApiModelProperty(value = "名称")
    private String name;
    @ApiModelProperty(value = "ID")
    private Integer id;
}

influxdb客户端设置超时时间

发表于 2021-10-26

// influxdb客户端超时是由于http超时导致.
// 1. 声明 OkHttpClient 设置超时时间
static OkHttpClient.Builder build = new OkHttpClient.Builder()
            .readTimeout(20, TimeUnit.SECONDS);

// 2. 
InfluxDB influxDB = InfluxDBFactory.connect("http://127.0.0.1:8086", build);

java容器内运行docker命令

发表于 2021-10-26

创建一个能运行docker命令的基础镜像

FROM hub.deri.org.cn/library/openjdk:8-jdk-alpine
MAINTAINER wuzhiyong Docker Maintainers "wuzhiyong@deri.energy"
RUN echo "Asia/shanghai" > /etc/timezone
RUN apk add docker
ENV LANG C.UTF-8

创建java镜像

FROM hub.deri.org.cn/library/openjdk:8-jdk-alpine-docker
MAINTAINER wuzhiyong Docker Maintainers "wuzhiyong@deri.energy"
ADD route-1.0.0-SNAPSHOT.jar /root
EXPOSE 8080
ENV LANG C.UTF-8
CMD cd /root  && java -jar route-1.0.0-SNAPSHOT.jar

启动容器必须携带的

 -v /var/run/docker.sock:/var/run/docker.sock

这样启动起来的java容器内，可以直接执行docker命令,如docker ps获取宿主机所有运行的容器列表.

Happywzy

TDengine客户端安装

下载服务端对应版本的客户端

windows客户端使用

TDengine集群部署

准备工作

所有节点安装服务端(注意不要启动taosd服务)

修改TDengine的配置文件（所有节点的文件`/etc/taos/taos.cfg`都需要修改）

启动集群

TDengine单机体验

springboot集成swagger

引入依赖

配置

访问UI

常用注解：

示例

influxdb客户端设置超时时间

java容器内运行docker命令

下载服务端对应版本的客户端

windows客户端使用

准备工作

所有节点安装服务端(注意不要启动taosd服务)

修改TDengine的配置文件（所有节点的文件/etc/taos/taos.cfg都需要修改）

启动集群

引入依赖

配置

访问UI

常用注解：

示例

修改TDengine的配置文件（所有节点的文件`/etc/taos/taos.cfg`都需要修改）