jprdonnelly/butler-sos
1
0
Fork 0
mirror of https://github.com/ptarmiganlabs/butler-sos.git synced 2025-12-19 17:58:18 -05:00
Code Issues Projects Releases Wiki Activity

feat: Add support for storing Sense engine warning/error log messages in InfluxDB.

Browse Source 
Implements #435
This commit is contained in:
Göran Sander
2022-08-08 18:59:57 +00:00
parent f05d5017aa
commit 40d784f037
2 changed files with 51 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/globals.js
View File

@@ -273,7 +273,11 @@ tagValuesLogEvent.push('user_directory');
tagValuesLogEvent.push('user_id');
tagValuesLogEvent.push('task_id');
tagValuesLogEvent.push('task_name');
tagValuesLogEvent.push('app_id');
tagValuesLogEvent.push('app_name');
tagValuesLogEvent.push('result_code');
tagValuesLogEvent.push('windows_user');
tagValuesLogEvent.push('engine_exe_version');
// Check if there are any extra log event tags in the config file
if (config.has('Butler-SOS.logEvents.tags') && config.get('Butler-SOS.logEvents.tags') !== null) {
@@ -416,6 +420,7 @@ const influx = new Influx.InfluxDB({
result_code: Influx.FieldType.STRING,
origin: Influx.FieldType.STRING,
context: Influx.FieldType.STRING,
session_id: Influx.FieldType.STRING,
raw_event: Influx.FieldType.STRING,
},
tags: tagValuesLogEvent,

60
src/lib/post-to-influxdb.js
View File

@@ -487,11 +487,12 @@ function postLogEventToInfluxdb(msg) {
let fields;
if (
msg.source === 'qseow-engine' ||
msg.source === 'qseow-proxy' ||
msg.source === 'qseow-scheduler' ||
msg.source === 'qseow-repository'
) {
if (msg.source === 'qseow-proxy') {
if (msg.source === 'qseow-engine') {
tags = {
host: msg.host,
level: msg.level,
@@ -500,10 +501,41 @@ function postLogEventToInfluxdb(msg) {
subsystem: msg.subsystem,
};
// Tags that are empty in some cases. Only add if they are non-empty
if (msg.user_full.length > 0) tags.user_full = msg.user_full;
if (msg.user_directory.length > 0) tags.user_directory = msg.user_directory;
if (msg.user_id.length > 0) tags.user_id = msg.user_id;
if (msg.result_code.length > 0) tags.result_code = msg.result_code;
if (msg?.user_full?.length > 0) tags.user_full = msg.user_full;
if (msg?.user_directory?.length > 0) tags.user_directory = msg.user_directory;
if (msg?.user_id?.length > 0) tags.user_id = msg.user_id;
if (msg?.result_code?.length > 0) tags.result_code = msg.result_code;
if (msg?.windows_user?.length > 0) tags.windows_user = msg.windows_user;
if (msg?.task_id?.length > 0) tags.task_id = msg.task_id;
if (msg?.task_name?.length > 0) tags.task_name = msg.task_name;
if (msg?.app_id?.length > 0) tags.app_id = msg.app_id;
if (msg?.app_name?.length > 0) tags.app_name = msg.app_name;
if (msg?.engine_exe_version?.length > 0)
tags.engine_exe_version = msg.engine_exe_version;
fields = {
message: msg.message,
exception_message: msg.exception_message,
command: msg.command,
result_code: msg.result_code,
origin: msg.origin,
context: msg.context,
session_id: msg.session_id,
raw_event: JSON.stringify(msg),
};
} else if (msg.source === 'qseow-proxy') {
tags = {
host: msg.host,
level: msg.level,
source: msg.source,
log_row: msg.log_row,
subsystem: msg.subsystem,
};
// Tags that are empty in some cases. Only add if they are non-empty
if (msg?.user_full?.length > 0) tags.user_full = msg.user_full;
if (msg?.user_directory?.length > 0) tags.user_directory = msg.user_directory;
if (msg?.user_id?.length > 0) tags.user_id = msg.user_id;
if (msg?.result_code?.length > 0) tags.result_code = msg.result_code;
fields = {
message: msg.message,
@@ -523,11 +555,11 @@ function postLogEventToInfluxdb(msg) {
subsystem: msg.subsystem,
};
// Tags that are empty in some cases. Only add if they are non-empty
if (msg.user_full.length > 0) tags.user_full = msg.user_full;
if (msg.user_directory.length > 0) tags.user_directory = msg.user_directory;
if (msg.user_id.length > 0) tags.user_id = msg.user_id;
if (msg.task_id.length > 0) tags.task_id = msg.task_id;
if (msg.task_name.length > 0) tags.task_name = msg.task_name;
if (msg?.user_full?.length > 0) tags.user_full = msg.user_full;
if (msg?.user_directory?.length > 0) tags.user_directory = msg.user_directory;
if (msg?.user_id?.length > 0) tags.user_id = msg.user_id;
if (msg?.task_id?.length > 0) tags.task_id = msg.task_id;
if (msg?.task_name?.length > 0) tags.task_name = msg.task_name;
fields = {
message: msg.message,
@@ -546,10 +578,10 @@ function postLogEventToInfluxdb(msg) {
subsystem: msg.subsystem,
};
// Tags that are empty in some cases. Only add if they are non-empty
if (msg.user_full.length > 0) tags.user_full = msg.user_full;
if (msg.user_directory.length > 0) tags.user_directory = msg.user_directory;
if (msg.user_id.length > 0) tags.user_id = msg.user_id;
if (msg.result_code.length > 0) tags.result_code = msg.result_code;
if (msg?.user_full?.length > 0) tags.user_full = msg.user_full;
if (msg?.user_directory?.length > 0) tags.user_directory = msg.user_directory;
if (msg?.user_id?.length > 0) tags.user_id = msg.user_id;
if (msg?.result_code?.length > 0) tags.result_code = msg.result_code;
fields = {
message: msg.message,