influx插入,需要给time字段添加@TimeColumn注解

This commit is contained in:
2023-09-27 14:27:51 +08:00
parent 4c4d2236a9
commit 3b34fd8cbb
4 changed files with 37 additions and 10 deletions

View File

@@ -101,7 +101,7 @@
<sentinel.datasource.nacos.version>1.8.1</sentinel.datasource.nacos.version> <sentinel.datasource.nacos.version>1.8.1</sentinel.datasource.nacos.version>
<jackson>2.12.4</jackson> <jackson>2.12.4</jackson>
<easyexcel>3.0.5</easyexcel> <easyexcel>3.0.5</easyexcel>
<influxdb-java.version>2.18</influxdb-java.version> <influxdb-java.version>2.22</influxdb-java.version>
<echarts.version>3.0.0.6</echarts.version> <echarts.version>3.0.0.6</echarts.version>
<gson.version>2.8.9</gson.version> <gson.version>2.8.9</gson.version>
<xxl-job.version>2.3.0</xxl-job.version> <xxl-job.version>2.3.0</xxl-job.version>
@@ -388,7 +388,7 @@
<dependency> <dependency>
<groupId>org.influxdb</groupId> <groupId>org.influxdb</groupId>
<artifactId>influxdb-java</artifactId> <artifactId>influxdb-java</artifactId>
<version>2.22</version> <version>${influxdb-java.version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>

View File

@@ -1,5 +1,7 @@
package com.njcn; package com.njcn;
import com.njcn.influx.imapper.DataFlickerMapper;
import com.njcn.influx.pojo.po.DataFlicker;
import com.njcn.oss.constant.OssPath; import com.njcn.oss.constant.OssPath;
import com.njcn.oss.utils.FileStorageUtil; import com.njcn.oss.utils.FileStorageUtil;
import lombok.SneakyThrows; import lombok.SneakyThrows;
@@ -8,6 +10,9 @@ import org.springframework.beans.factory.annotation.Autowired;
import java.io.File; import java.io.File;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.time.Instant;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID; import java.util.UUID;
/** /**
@@ -15,18 +20,41 @@ import java.util.UUID;
* @version 1.0.0 * @version 1.0.0
* @date 2021年12月14日 12:55 * @date 2021年12月14日 12:55
*/ */
public class OssTest extends BaseJunitTest{ public class OssTest extends BaseJunitTest {
@Autowired @Autowired
private FileStorageUtil fileStorageUtil; private FileStorageUtil fileStorageUtil;
@Autowired
private DataFlickerMapper dataFlickerMapper;
@SneakyThrows @SneakyThrows
@Test @Test
public void test(){ public void test() {
File file = new File("C:\\Users\\DELL\\Desktop\\6FEC92B75A104D1295715A661A2CC196.docx"); File file = new File("C:\\Users\\DELL\\Desktop\\6FEC92B75A104D1295715A661A2CC196.docx");
String s = fileStorageUtil.uploadStream(new FileInputStream(file), OssPath.ALGORITHM, UUID.randomUUID() + ".docx"); String s = fileStorageUtil.uploadStream(new FileInputStream(file), OssPath.ALGORITHM, UUID.randomUUID() + ".docx");
System.out.println("hello"); System.out.println("hello");
} }
@SneakyThrows
@Test
public void testInflux() {
List<DataFlicker> dataFlickers = new ArrayList<>();
for (int i = 0; i < 10; i++) {
DataFlicker dataFlicker = new DataFlicker();
dataFlicker.setTime(Instant.now());
dataFlicker.setFluc(12.5);
dataFlicker.setLineId("123456");
dataFlicker.setPhaseType("C");
dataFlicker.setPlt(12.5);
dataFlicker.setPst(12.5);
dataFlicker.setQualityFlag("0");
Thread.sleep(1000);
dataFlickers.add(dataFlicker);
}
dataFlickerMapper.insertBatch(dataFlickers);
}
} }

View File

@@ -5,6 +5,7 @@ import com.njcn.common.utils.serializer.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;
import java.time.Instant; import java.time.Instant;
@@ -18,6 +19,7 @@ import java.time.Instant;
@Measurement(name = "data_flicker") @Measurement(name = "data_flicker")
public class DataFlicker { public class DataFlicker {
@TimeColumn
@Column(name = "time") @Column(name = "time")
@JsonSerialize(using = InstantDateSerializer.class) @JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;

View File

@@ -291,6 +291,7 @@
<module filepath="$PROJECT_DIR$/pqs-common/common-echarts/common-echarts.iml"/> <module filepath="$PROJECT_DIR$/pqs-common/common-echarts/common-echarts.iml"/>
<module filepath="$PROJECT_DIR$/pqs-common/common-huawei/common-huawei.iml"/> <module filepath="$PROJECT_DIR$/pqs-common/common-huawei/common-huawei.iml"/>
<module filepath="$PROJECT_DIR$/pqs-common/common-oss/common-oss.iml"/> <module filepath="$PROJECT_DIR$/pqs-common/common-oss/common-oss.iml"/>
<module filepath="$PROJECT_DIR$/pqs-common/common-mq/common-mq.iml"/>
<module filepath="$PROJECT_DIR$/pqs-common/pqs-common.iml"/> <module filepath="$PROJECT_DIR$/pqs-common/pqs-common.iml"/>
<module filepath="$PROJECT_DIR$/pqs-gateway/pqs-gateway.iml"/> <module filepath="$PROJECT_DIR$/pqs-gateway/pqs-gateway.iml"/>
<module filepath="$PROJECT_DIR$/pqs-user/user-api/user-api.iml"/> <module filepath="$PROJECT_DIR$/pqs-user/user-api/user-api.iml"/>
@@ -322,20 +323,16 @@
<module filepath="$PROJECT_DIR$/pqs-job/job-executor/job-executor.iml"/> <module filepath="$PROJECT_DIR$/pqs-job/job-executor/job-executor.iml"/>
<module filepath="$PROJECT_DIR$/pqs-job/pqs-job.iml"/> <module filepath="$PROJECT_DIR$/pqs-job/pqs-job.iml"/>
<module filepath="$PROJECT_DIR$/pqs-job/job-api/job-api.iml"/> <module filepath="$PROJECT_DIR$/pqs-job/job-api/job-api.iml"/>
<module filepath="$PROJECT_DIR$/pqs-quality/quality-api/quality-api.iml"/>
<module filepath="$PROJECT_DIR$/pqs-quality/quality-boot/quality-boot.iml"/>
<module filepath="$PROJECT_DIR$/pqs-quality/pqs-quality.iml"/>
<module filepath="$PROJECT_DIR$/pqs-advance/advance-api/advance-api.iml"/> <module filepath="$PROJECT_DIR$/pqs-advance/advance-api/advance-api.iml"/>
<module filepath="$PROJECT_DIR$/pqs-advance/advance-boot/advance-boot.iml"/> <module filepath="$PROJECT_DIR$/pqs-advance/advance-boot/advance-boot.iml"/>
<module filepath="$PROJECT_DIR$/pqs-advance/pqs-advance.iml"/> <module filepath="$PROJECT_DIR$/pqs-advance/pqs-advance.iml"/>
<module filepath="$PROJECT_DIR$/pqs-prepare/event-prepare/event-prepare.iml"/> <module filepath="$PROJECT_DIR$/pqs-prepare/prepare-boot/prepare-boot.iml"/>
<module filepath="$PROJECT_DIR$/pqs-prepare/harmonic-prepare/harmonic-prepare.iml"/>
<module filepath="$PROJECT_DIR$/pqs-prepare/prepare-api/prepare-api.iml"/> <module filepath="$PROJECT_DIR$/pqs-prepare/prepare-api/prepare-api.iml"/>
<module filepath="$PROJECT_DIR$/pqs-prepare/pqs-prepare.iml"/> <module filepath="$PROJECT_DIR$/pqs-prepare/pqs-prepare.iml"/>
<module filepath="$PROJECT_DIR$/pqs-process/process-api/process-api.iml"/> <module filepath="$PROJECT_DIR$/pqs-process/process-api/process-api.iml"/>
<module filepath="$PROJECT_DIR$/pqs-process/process-boot/process-boot.iml"/> <module filepath="$PROJECT_DIR$/pqs-process/process-boot/process-boot.iml"/>
<module filepath="$PROJECT_DIR$/pqs-process/pqs-process.iml"/> <module filepath="$PROJECT_DIR$/pqs-process/pqs-process.iml"/>
<module filepath="$PROJECT_DIR$/pqs-algorithm/pqs-algorithm.iml"/> <module filepath="$PROJECT_DIR$/pqs-influx/pqs-influx.iml"/>
</modules> </modules>
</component> </component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" default="false" project-jdk-name="1.8" project-jdk-type="JavaSDK" assert-keyword="true" jdk-15="true"/> <component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" default="false" project-jdk-name="1.8" project-jdk-type="JavaSDK" assert-keyword="true" jdk-15="true"/>