feat: enhance InfluxDB health check logging with detailed error information
This commit is contained in:
@@ -62,10 +62,18 @@ async function query(bucket, relativeTime, measurement, sensor, field) {
|
|||||||
|
|
||||||
async function checkInflux() {
|
async function checkInflux() {
|
||||||
try {
|
try {
|
||||||
await querying.rows(`from(bucket: "boat") |> range(start: -1s) |> limit(n:1)`).next();
|
const result = await querying.collectRows(
|
||||||
return true;
|
`from(bucket: "boat") |> range(start: -1s) |> limit(n:1)`
|
||||||
|
);
|
||||||
|
console.log('InfluxDB: OK');
|
||||||
|
return { ok: true };
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
return false;
|
console.error('InfluxDB check failed:', {
|
||||||
|
message: error.message,
|
||||||
|
statusCode: error.statusCode ?? 'N/A',
|
||||||
|
body: error.body ?? 'N/A'
|
||||||
|
});
|
||||||
|
return false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user