如何创建 pyserial Web 服务？

Question

我编写了一个与 /dev/ttyS02 上的串行设备交互的 Web 应用程序。 问题是我当前的消息传递和排队解决方案。请阅读下文。

这是应用程序和pyserial之间的通信桥梁：

• 我的 Web 应用程序通过 PHP 将请求记录插入到 MySQL 中的 d_requests 表中。 插入记录的已处理列设置为 0。 插入的记录的 id 保存在 $id 变量中，并且 PHP 应用程序输入 循环状态，它将不断检查 d_requests[processed] 列是否 = 1 使用 $id 作为查找参考。

• 我有一个 python 守护进程服务，它每秒检查一次中的记录 d_requests 表，其中已处理列 = 0。 这被认为是一个新请求。（参考源代码 - python 服务）

• 然后，python 服务使用记录的信息通过以下方式连接到端口 pyserial。

• 执行请求的操作。然后记录的已处理列更新为 1 其他一些字段也更新了。 这将记录标记为已处理。

• 然后 PHP 控制块退出循环（第 1 点）并以 json 形式返回结果 结果

一些注意事项

• 串行设备每 250 毫秒能够处理 1 个请求。
• python 守护进程服务监视 d_requests 表以获取已处理的记录 每 1 秒列 = 0。
• 我的 Web 应用程序与 python 守护进程服务的唯一通信是 MySQL
  DB 通过在 d_requests 表中插入请求记录。
• 我使用 PHP 块代码每秒使用插入的 id 来查找请求以进行检查 如果已处理列已更新为 1。

我的担忧

单点故障

当守护程序服务未运行时，无法发生串行请求

极端资源使用 strong>

我预计每秒向串行设备发出大约 4-5 个请求。使用当前的实现 为了处理消息，数据库将超时工作，CPU 使用率会很高，因为 PHP 应用程序和 python 守护进程/服务将连接数据库并在数据库上执行查询，并且请求处理会出现延迟。

结论： 有没有更好的方法来改进我当前的消息传递和排队解决方案？ 我认为 pyserial Web 服务在这种情况下会很好用，例如串行端口。连接到网络套接字，例如。主机：<7000>我可以通过 PHP 向其发送请求并等待 Web 服务返回的响应。不幸的是我不知道该怎么做。

有什么想法吗？

谢谢

源代码

python 服务

    import sys, time
    from daemon import Daemon
    import MySQLdb 

#Database parameters
config = {"host":"localhost","username":"root","password":"cake","database":"mydb"}

#Check if MySQLdb library is present
try:
    conn = MySQLdb.connect(config['host'],config['username'],config['password'],config['database'])
except MySQLdb.Error, e:
    print "Error %d: %s" % (e.args[o], e.args[1])
    sys.exit(1);

#Check if pyserial library is present
try:
    import serial
except ImportError:
    print "Error,pySerial module not installed"
    sys.exit(1);

#Create DB cursor  
#cursor = conn.cursor(cursorclass=MySQLdb.cursors.DictCursor)
#Declare global variables here
class MyDaemon(Daemon): 
    def run(self):
        while True:
            time.sleep(2)
            cursor = conn.cursor(cursorclass=MySQLdb.cursors.DictCursor)
            data = ''
            try:
                cursor.execute ("""SELECT * FROM d_requests where processed = 0""")
                rows=cursor.fetchall()
                print "Waiting for requests..."
            except MySQLdb.Error as detail:
                print "MySQL Error,",detail
            if len(rows) == 0:
                cursor.close()
                print "No request found..."
                continue
            for row in rows:
                try:                
                    print "Processing request..."                   
                    ser = serial.Serial(port=row['port'],
                    baudrate = row['baud'],
                    bytesize = row['bytesize'], #8
                    parity = row['parity'], #serial.PARITY_NONE or N or C
                    stopbits = row['stopbits'], #1
                    timeout = row['wait_for_reply'], #0.5
                    xonxoff = row['sw_flowcontrol'], #0
                    rtscts = row['hw_flowcontrol']) #0                  
                    #Send command to device
                    ser.write(row['request_string'] + "\r")
                    #Read device response                   
                    data = ser.read(100)#TBD:This value needs to be changeable,not always 100 bytes
                    ser.close()
                    print "RESULT : " + data                    
                except (serial.SerialException, AttributeError, NameError) as detail:
                    data = "Error, could not open port"
                    print data                  
                except serial.SerialTimeoutException as detail:
                    data = "Error, port connection timeout" #Error ,detail
                    print data
                except:
                    data = "Error,Unexpected error"
                    print data              
                finally:
                    #ser.close()
                    try:
                        cursor.execute("""UPDATE d_requests SET processed = %s, result_string = %s WHERE id = %s""",(1,data,row['id']))
                    except MySQLdb.Error as detail:
                        print "MySQL Error,",detail
                #cursor.commit() for innoDB table engines
            cursor.close()
if __name__ == "__main__":
    daemon = MyDaemon('/tmp/daemon-example.pid')
    if len(sys.argv) == 2:
        if 'start' == sys.argv[1]:
            daemon.start()          
        elif 'stop' == sys.argv[1]:
            daemon.stop()
        elif 'restart' == sys.argv[1]:
            daemon.restart()
        elif 'foreground' == sys.argv[1]: #this runs the daemon in the foreground
            daemon.run()
        else:
            print "Unknown command"
            sys.exit(2)
        sys.exit(0)
    else:
        print "usage: %s start|stop|restart" % sys.argv[0]
        sys.exit(2)

Answer 1

是否有更好的方法来改进我当前的消息传递和排队解决方案？

你打赌！它们被称为消息队列，它们非常棒。

我最喜欢的是 Gearman，它是由为我们带来 memcached 的同一团队编写的。它有 PHP 和 Python 绑定。与其说它实际上是一个消息队列，不如说它是一个 RPC 服务。无论如何，它允许您从一个环境调用方法并在另一个环境中处理它们。

在这种情况下，您需要用 Python 编写串行接口代码，并让它以 Gearman 函数的形式公开它可以执行的所有操作。它将作为守护进程打开。您的 PHP 代码可以通过 Gearman 调用这些函数。

Answer 2

研究类似的需求。到目前为止发现“ser2net”和“termnetd”守护进程很有帮助。