obd2.py

import serial
import obd
import ast
import sys
import time
import argparse
import traceback
from logging import raiseExceptions
sys.path.append('/opt/iotistic-mnvr/pyscripts/')
from network_utils import run
from db_util import *

parser = argparse.ArgumentParser()
# parser.add_argument("-r", "--request", type=str, help="requested data")
args = parser.parse_args()


def connect_to_OBD():
    while True:
        try:
            serialport = '/dev/ttyUSB0' if 'Future' in run('udevadm info /dev/ttyUSB0') else '/dev/ttyUSB4'
            connection = obd.OBD(serialport)
            return connection
        except:
            traceback.print_exc()
            continue

def init_obd_db():
    obd_db = Database('/home/mnvr/Data/obd.db')  # GPS_DB SETUP
    obd_db.create_table("obd_data")
    obd_db.empty_table("obd_data")
    return obd_db

if __name__=='__main__':
    connection = connect_to_OBD()
    obd_db = init_obd_db()
    time.sleep(0.5)
    while True:
        try:
            res = connection.query(obd.commands['GET_DTC'])
            response = ast.literal_eval(str(res))
            print(f'insert into obd_data (candtc) VALUES ("{response}")')
            # print(response)
            if (str(response)== 'None'):
                raise Exception('OBD Connection is not available.')
            obd_db.send_query(f'insert into obd_data (candtc) VALUES ("{response}")')
            time.sleep(2)

        except:
            traceback.print_exc()
            connection.close()
            time.sleep(1)
            connection = connect_to_OBD()
            continue