如何使用Python将媒体流从SocketSever传输到Falcon API

问题描述

我正在开发一个小型python服务器，旨在将MP4流作为套接字服务器接收，我想将数据传输到另一个与Falcon进行GET请求连接的客户端。

这是我的API服务器，用于发送媒体：

class StreamResource:
    def on_get(self,req,resp):
        #Throw error rfile is not defined
        resp.stream = hlserver.socket_list[0].rfile.iter_content(io.DEFAULT_BUFFER_SIZE)

app = falcon.API()
app.add_route('/livestream.mp4',StreamResource())

我的套接字服务器在这里接收媒体

class MyTCPHandler(socketserver.StreamRequestHandler):

    def setup(self):
      print(self.client_address[0],' connected')
      socket_list.append(self)

    def handle(self):
        #Have to keep this to prevent client to be disconnected
        self.data = self.request.recv(1024).strip()

    def finish(self):
      print(self.client_address[0],' disconnected')
      socket_list.remove(self)



class ThreadedSocketServer(object):

    def __init__(self,interval=1):
    
        self.interval = interval

        thread = threading.Thread(target=self.run,args=())
        thread.daemon = True                            # Daemonize thread
        thread.start()                                  # Start the execution

    def run(self):
      HOST,PORT = "localhost",8001

      # Create the server,binding to localhost on port 9999
      server = socketserver.Tcpserver((HOST,PORT),MyTCPHandler)

      # Activate the server; this will keep running until you
      # interrupt the program with Ctrl-C
      server.serve_forever()

所以我的主要目标是将数据从MyTCPHandler.handle传输到StreamResource.on_get。

1. 我不知道什么是最好的方法。是否可以传递流引用，还是应该将字节块复制到缓冲区或其他任何内容中？
2. 我尝试在StreamRequestHandler上使用socketserver documentation中的示例。他们正在使用rfile属性，但是当我执行同样的操作时，我有了AttributeError: 'MyTCPHandler' object has no attribute 'rfile'
3. 如果我将MyTCPHandler.handle方法设置为空，则每次连接后我都会立即断开客户端连接

感谢您的帮助

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）