{% tabs tag-hide %}
<dependency>
<groupId>cn.allbs</groupId>
<artifactId>allbs-influx</artifactId>
<version>2.0.2</version>
</dependency>implementation 'cn.allbs:allbs-influx:2.0.2'
implementation("cn.allbs:allbs-influx:2.0.2")
{% endtabs %}
influx:
open_url: http://192.168.1.111:8086
username: ${INFLUX-USER:root}
password: ${INFLUX-PWD:123456}
# 表名
database: allbstest
# influxdb储存策略
retention_policy: autogen
# 储存永久
retention_policy_time: 0s
# 项目启动时如果无法连接influxdb库是否允许项目继续启动，设置为true为可以启动，默认为false如果无法连接则项目无法启动
skip-error: true启动类添加注解@EnableAllbsInflux
import javax.annotation.Resource;
@Resource
private InfluxTemplate influxTemplate;time时间为系统默认时间
// tags
Map<String, String> tagMap = new HashMap<>(2);
tagMap.put("entNo", "q0038");
tagMap.put("outletNo", "q0038g0001");
// fields
Map<String, Object> fieldMap = new HashMap<>(2);
fieldMap.put("IPA", "1");
fieldMap.put("pushTime", "2020-03-05 15:00:00");
influxTemplate.insert("表名", tagMap, fieldMap);influxTemplate.insert("表名", tagMap, fieldMap, Instant.now().toEpochMilli(), TimeUnit.MILLISECONDS);当前插入数据都为当地实际时间，考虑到部分开发使用influxdb时会插入0时区的时间，所以可以自定义时间偏移量，下方代码插入时间将会比实际时间减少8小时
influxTemplate.insert(database, tags, params, ZoneOffset.of("+8"));考虑到批量插入时时间戳不能一致，所以不再提供自定义时间的参数，如果实在需要可以循环单个插入
String database = "cq_test";
// tags
Map<String, String> tags = new HashMap<>();
tags.put("tag1", "1111");
tags.put("tag2", "22222");
// params
List<Map<String, Object>> list = new ArrayList<>();
for (int i = 0; i < 4; i++) {
Map<String, Object> params = new HashMap<>();
params.put("info", "测试数据" + i);
params.put("type", i);
list.add(params);
}
influxTemplate.batchInsert(database, tags, list);
QueryResult result = influxTemplate.query("SELECT * FROM \"zt_gas_waste\" order by time desc limit 100\n");
List<QueryResult.Series> series = result.getResults().get(0).getSeries();String sql = "SELECT * FROM cq_test order by time desc";
List<Map<String, Object>> resList = influxTemplate.queryMapList(sql);
log.info(JsonUtil.toJson(resList));
String sql = "SELECT * FROM cq_test order by time desc";
List<Map<String, Object>> resList = influxTemplate.queryMapList(sql, "yyyy年MM月dd日HH时mm分ss秒");
log.info(JsonUtil.toJson(resList));
String sql = "SELECT * FROM cq_test order by time desc";
List<CqTest> resList = influxTemplate.queryBeanList(sql, CqTest.class);
log.info(resList.toString());
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent