wn/MqttToInflux
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-08-01 16:58:56 +02:00
parent 68ced39827
commit 3425f25a51
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.ts
View File

@ -3,7 +3,7 @@ import * as Mqtt from 'mqtt'
import { post } from 'request' import { post } from 'request'
const BROKER : string = 'mqtt://localhost' const BROKER : string = 'mqtt://172.16.2.16'
const INFLUXDB : string = 'http://172.16.3.15:8086/write?db=smarthome' const INFLUXDB : string = 'http://172.16.3.15:8086/write?db=smarthome'
const VERBOSE : boolean = true const VERBOSE : boolean = true
@ -49,7 +49,7 @@ mqttClient.on('message', (topic : string, messageBuf : Buffer) => {
if (err) { if (err) {
log.error(`Error when sending data to database: ${err}`) log.error(`Error when sending data to database: ${err}`)
} else { } else {
log.info(`Response from database: ${res}, ${body}`) log.info('Inserted into database')
} }
}) })