# kapacitor-java

**Repository Path**: azier/kapacitor-java

## Basic Information

- **Project Name**: kapacitor-java
- **Description**: No description available
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2019-08-29
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# kapacitor-java

#### 介绍  

  本项目是influxdata组织开发的kapacitor组件的脚本工具，本质上我这个只是个用于生成kapacitor脚本的字符串拼接工具。  

#### 包说明  

###### generator包  

  这个包是用于从[kapacitor](https://docs.influxdata.com/kapacitor/v1.5/nodes)官网爬取并生成初始node和method对象的代码（你没看错，下面的method包和node包都是这么来的），注意这段代码
可能导致你的ip访问被kapacitor官网封了（403）。  

###### kapacitor包    

1. model 对task的定义；  
2. script 包含Node和Method定义（不完整，缺少InfluxQLNode部分和因为403问题没获取到的部分）；  
3. Kapacitor.java 用于连接Kapacitor；  
#### 用法  

Kapacitor.java
```Kapacitor.java
    Kapacitor kapacitor = new Kapacitor("http://xxx.xxx.xxx.xxx", 9092, "/kapacitor/v1/");
    List<Task> allTask = kapacitorUtil.getAllTasks();
```
script
```script
    Script streamNode = stream().quite()
            .from()
            .database("xxx").retentionPolicy("autogen")
            .groupByAll()
            .where("\"tagname\"=='123456'")
            .stats(1L, DurationLiteral.DAY)
            .align().quite().quite();
    System.out.println(streamNode.getScript());
```