logAggregator/casRpsLogExtractor.js

let sql=require("mssql");
let request=require("request-promise");

//sql.trustedConnection = true;
let sqlConfig = {
    user: 'casdbuser',
    password:'4KcLao2016!',
    server: 'ustww2063\\CCE',
    database: 'CAS110',
    port: 1433
}

let sourceTag="CCERpsLog";
let processingType="casrpslog";
let maxPKey="";

sql.connect(sqlConfig,err => {
    console.log("JOE" , err);
    const sqlRequest = new sql.Request();
    sqlRequest.stream = true;


    setInterval(_=>{
        sqlRequest.query('select top 1 * from rpslog where pkey > \'' + maxPKey + '\' order by pkey');
    },500)

    sqlRequest.on('row',row=>{
        outData={sourceTag:sourceTag,processingType:processingType,data:row};
        console.log(outData);
        request.json = true;
        request({method:'POST',uri:'http://localhost:2222',body:JSON.stringify(outData),json:true}).then(_=>{
            // count up the maxPKey only when the request was successful...
            if (row.PKey > maxPKey) {
                maxPKey=row.PKey;
            }
        });

    });

    sqlRequest.on('done', result=>{
        console.log("Done");
    });
})