joe/logAggregator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Implement a non-polling flag in the DB-Extractor

Browse Source
This commit is contained in:
Joe Tretter
2019-04-09 14:20:21 -05:00
parent 84c045f6c8
commit d06d0a32bf
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
DBExtractor/DBExtractor.config.json.example
View File

@@ -5,9 +5,10 @@
"serverURI": "http://localhost:2222", "serverURI": "http://localhost:2222",
"maxResultsPerMessage":100, "maxResultsPerMessage":100,
"statements":{ "statements":{
"poller":"'select top ' + config.maxResultsPerMessage + ' * from rpslog with (nolock) where pkey > \\'' + maxPKey + '\\' and businessModified < dateAdd(mi,-30, getdate()) order by pkey'" "poller":"'select top ' + config.maxResultsPerMessage + ' * from rpslog with (nolock) where pkey > \\'' + maxPKey + '\\' order by pkey'"
}, },
"pollIntervalIdle": 10000, "pollIntervalIdle": 10000,
"pollMode": false,
"UP_sqlConfig": { "UP_sqlConfig": {
"user": "casdbuser", "user": "casdbuser",
"password": "4KcLao2016!", "password": "4KcLao2016!",

9
DBExtractor/DBExtractor.js
View File

@@ -99,8 +99,13 @@ try {
}); });
process.stdout.write(">" + allRows.length + ">"); process.stdout.write(">" + allRows.length + ">");
} else { } else {
theInterval = setInterval(runNextPoll, config.pollIntervalIdle); if (config.pollMode) {
process.stdout.write("."); theInterval = setInterval(runNextPoll, config.pollIntervalIdle);
process.stdout.write(".");
} else {
sql.close();
return(true);
}
} }
allRows=[]; allRows=[];