Compare commits
3 Commits
c5e1bb4c64
...
2356040572
Author | SHA1 | Date | |
---|---|---|---|
2356040572 | |||
b0bbf0c71a | |||
37b78e7373 |
@ -40,12 +40,7 @@ function checkWriteApi(influxDb, options){
|
||||
const writeApi = influxDb.getWriteApi(options.org, options.bucket); // Get WriteAPI
|
||||
writeApi.writePoint(new Point("test").tag("ConnectionTest", true).intField("value", 0).timestamp(0)) // Write dummy-point
|
||||
writeApi.close()
|
||||
.catch((err) => {
|
||||
logger.error("Could not get writeApi:");
|
||||
logger.error(`Error [${err.code}]:`, err.message);
|
||||
if(err.code == "not found") logger.fatal("No write-permission?");
|
||||
reject();
|
||||
}).then((res) => {
|
||||
.then((res) => {
|
||||
logger.debug("Writing ok");
|
||||
|
||||
// Delete the connection-text-point
|
||||
@ -64,6 +59,11 @@ function checkWriteApi(influxDb, options){
|
||||
reject();
|
||||
})
|
||||
.then(resolve())
|
||||
},
|
||||
(err) => {
|
||||
logger.error("Could not get writeApi:");
|
||||
logger.error(`Error [${err.code}]:`, err.message);
|
||||
reject();
|
||||
});
|
||||
});
|
||||
}
|
||||
|
@ -33,7 +33,7 @@ if(errorMsg){
|
||||
})})
|
||||
.then((res) => {return InfluxChecks.checkWriteApi(influxDb, {
|
||||
org: env.INFLUX_ORG,
|
||||
name: env.INFLUX_BUCKET
|
||||
bucket: env.INFLUX_BUCKET
|
||||
})})
|
||||
.catch((err) => {
|
||||
if(err) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user