Changeset - 590eff6f7ddc
[Not reviewed]
default
0 1 0
matthewreed - 9 years ago 2016-07-23 20:32:37

Added WaterSense data logging
1 file changed with 22 insertions and 0 deletions:
0 comments (0 inline, 0 general)
hydrobot.py
Show inline comments
 
@@ -62,48 +62,70 @@ class Database:
 
                    "fields": {
 
                        "value": (float)(message.Input1.value)
 
                    }
 
                },
 
                {
 
                    "measurement": self.name + "_input_2",
 
                    "fields": {
 
                        "value": (float)(message.Input2.value)
 
                    }
 
                },
 
                {
 
                    "measurement": self.name + "_input_3",
 
                    "fields": {
 
                        "value": (float)(message.Input3.value)
 
                    }
 
                },
 
                {
 
                    "measurement": self.name + "_input_4",
 
                    "fields": {
 
                        "value": (float)(message.Input4.value)
 
                    }
 
                }
 
            ]
 
            self.client.write_points(json_body)
 
        if message == msgdb.WaterSense:
 
            json_body = [
 
                {
 
                    "measurement": self.name + "_water_level",
 
                    "fields": {
 
                        "value": (float)(message.PercentFull.value)
 
                    }
 
                },
 
                {
 
                    "measurement": self.name + "_water_temp",
 
                    "fields": {
 
                        "value": (float)(message.Temperature.value)
 
                    }
 
                },
 
                {
 
                    "measurement": self.name + "_water_raw_debug",
 
                    "fields": {
 
                        "value": (float)(message.RawDebug.value)
 
                    }
 
                }
 
            ]
 
            self.client.write_points(json_body)
 

	
 

	
 
class CanBus:
 
    
 
    def __init__(self, database):
 
        
 
        self.database = database
 

	
 
        self.dev = socketcan.SocketCanDev("can0")
 
        
 
        parser = jsondb.JsonDbParser()
 
        self.msgdb = parser.parse('hydrobot_can.json')
 
        
 
        self.temp_msg = self.msgdb.AirSense
 
        self.relay_msg = self.msgdb.RelayDriveIn
 
        self.relay_send_msg = self.msgdb.RelayDriveOut
 
        
 
    def start(self):
 
        self.dev.start()
 
        
 
    def start_receive(self):
 
        _thread.start_new_thread(self.process_can, ())
 

	
 
    def process_can(self):
0 comments (0 inline, 0 general)