node.js - nodejsとffmpegを使ったリアルタイム動画変換

Question

ffmpeg と nodejs を使用して、非常に単純なサーバー側のビデオ変換を作成しようとしています。これまでのところ、ビデオ入力を変換するための 1 つと、変換されたビデオをリッスンして websocket に渡すための 2 つの UDP サーバーがあります。

ストリームが来るUDPサーバーを1つ作成し、ffmpegを呼び出してビデオ入力を変換します。次に、2 番目の UDP サーバーが変換されたビデオを取得し、それを websocket サーバーに渡して、ビデオをブラウザーにストリーミングします。

問題はおそらくffmpegへの入力にあります。私が得るエラーは

_stream_readable.js:476
  dest.on('unpipe', onunpipe);
       ^
TypeError: Object 

コードは次のようになります。

// Websocket Server
var socketServer = new (require('ws').Server)({port: 8081});
socketServer.on('connection', function(socket) {
    socket.on('close', function(code, message){
        console.log( 'Disconnected WebSocket ('+socketServer.clients.length+' total)' );
    });
});

socketServer.broadcast = function(data, opts) {
    for( var i in this.clients ) {
        this.clients[i].send(data, opts);
    }
};

// UDP Server
var udpServer = require("dgram").createSocket("udp4");

udpServer.on("message", function(msg, rinfo) {
    socketServer.broadcast(msg, {binary:true});
    console.log("server got: " + msg + " from " + rinfo.address + ":" + rinfo.port);
});

udpServer.on("listening", function() {
    var address = udpServer.address();
    console.log("server listening " + address.address + ":" + address.port);
});
udpServer.bind(8082);

// UDP Server for stream conversion
var udpServer2 = require("dgram").createSocket("udp4");

udpServer2.on("message", function(msg, rinfo) {
    // **********  THIS IS WHERE ERROR OCCURS **************
    var ffmpeg = require('child_process')
            .spawn('ffmpeg',['-f','video4linux2','-i','-','-f','mpeg1video','udp://127.0.0.1:8082']);
    ffmpeg.stdin.pipe(msg);
});

udpServer2.on("listening", function() {
    var address = udpServer2.address();
    console.log("server listening " + address.address + ":" + address.port);
});
udpServer2.bind(8083);