大佬教程收集整理的这篇文章主要介绍了解决spring boot项目中influxDB的连接问题,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
我正在尝试使用我的 Spring Boot 项目连接到 influxdb,该项目可以轻松连接到 POSTGRes 数据库。这是我的应用程序属性:
### Application server ###
server.port=8088
### DATABASE POSTGRES LOCAL ###
#spring.jpa.hibernate.ddl-auto=update
spring.data@R_772_9016@e.url=jdbc:POSTGResql://localhost:5432/xxxxres
spring.data@R_772_9016@e.username=xxxx
spring.data@R_772_9016@e.password=xxxx
### INFLUX ###
spring.influx.url=https://xxxxxx.it:66xx3
spring.influx.user=admin
spring.influx.password=xxx
spring.influx.database=xxx
我创建了一些与 POSTGRes 一起使用的 REST 调用,但我不能在涌入时做同样的事情。我的疑问是与 influx db 的联系。
这是我的 Influx 实体:
@measurement(name = "M_M_TEST")
public class MMEntity {
@column(name = "Time")
private Integer time;
@column(name = "Dul5_L1_AUX_OTH_OTH_OTH.Active_Energy")
private Integer Dul5_L1_AUX_OTH_OTH_OTH_Active_Energy;
@column(name = "Dul5_L1_AUX_OTH_OTH_OTH.Active_Power")
private Integer Dul5_L1_AUX_OTH_OTH_OTH_Active_Power;
}
这是我的模型:
@measurement(name = "M_M_TEST")
public class MMModel {
private Integer time;
private Integer Dul5_L1_AUX_OTH_OTH_OTH_Active_Energy;
private Integer Dul5_L1_AUX_OTH_OTH_OTH_Active_Power;
//GETTER & SETTER
}
这是我的控制器:
@API(tags = { SwaggerTags.TAG_M_M_name })
@requestMapPing("/v1/basePath")
@RestController
@EnableGlobalMethodSecurity(prePostEnabled = true,securedEnabled = truE)
public class MMController extends AbstractController{
private static final Logger logger = LoggerFactory.getLogger(MMController.class);
@autowired
MMservice mMservice;
@APIOperation(value = "Finds all values of MM")
@GetMapPing("/M-M/all")
public List<MMModel> findAll() {
final String METHOD_name = "findAll()";
try {
startLog(METHOD_Name);
final List<MonterotondoMarittimoEntity> result = monterotondoMarittimoservice.findAll();
final List<MonterotondoMarittimoModel> response = ModelMapUtils.createObject(result,MonterotondoMarittimoModel.class);
endLog(METHOD_name,responsE);
return response;
} catch (final Exception E) {
errorLog(METHOD_name,E);
throw e;
}
}
}
这是我的服务:
@service
public class MonterotondoMarittimoservice extends Abstractservice {
@autowired
InfluxDB influxDB;
@Value("${spring.influx.url}")
private String influxDBUrl;
@Value("${spring.influx.user}")
private String username;
@Value("${spring.influx.passworD}")
private String password;
@Value("${spring.influx.databasE}")
private String database;
@transactional
public List<MMEntity> findAll() {
final String METHOD_name = "findAll()";
startLog(METHOD_Name);
List<MMEntity> result = new ArrayList<MMEntity>();
final query query = new query("SELECT * FROM M_M liMIT 10",databasE);
queryResult queryResult = influxDB.query(query);
InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
result = resultMapper.topOJO(queryResult,MMEntity.class);
endLog(METHOD_name,result);
return result;
}
}
我想使用 findAll 方法获取表 M_M 中存在的所有元素。
但是当我使用 Swagger 执行该方法时,此日志出现 500 错误 ("org.influxdb.InfluxDBIOException: javax.net.ssl.SSLHandshakeException: PKIX path building Failed: sun.security.provIDer.certpath.SunCertPathBuilderException: unable to find valID certification path to requested target")
是否需要一个类来配置与 Influx 的连接?
我能做些什么来解决我的问题?
请帮帮我。
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)
以上是大佬教程为你收集整理的解决spring boot项目中influxDB的连接问题全部内容,希望文章能够帮你解决解决spring boot项目中influxDB的连接问题所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。