wu_xinjun
2022-06-15 0dc337197311d0fec373bf479f8ee0ac26b4cad6
scripts/mqClient.py
@@ -8,7 +8,7 @@
from src.engine.AcquisitionMain import AcquisitionMain
from src.engine.AcquisitionMain import Config
# from src.engine.AcquisitionMain import Config
def quit(signum, frame):
    print('You choose to stop me.')
@@ -20,16 +20,14 @@
        print("EXAMPLE: Client.py 172.17.17.206 chai password123 aerial_rpc pod1 http://172.17.17.206/api 192.168.2.65")
        exit(1)
    if len(sys.argv) != 8:
    if len(sys.argv) != 6:
        help()
    try:
        MQhost = str(sys.argv[1])
        MQuser = str(sys.argv[2])
        MQpassword = str(sys.argv[3])
        QUEUEname = str(sys.argv[4])
        DEVICEname = str(sys.argv[5])
        SERVERhost = str(sys.argv[6])
        MICROWAVEhost = str(sys.argv[7])
        DEVICEname = str(sys.argv[4])
        MICROWAVEhost = str(sys.argv[5])
    except Exception as e:
        print(e)
@@ -40,15 +38,13 @@
    signal.signal(signal.SIGTERM, quit)
    # client = AcquisitionMain('192.168.3.54', 'chai',
    #                       'password123', 'aerial_rpc', 'pod1', 'http://192.168.3.54:5000/api', 10)
    config_dir = os.path.join(__file__, "..",  "../src/config.json" )
    config_path = os.path.abspath(config_dir)
    config = Config(config_path)
    # config_dir = os.path.join(__file__, "..",  "../src/config.json" )
    # config_path = os.path.abspath(config_dir)
    # config = Config(config_path)
    client = AcquisitionMain(MQhost,
                             MQuser,
                             MQpassword, 
                             QUEUEname,
                             DEVICEname, 
                             SERVERhost,
                             MICROWAVEhost, # udp server host, 192.168.2.65 for production
                             config)
                            )
    client.start()