diff --git a/database.py b/database.py --- a/database.py +++ b/database.py @@ -29,11 +29,11 @@ class Database: port = config.get("database", "port") username = config.get("database", "username") password = config.get("database", "password") - database = config.get("database", "database") + self.database = config.get("database", "database") self.name = config.get("system", "name") try: - self.client = InfluxDBClient(host, port, username, password, database) + self.client = InfluxDBClient(host, port, username, password, self.database) MySeriesHelper.Meta.client = self.client MySeriesHelper.Meta.series_name = self.name + '.{measurement}' self.logger.info("Connected to database") @@ -57,3 +57,24 @@ class Database: self.logger.error("Database issue!") else: self.logger.warning("Unknown data key: " + str(message)) + + def read_value(self, name, data_name, sensor_num): + #try: + + if sensor_num > 0: + num = "_" + str(sensor_num) + else: + num = "" + measurement = "\"" + self.name + "." + name + "." + data_name + num + "\"" + results = self.client.query(("SELECT last(\"value\") from %s") % (measurement)) + points = results.get_points() + for item in points: + return item["last"] + + + #except: + # self.logger.error("Database issue!") + + + +