建筑公司企业号_网站推广员是什么_企业培训平台_浙江seo关键词

1）创建一个Springboot项目，在pom.xml引入influxDB相关的包

<!-- influxdb --><dependency><groupId>org.jetbrains.kotlin</groupId><artifactId>kotlin-stdlib</artifactId><version>1.8.10</version> <!-- 可以使用最新的稳定版本 --></dependency><dependency><groupId>org.influxdb</groupId><artifactId>influxdb-java</artifactId><version>2.22</version> <!-- 确保使用支持的版本 --></dependency><dependency><groupId>com.influxdb</groupId><artifactId>influxdb-client-java</artifactId><version>6.6.0</version></dependency>

2)application.yml添加配置信息

influxdb:url: http://127.0.0.1:8017username: rootpassword: wz1123456token: vHqPBS1IPKo6ydzh-c5mqXnJn0h1HgHhbeD5M94BTRC0V49422iPyq3c6Vj9MYmamk3EjcivbtkqvwYPqigY3Q==bucket: wzadministratororg: wz_influxdb

3）新建InfluxDBConfig.java文件

@Configuration
public class InfluxDBConfig {@Value("${influxdb.url}")private String url;@Value("${influxdb.token}")private String token;@Value("${influxdb.org}") // 组织名称private String org;@Value("${influxdb.bucket}") // 存储桶名称private String bucket;@Beanpublic InfluxDBClient influxDBClient() {return InfluxDBClientFactory.create(url, token.toCharArray(), org, bucket);}
}

4）自动化测试InfluxDBDataReader.java，以插入数据为例，DevPointFiveSeDayShard类为实体类，自定义

@Component
public class InfluxDBDataReader {String realTimePre = "REA:";String recentTimePre = "REC:";@Autowiredprivate MongoTemplate mongoTemplate;@Autowiredprivate JedisPool jedisPool;private static final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");private static final DateTimeFormatter formatter2 = DateTimeFormatter.ofPattern("yyyy_MM_dd_HH_mm_ss");// 在你的类中添加 ObjectMapper 的实例@Autowiredprivate ObjectMapper objectMapper;@Autowiredprivate DevPointForMongoDBService devPointForMongoDBService;@Autowiredprivate InfluxDBClient influxDBClient;@Value("${influxdb.bucket}")private String bucket;@Value("${influxdb.org}")private String org;/*** 定时任务启动，每隔5s,统一在AllAutoReader类中启动*/
//    @EventListener(ApplicationReadyEvent.class)
//    @Scheduled(fixedRate = 5000)
//    @PostConstructpublic void runInfluxDB() {insertDevToInfluxDB();}public void insertDevToInfluxDB(){try{List<DevPointFiveSeDayShard> devPointFiveList = RandomlyGeneratEntityCongfig.GenerateEntity(30000);List<Point> points = new ArrayList<>();WriteApiBlocking writeApi = influxDBClient.getWriteApiBlocking();for (DevPointFiveSeDayShard data : devPointFiveList) {// 创建一个 Point 对象Point point = Point.measurement("devPoint2") // measurement 名称.addTag("productId", data.getProductId()) // tag.addField("variableId", data.getVariableId()) // Field.addField("calcValue", data.getCalcValue()) // field.addField("errType", data.getErrType()) // field.time(data.getReportDateTime(), WritePrecision.MS); // 设置时间戳，单位为纳秒points.add(point);}// 插入数据System.out.println("Writing points to bucket: " + bucket);long startTime = System.currentTimeMillis();writeApi.writePoints(points);long endTime = System.currentTimeMillis();System.out.println(LocalDateTime.now().format(formatter) + "存储InfluxDB数据耗时：" + (endTime - startTime) + "ms" + "存储量：" + devPointFiveList.size());System.out.println("points插入完成==");}catch (Exception e){e.printStackTrace();}}
}

其他操作见官网文档：InfluxDB OSS v2 Documentation