HydroBot/hydrobot-software Changeset - 1dd55863f684

Changeset - 1dd55863f684

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

matthewreed - 9 years ago 2017-01-01 16:46:22

Added exception handling for database connection error

1 file changed with 22 insertions and 22 deletions:

hydrobot.py

0 comments (0 inline, 0 general)

hydrobot.py

➞

Show inline comments

@@ @@ -3,13 +3,12 @@ import time @@
 import _thread
 import ast
 import configparser
 import datetime
 from canard import can, messaging
 from canard.hw import socketcan
 from canard.hw import cantact
 from canard.file import jsondb
 from canard.utils import queue
 from influxdb import InfluxDBClient
 from influxdb import SeriesHelper
 from apscheduler.schedulers.background import BackgroundScheduler
 import PID
@@ @@ -63,45 +62,46 @@ class Database: @@
         host = config.get("database", "host")
         port = config.get("database", "port")
         username = config.get("database", "username")
         password = config.get("database", "password")
         database = config.get("database", "database")
         self.name = config.get("system", "name")
         self.client = InfluxDBClient(host, port, username, password, database)
         MySeriesHelper.Meta.client = self.client
         MySeriesHelper.Meta.series_name = self.name + '.{measurement}'
         try:
             self.client = InfluxDBClient(host, port, username, password, database)
             MySeriesHelper.Meta.client = self.client
             MySeriesHelper.Meta.series_name = self.name + '.{measurement}'
         except:
             logger.error("Could not connect to database")
         # To manually submit data points which are not yet written, call commit:
         #MySeriesHelper.commit()
     def log_data(self, msgdb, message):
         if message == msgdb.AirSense:
             MySeriesHelper(measurement='air_temp', value=(float)(message.Temperature.value))
             MySeriesHelper(measurement='air_humidity', value=(float)(message.Humidity.value))
             MySeriesHelper(measurement='air_pressure', value=(float)(message.Pressure.value))
         if message == msgdb.RelayDriveIn:
             MySeriesHelper(measurement='water_flow_rate', value=(float)(message.FlowRate.value))
             MySeriesHelper(measurement='input_1', value=(float)(message.Input1.value))
             MySeriesHelper(measurement='input_2', value=(float)(message.Input2.value))
             MySeriesHelper(measurement='input_3', value=(float)(message.Input3.value))
             MySeriesHelper(measurement='input_4', value=(float)(message.Input4.value))
         if message == msgdb.WaterSense:
             MySeriesHelper(measurement='water_level', value=(float)(message.PercentFull.value))
             MySeriesHelper(measurement='water_temp', value=(float)(message.Temperature.value))
         try:
             if message == msgdb.AirSense:
                 MySeriesHelper(measurement='air_temp', value=(float)(message.Temperature.value))
                 MySeriesHelper(measurement='air_humidity', value=(float)(message.Humidity.value))
                 MySeriesHelper(measurement='air_pressure', value=(float)(message.Pressure.value))
             if message == msgdb.RelayDriveIn:
                 MySeriesHelper(measurement='water_flow_rate', value=(float)(message.FlowRate.value))
                 MySeriesHelper(measurement='input_1', value=(float)(message.Input1.value))
                 MySeriesHelper(measurement='input_2', value=(float)(message.Input2.value))
                 MySeriesHelper(measurement='input_3', value=(float)(message.Input3.value))
                 MySeriesHelper(measurement='input_4', value=(float)(message.Input4.value))
             if message == msgdb.WaterSense:
                 MySeriesHelper(measurement='water_level', value=(float)(message.PercentFull.value))
                 MySeriesHelper(measurement='water_temp', value=(float)(message.Temperature.value))
         except:
             logger.error("Could not connect to database")
 class CanBus:
     def __init__(self, database):
         self.database = database
         self.dev = socketcan.SocketCanDev("can0")
         #self.dev = cantact.CantactDev("/dev/ttyACM8")
         #self.dev.set_bitrate(500000)
         self.queue = queue.CanQueue(self.dev)
         parser = jsondb.JsonDbParser()
         self.msgdb = parser.parse('hydrobot_can.json')
         self.temp_msg = self.msgdb.AirSense

0 comments (0 inline, 0 general)