mirror of
https://github.com/ptarmiganlabs/butler-sos.git
synced 2025-12-19 09:47:53 -05:00
Complete InfluxDB v3 support for all posting functions
Co-authored-by: mountaindude <1029262+mountaindude@users.noreply.github.com>
This commit is contained in:
copilot-swe-agent[bot]
committed by
Göran Sander
Göran Sander
parent
3a0592967c
commit
897f8c6490
@@ -747,6 +747,55 @@ export async function postProxySessionsToInfluxdb(userSessions) {
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
`PROXY SESSIONS: Sent user session data to InfluxDB for server "${userSessions.host}", virtual proxy "${userSessions.virtualProxy}"`
|
||||
);
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
// Only write to InfluxDB if the global influxWriteApi object has been initialized
|
||||
if (!globals.influxWriteApi) {
|
||||
globals.logger.warn(
|
||||
'PROXY SESSIONS: Influxdb write API object not initialized. Data will not be sent to InfluxDB'
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
// Find writeApi for the specified server
|
||||
const writeApi = globals.influxWriteApi.find(
|
||||
(element) => element.serverName === userSessions.serverName
|
||||
);
|
||||
|
||||
// Ensure that the writeApi object was found
|
||||
if (!writeApi) {
|
||||
globals.logger.warn(
|
||||
`PROXY SESSIONS: Influxdb v3 write API object not found for host ${userSessions.host}. Data will not be sent to InfluxDB`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
// Create data points
|
||||
const points = [
|
||||
new Point('user_session_summary')
|
||||
.intField('session_count', userSessions.sessionCount)
|
||||
.stringField('session_user_id_list', userSessions.uniqueUserList),
|
||||
];
|
||||
|
||||
// Write to InfluxDB
|
||||
try {
|
||||
const res = await writeApi.writeAPI.writePoints(points);
|
||||
globals.logger.debug(`PROXY SESSIONS: Wrote data to InfluxDB v3`);
|
||||
} catch (err) {
|
||||
globals.logger.error(
|
||||
`PROXY SESSIONS: Error saving user session data to InfluxDB v3! ${globals.getErrorMessage(err)}`
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.debug(
|
||||
`PROXY SESSIONS: Session count for server "${userSessions.host}", virtual proxy "${userSessions.virtualProxy}"": ${userSessions.sessionCount}`
|
||||
);
|
||||
globals.logger.debug(
|
||||
`PROXY SESSIONS: User list for server "${userSessions.host}", virtual proxy "${userSessions.virtualProxy}"": ${userSessions.uniqueUserList}`
|
||||
);
|
||||
|
||||
globals.logger.verbose(
|
||||
`PROXY SESSIONS: Sent user session data to InfluxDB for server "${userSessions.host}", virtual proxy "${userSessions.virtualProxy}"`
|
||||
);
|
||||
@@ -883,6 +932,46 @@ export async function postButlerSOSMemoryUsageToInfluxdb(memory) {
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'MEMORY USAGE INFLUXDB: Sent Butler SOS memory usage data to InfluxDB'
|
||||
);
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
// Create new write API object
|
||||
// advanced write options
|
||||
const writeOptions = {
|
||||
/* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
|
||||
flushInterval: 5000,
|
||||
|
||||
/* the count of internally-scheduled retries upon write failure, the delays between write attempts follow an exponential backoff strategy if there is no Retry-After HTTP header */
|
||||
maxRetries: 2, // do not retry writes
|
||||
|
||||
// ... there are more write options that can be customized, see
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeoptions.html and
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeretryoptions.html
|
||||
};
|
||||
|
||||
const org = globals.config.get('Butler-SOS.influxdbConfig.v3Config.org');
|
||||
const database = globals.config.get('Butler-SOS.influxdbConfig.v3Config.database');
|
||||
|
||||
const writeApi = globals.influx.getWriteApi(org, database, 'ns', writeOptions);
|
||||
|
||||
const point = new Point('butlersos_memory_usage')
|
||||
.tag('butler_sos_instance', memory.instanceTag)
|
||||
.tag('version', butlerVersion)
|
||||
.floatField('heap_used', memory.heapUsedMByte)
|
||||
.floatField('heap_total', memory.heapTotalMByte)
|
||||
.floatField('external', memory.externalMemoryMByte)
|
||||
.floatField('process_memory', memory.processMemoryMByte);
|
||||
|
||||
try {
|
||||
const res = await writeApi.writePoint(point);
|
||||
globals.logger.debug(`MEMORY USAGE INFLUXDB: Wrote data to InfluxDB v3`);
|
||||
} catch (err) {
|
||||
globals.logger.error(
|
||||
`MEMORY USAGE INFLUXDB: Error saving user session data to InfluxDB v3! ${globals.getErrorMessage(err)}`
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'MEMORY USAGE INFLUXDB: Sent Butler SOS memory usage data to InfluxDB'
|
||||
);
|
||||
@@ -1093,6 +1182,56 @@ export async function postUserEventToInfluxdb(msg) {
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'USER EVENT INFLUXDB: Sent Butler SOS user event data to InfluxDB'
|
||||
);
|
||||
} catch (err) {
|
||||
globals.logger.error(
|
||||
`USER EVENT INFLUXDB: Error getting write API: ${globals.getErrorMessage(err)}`
|
||||
);
|
||||
}
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
// Create new write API object
|
||||
// Advanced write options
|
||||
const writeOptions = {
|
||||
/* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
|
||||
flushInterval: 5000,
|
||||
|
||||
/* the count of internally-scheduled retries upon write failure, the delays between write attempts follow an exponential backoff strategy if there is no Retry-After HTTP header */
|
||||
maxRetries: 2, // do not retry writes
|
||||
|
||||
// ... there are more write options that can be customized, see
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeoptions.html and
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeretryoptions.html
|
||||
};
|
||||
|
||||
const org = globals.config.get('Butler-SOS.influxdbConfig.v3Config.org');
|
||||
const database = globals.config.get('Butler-SOS.influxdbConfig.v3Config.database');
|
||||
|
||||
const writeApi = globals.influx.getWriteApi(org, database, 'ns', writeOptions);
|
||||
|
||||
const point = new Point('log_event')
|
||||
.tag('host', msg.host)
|
||||
.tag('level', msg.level)
|
||||
.tag('source', msg.source)
|
||||
.tag('log_row', msg.log_row)
|
||||
.tag('subsystem', msg.subsystem ? msg.subsystem : 'n/a')
|
||||
.stringField('message', msg.message)
|
||||
.stringField('exception_message', msg.exception_message ? msg.exception_message : '')
|
||||
.stringField('app_name', msg.appName ? msg.appName : '')
|
||||
.stringField('app_id', msg.appId ? msg.appId : '')
|
||||
.stringField('execution_id', msg.executionId ? msg.executionId : '')
|
||||
.stringField('command', msg.command ? msg.command : '')
|
||||
.stringField('result_code', msg.resultCode ? msg.resultCode : '')
|
||||
.stringField('origin', msg.origin ? msg.origin : '')
|
||||
.stringField('context', msg.context ? msg.context : '')
|
||||
.stringField('session_id', msg.sessionId ? msg.sessionId : '')
|
||||
.stringField('raw_event', msg.rawEvent ? msg.rawEvent : '');
|
||||
|
||||
try {
|
||||
const res = await writeApi.writePoint(point);
|
||||
globals.logger.debug(`USER EVENT INFLUXDB: Wrote data to InfluxDB v3`);
|
||||
|
||||
globals.logger.verbose(
|
||||
'USER EVENT INFLUXDB: Sent Butler SOS user event data to InfluxDB'
|
||||
);
|
||||
@@ -1556,6 +1695,153 @@ export async function postLogEventToInfluxdb(msg) {
|
||||
);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'LOG EVENT INFLUXDB: Sent Butler SOS log event data to InfluxDB'
|
||||
);
|
||||
} catch (err) {
|
||||
globals.logger.error(
|
||||
`LOG EVENT INFLUXDB: Error getting write API: ${globals.getErrorMessage(err)}`
|
||||
);
|
||||
}
|
||||
}
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
if (
|
||||
msg.source === 'qseow-engine' ||
|
||||
msg.source === 'qseow-proxy' ||
|
||||
msg.source === 'qseow-scheduler' ||
|
||||
msg.source === 'qseow-repository' ||
|
||||
msg.source === 'qseow-qix-perf'
|
||||
) {
|
||||
// Create new write API object
|
||||
// Advanced write options
|
||||
const writeOptions = {
|
||||
/* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
|
||||
flushInterval: 5000,
|
||||
|
||||
/* the count of internally-scheduled retries upon write failure, the delays between write attempts follow an exponential backoff strategy if there is no Retry-After HTTP header */
|
||||
maxRetries: 2, // do not retry writes
|
||||
|
||||
// ... there are more write options that can be customized, see
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeoptions.html and
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeretryoptions.html
|
||||
};
|
||||
|
||||
const org = globals.config.get('Butler-SOS.influxdbConfig.v3Config.org');
|
||||
const database = globals.config.get('Butler-SOS.influxdbConfig.v3Config.database');
|
||||
|
||||
const writeApi = globals.influx.getWriteApi(org, database, 'ns', writeOptions);
|
||||
|
||||
const logLevel = 'log_level';
|
||||
|
||||
const logLevelValue = msg.level;
|
||||
|
||||
// Determine what tags to use for the log event point
|
||||
// Tags are are part of the data model that will be used in this call.
|
||||
// Tags are what make for efficient queries in InfluxDB
|
||||
let point;
|
||||
|
||||
// Does the message have QIX perf data in the message field?
|
||||
// I.e. is this a log event with performance data from QIX engine?
|
||||
if (
|
||||
msg.source === 'qseow-qix-perf' &&
|
||||
msg.message.split(' ').length >= 22 &&
|
||||
msg.message.split(' ')[7] !== '(null)'
|
||||
) {
|
||||
const parts = msg.message.split(' ');
|
||||
const objectType = parts[5];
|
||||
const method = parts[6];
|
||||
const appId = parts[7];
|
||||
|
||||
if (isNaN(parts[9]) || isNaN(parts[11]) || isNaN(parts[13])) {
|
||||
// One or more of the performance metric is not a number, this is not a valid QIX perf log event
|
||||
globals.logger.debug(
|
||||
`LOG EVENT INFLUXDB v3: Performance metrics not valid: ${parts[9]}, ${parts[11]}, ${parts[13]}`
|
||||
);
|
||||
|
||||
point = new Point('log_event')
|
||||
.tag('host', msg.host)
|
||||
.tag('level', msg.level)
|
||||
.tag('source', msg.source)
|
||||
.tag('log_row', msg.log_row)
|
||||
.tag('subsystem', msg.subsystem ? msg.subsystem : 'n/a')
|
||||
.stringField('message', msg.message)
|
||||
.stringField(
|
||||
'exception_message',
|
||||
msg.exception_message ? msg.exception_message : ''
|
||||
)
|
||||
.stringField('app_name', msg.appName ? msg.appName : '')
|
||||
.stringField('app_id', msg.appId ? msg.appId : '')
|
||||
.stringField('execution_id', msg.executionId ? msg.executionId : '')
|
||||
.stringField('command', msg.command ? msg.command : '')
|
||||
.stringField('result_code', msg.resultCode ? msg.resultCode : '')
|
||||
.stringField('origin', msg.origin ? msg.origin : '')
|
||||
.stringField('context', msg.context ? msg.context : '')
|
||||
.stringField('session_id', msg.sessionId ? msg.sessionId : '')
|
||||
.stringField('raw_event', msg.rawEvent ? msg.rawEvent : '');
|
||||
} else {
|
||||
// We have a valid QIX performance log event
|
||||
|
||||
point = new Point('log_event')
|
||||
.tag('host', msg.host)
|
||||
.tag('level', msg.level)
|
||||
.tag('source', msg.source)
|
||||
.tag('log_row', msg.log_row)
|
||||
.tag('subsystem', msg.subsystem ? msg.subsystem : 'n/a')
|
||||
.tag('object_type', objectType)
|
||||
.tag('method', method)
|
||||
.stringField('message', msg.message)
|
||||
.stringField(
|
||||
'exception_message',
|
||||
msg.exception_message ? msg.exception_message : ''
|
||||
)
|
||||
.stringField('app_name', msg.appName ? msg.appName : '')
|
||||
.stringField('app_id', appId)
|
||||
.stringField('execution_id', msg.executionId ? msg.executionId : '')
|
||||
.stringField('command', msg.command ? msg.command : '')
|
||||
.stringField('result_code', msg.resultCode ? msg.resultCode : '')
|
||||
.stringField('origin', msg.origin ? msg.origin : '')
|
||||
.stringField('context', msg.context ? msg.context : '')
|
||||
.stringField('session_id', msg.sessionId ? msg.sessionId : '')
|
||||
.stringField('raw_event', msg.rawEvent ? msg.rawEvent : '')
|
||||
|
||||
// engine performance fields
|
||||
.floatField('process_time', parseFloat(parts[9]))
|
||||
.floatField('work_time', parseFloat(parts[11]))
|
||||
.floatField('lock_time', parseFloat(parts[13]))
|
||||
.floatField('validate_time', parseFloat(parts[15]))
|
||||
.floatField('traverse_time', parseFloat(parts[17]))
|
||||
.intField('handle', parseInt(parts[19], 10))
|
||||
.intField('net_ram', parseInt(parts[20], 10))
|
||||
.intField('peak_ram', parseInt(parts[21], 10));
|
||||
}
|
||||
} else {
|
||||
// No QIX perf data, use standard log event format
|
||||
point = new Point('log_event')
|
||||
.tag('host', msg.host)
|
||||
.tag('level', msg.level)
|
||||
.tag('source', msg.source)
|
||||
.tag('log_row', msg.log_row)
|
||||
.tag('subsystem', msg.subsystem ? msg.subsystem : 'n/a')
|
||||
.stringField('message', msg.message)
|
||||
.stringField(
|
||||
'exception_message',
|
||||
msg.exception_message ? msg.exception_message : ''
|
||||
)
|
||||
.stringField('app_name', msg.appName ? msg.appName : '')
|
||||
.stringField('app_id', msg.appId ? msg.appId : '')
|
||||
.stringField('execution_id', msg.executionId ? msg.executionId : '')
|
||||
.stringField('command', msg.command ? msg.command : '')
|
||||
.stringField('result_code', msg.resultCode ? msg.resultCode : '')
|
||||
.stringField('origin', msg.origin ? msg.origin : '')
|
||||
.stringField('context', msg.context ? msg.context : '')
|
||||
.stringField('session_id', msg.sessionId ? msg.sessionId : '')
|
||||
.stringField('raw_event', msg.rawEvent ? msg.rawEvent : '');
|
||||
}
|
||||
|
||||
try {
|
||||
const res = await writeApi.writePoint(point);
|
||||
globals.logger.debug(`LOG EVENT INFLUXDB: Wrote data to InfluxDB v3`);
|
||||
|
||||
globals.logger.verbose(
|
||||
'LOG EVENT INFLUXDB: Sent Butler SOS log event data to InfluxDB'
|
||||
);
|
||||
@@ -1801,6 +2087,99 @@ export async function storeEventCountInfluxDB() {
|
||||
return;
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'EVENT COUNT INFLUXDB: Sent Butler SOS event count data to InfluxDB'
|
||||
);
|
||||
} catch (err) {
|
||||
globals.logger.error(`EVENT COUNT INFLUXDB: Error getting write API: ${err}`);
|
||||
}
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
// Create new write API object
|
||||
// advanced write options
|
||||
const writeOptions = {
|
||||
/* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
|
||||
flushInterval: 5000,
|
||||
|
||||
/* the count of internally-scheduled retries upon write failure, the delays between write attempts follow an exponential backoff strategy if there is no Retry-After HTTP header */
|
||||
maxRetries: 2, // do not retry writes
|
||||
|
||||
// ... there are more write options that can be customized, see
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeoptions.html and
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeretryoptions.html
|
||||
};
|
||||
|
||||
const org = globals.config.get('Butler-SOS.influxdbConfig.v3Config.org');
|
||||
const database = globals.config.get('Butler-SOS.influxdbConfig.v3Config.database');
|
||||
|
||||
const writeApi = globals.influx.getWriteApi(org, database, 'ns', writeOptions);
|
||||
|
||||
try {
|
||||
// Store data for each log event
|
||||
|
||||
for (const logEvent of logEvents) {
|
||||
const tags = {
|
||||
butler_sos_instance: globals.options.instanceTag,
|
||||
};
|
||||
|
||||
// Add static tags defined in config file, if any
|
||||
// Add the static tag to the data structure sent to InfluxDB
|
||||
// Is the array present in the config file?
|
||||
if (
|
||||
globals.config.has(
|
||||
'Butler-SOS.qlikSenseEvents.eventCount.influxdb.staticTag'
|
||||
) &&
|
||||
Array.isArray(
|
||||
globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.eventCount.influxdb.staticTag'
|
||||
)
|
||||
)
|
||||
) {
|
||||
// Yes, the config tag array exists
|
||||
const configTags = globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.eventCount.influxdb.staticTag'
|
||||
);
|
||||
|
||||
configTags.forEach((tag) => {
|
||||
tags[tag.name] = tag.value;
|
||||
});
|
||||
}
|
||||
|
||||
// Add timestamp from when the event was received by Butler SOS
|
||||
const point = new Point(
|
||||
globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.eventCount.influxdb.measurementName'
|
||||
)
|
||||
)
|
||||
.tag('host', logEvent.host)
|
||||
.tag('level', logEvent.level)
|
||||
.tag('source', logEvent.source)
|
||||
.tag('log_row', logEvent.log_row)
|
||||
.tag('subsystem', logEvent.subsystem ? logEvent.subsystem : 'n/a')
|
||||
.stringField('message', logEvent.message)
|
||||
.stringField(
|
||||
'exception_message',
|
||||
logEvent.exception_message ? logEvent.exception_message : ''
|
||||
)
|
||||
.stringField('app_name', logEvent.appName ? logEvent.appName : '')
|
||||
.stringField('app_id', logEvent.appId ? logEvent.appId : '')
|
||||
.stringField('execution_id', logEvent.executionId ? logEvent.executionId : '')
|
||||
.stringField('command', logEvent.command ? logEvent.command : '')
|
||||
.stringField('result_code', logEvent.resultCode ? logEvent.resultCode : '')
|
||||
.stringField('origin', logEvent.origin ? logEvent.origin : '')
|
||||
.stringField('context', logEvent.context ? logEvent.context : '')
|
||||
.stringField('session_id', logEvent.sessionId ? logEvent.sessionId : '')
|
||||
.stringField('raw_event', logEvent.rawEvent ? logEvent.rawEvent : '')
|
||||
.timestamp(new Date(logEvent.timestamp));
|
||||
|
||||
// Add tags to point
|
||||
Object.keys(tags).forEach((key) => {
|
||||
point.tag(key, tags[key]);
|
||||
});
|
||||
|
||||
const res = await writeApi.writePoint(point);
|
||||
globals.logger.debug(`EVENT COUNT INFLUXDB: Wrote data to InfluxDB v3`);
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'EVENT COUNT INFLUXDB: Sent Butler SOS event count data to InfluxDB'
|
||||
);
|
||||
@@ -2043,6 +2422,121 @@ export async function storeRejectedEventCountInfluxDB() {
|
||||
return;
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'REJECT LOG EVENT INFLUXDB: Sent Butler SOS rejected event count data to InfluxDB'
|
||||
);
|
||||
} catch (err) {
|
||||
globals.logger.error(`REJECTED LOG EVENT INFLUXDB: Error getting write API: ${err}`);
|
||||
}
|
||||
} else if (globals.config.get('Butler-SOS.influxdbConfig.version') === 3) {
|
||||
// Create new write API object
|
||||
// advanced write options
|
||||
const writeOptions = {
|
||||
/* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
|
||||
flushInterval: 5000,
|
||||
|
||||
/* the count of internally-scheduled retries upon write failure, the delays between write attempts follow an exponential backoff strategy if there is no Retry-After HTTP header */
|
||||
maxRetries: 2, // do not retry writes
|
||||
|
||||
// ... there are more write options that can be customized, see
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeoptions.html and
|
||||
// https://influxdata.github.io/influxdb-client-js/influxdb-client.writeretryoptions.html
|
||||
};
|
||||
|
||||
const org = globals.config.get('Butler-SOS.influxdbConfig.v3Config.org');
|
||||
const database = globals.config.get('Butler-SOS.influxdbConfig.v3Config.database');
|
||||
|
||||
const writeApi = globals.influx.getWriteApi(org, database, 'ns', writeOptions);
|
||||
|
||||
try {
|
||||
const points = [];
|
||||
const measurementName = globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.rejectedEventCount.influxdb.measurementName'
|
||||
);
|
||||
|
||||
rejectedLogEvents.forEach((event) => {
|
||||
globals.logger.debug(`REJECTED LOG EVENT INFLUXDB 3: ${JSON.stringify(event)}`);
|
||||
|
||||
if (
|
||||
event.source === 'qseow-qix-perf' &&
|
||||
event.message.split(' ').length >= 22 &&
|
||||
event.message.split(' ')[7] !== '(null)'
|
||||
) {
|
||||
const parts = event.message.split(' ');
|
||||
const objectType = parts[5];
|
||||
const method = parts[6];
|
||||
|
||||
let point = new Point(measurementName)
|
||||
.tag('source', event.source)
|
||||
.tag('object_type', objectType)
|
||||
.tag('method', method)
|
||||
.tag('level', event.level)
|
||||
.tag('log_row', event.log_row)
|
||||
.stringField('message', event.message)
|
||||
.intField('count', 1);
|
||||
|
||||
// Add static tags defined in config file, if any
|
||||
if (
|
||||
globals.config.has(
|
||||
'Butler-SOS.logEvents.enginePerformanceMonitor.trackRejectedEvents.tags'
|
||||
) &&
|
||||
Array.isArray(
|
||||
globals.config.get(
|
||||
'Butler-SOS.logEvents.enginePerformanceMonitor.trackRejectedEvents.tags'
|
||||
)
|
||||
)
|
||||
) {
|
||||
const configTags = globals.config.get(
|
||||
'Butler-SOS.logEvents.enginePerformanceMonitor.trackRejectedEvents.tags'
|
||||
);
|
||||
for (const item of configTags) {
|
||||
point.tag(item.name, item.value);
|
||||
}
|
||||
}
|
||||
|
||||
points.push(point);
|
||||
} else {
|
||||
let point = new Point(measurementName)
|
||||
.tag('source', event.source)
|
||||
.tag('level', event.level)
|
||||
.tag('log_row', event.log_row)
|
||||
.stringField('message', event.message)
|
||||
.intField('count', 1);
|
||||
|
||||
// Add static tags defined in config file, if any
|
||||
if (
|
||||
globals.config.has(
|
||||
'Butler-SOS.qlikSenseEvents.rejectedEventCount.influxdb.staticTag'
|
||||
) &&
|
||||
Array.isArray(
|
||||
globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.rejectedEventCount.influxdb.staticTag'
|
||||
)
|
||||
)
|
||||
) {
|
||||
const configTags = globals.config.get(
|
||||
'Butler-SOS.qlikSenseEvents.rejectedEventCount.influxdb.staticTag'
|
||||
);
|
||||
for (const item of configTags) {
|
||||
point.tag(item.name, item.value);
|
||||
}
|
||||
}
|
||||
|
||||
points.push(point);
|
||||
}
|
||||
});
|
||||
|
||||
// Write to InfluxDB
|
||||
try {
|
||||
const res = await writeApi.writePoints(points);
|
||||
globals.logger.debug(`REJECT LOG EVENT INFLUXDB: Wrote data to InfluxDB v3`);
|
||||
} catch (err) {
|
||||
globals.logger.error(
|
||||
`REJECTED LOG EVENT INFLUXDB: Error saving data to InfluxDB v3! ${err}`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
globals.logger.verbose(
|
||||
'REJECT LOG EVENT INFLUXDB: Sent Butler SOS rejected event count data to InfluxDB'
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user