collectorFile.py

#!/opt/bin/python

import ConfigParser
import datetime

config = ConfigParser.RawConfigParser()
config.read('config/collector.cfg')

FILENAME = config.get('file', 'filename')

fileHandle = None


def connectToDatasource(connectionId):
    global fileHandle
    if fileHandle is None:
        fileHandle = open(FILENAME, 'a', 1)
        print "opening file"


def writeToDatasource(connectionId, temp=0, date=datetime.datetime.now(), sensorName='unknown'):
    connectToDatasource(connectionId)
    fileHandle.write(
        "INSERT INTO log (value, datetime, fk_sensor) VALUES ({0}, '{1}', '{2}')"
        .format(temp, date, sensorName))


def writeToControlDatasource(connectionId, value=0, date=datetime.datetime.now(),):
    connectToDatasource()
    fileHandle.write(
        "INSERT INTO logs_control (value, datetime) VALUES ({0}, '{1}')"
        .format(value, date))


def close(connectionId):
    global fileHandle
    fileHandle.close()