HydroBot/hydrobot-software Changeset - ef97024d8644

Changeset - ef97024d8644

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

matthewreed - 9 years ago 2017-01-01 17:06:23

Added exception handling for database connection error in output logging

1 file changed with 16 insertions and 4 deletions:

hydrobot.py

0 comments (0 inline, 0 general)

hydrobot.py

➞

Show inline comments

@@ @@ -131,31 +131,43 @@ class CanBus: @@
         self.relay_send_msg.Output3.value = 1
         self.relay_send_msg.Output4.value = 1
         logger.debug("Send CAN message! ID: " + hex(self.relay_send_msg.id) + " Data: " + str(self.relay_send_msg.data))
         self.queue.send(self.relay_send_msg.encode())
     def set_output(self, module, output, state):
         logger.info("Output! " + module + " " + output + " " + str(state))
         msg = self.msgdb.lookup_message(module)
         msg.lookup_signal(output).value = state
         self.queue.send(msg.encode())
         if msg.lookup_signal(output) == msg.Output1:
             MySeriesHelper(measurement='output_1', value=state)
             try:
                 MySeriesHelper(measurement='output_1', value=state)
             except:
                 logger.error("Could not connect to database")
         if msg.lookup_signal(output) == msg.Output2:
             MySeriesHelper(measurement='output_2', value=state)
             try:
                 MySeriesHelper(measurement='output_2', value=state)
             except:
                 logger.error("Could not connect to database")
         if msg.lookup_signal(output) == msg.Output3:
             MySeriesHelper(measurement='output_3', value=state)
             try:
                 MySeriesHelper(measurement='output_3', value=state)
             except:
                 logger.error("Could not connect to database")
         if msg.lookup_signal(output) == msg.Output4:
             MySeriesHelper(measurement='output_4', value=state)
             try:
                 MySeriesHelper(measurement='output_4', value=state)
             except:
                 logger.error("Could not connect to database")
 class Scheduler:
     def __init__(self, canbus):
         self.canbus = canbus
         self.apscheduler = BackgroundScheduler()
         self.apscheduler.configure(timezone=timezone('US/Eastern'))
     def start(self):
         self.apscheduler.start()

0 comments (0 inline, 0 general)