如何防止值错误：flask socketio 中有效负载中的数据包过多

Question

所以我正在做我的期末项目。我想从客户端网络摄像头获取头部姿势估计。我使用 websocket 成功将网络摄像头传输到服务器。但是当我尝试将头部姿势函数放入套接字路径中时，终端valueError: too many packets in payload经常显示错误。有谁知道如何防止这个错误？任何答案将不胜感激。谢谢 ！

这是我的代码以获取更多信息。

JavaScript

var constraints = { audio: false, video: { width: 500, height: 500 } }; 
var video = document.querySelector('video');
var canvas = document.querySelector('canvas');

var socket = io('https://0.0.0.0:8000');

navigator.mediaDevices.getUserMedia(constraints)
    .then(function(mediaStream) {
    video.srcObject = mediaStream;
    video.onloadedmetadata = function(e) {
    video.play();

  };
})
.catch(function(err) { console.log(err.name + ": " + err.message); })

socket.on('connect', function () {
    console.log('connected !', socket.connected);

    function capture() {
        canvas.width = 200;
        canvas.height = 200;
        canvas.getContext('2d').drawImage(video, 0, 0, 200, 200);
        var data = canvas.toDataURL('image/jpeg');

        return data;
    };

    var FPS = 50

    setInterval(() => {
        var imgData = capture();

        socket.emit('image', imgData);

    }, 1000 / FPS);
});

烧瓶应用程序

@socketio.on('image')
def image(data_image):
    time.sleep(1)
    encoded_image = data_image.split(",")[1]
    decoded = base64.b64decode(encoded_image)
    frame = cv2.imdecode(np.frombuffer(decoded, np.uint8), -1)

    #this is my head pose module
    pose = FacePosition(frame)

    head_pose = pose.run()
    print(head_pose)

if __name__ == '__main__':
    socketio.run(app, threaded = True)

Answer 1

您可能想看一下这个github 问题。提高 enigneio 的 max_decode_packets 确实为我解决了这个问题。