如何在 NodeJS 中成功解析 FFMpeg 的输出

Question

所以我看到了很多关于 FFMPeg 的主题，它是我今天学到的一个很棒的工具，但是我花了一天时间完善命令，现在有点卡在 NodeJS 部分。

本质上，该命令执行以下操作：从 Mac OSX 网络摄像头获取输入，然后将其流式传输到网络套接字。现在我查看了很多 NodeJS 库，但找不到一个满足我需要的库；或者不明白怎么做。这是我正在使用的命令示例：

ffmpeg -f avfoundation -framerate 30 -video_size 640x480 -pix_fmt uyvy422 -i "0:1" -f mpegts -codec:v mpeg1video -s 640x480 -b:v 1000k -bf 0 http://localhost:8081/stream

这可以满足我在流式传输方面所需的一切，但我希望通过 NodeJS 调用它，然后能够监控日志并解析返回的数据，例如：

frame= 4852 fps= 30 q=6.8 size=   30506kB time=00:02:41.74 bitrate=1545.1kbits/s speed=   1x    \r

并使用它来获取一个 JSON 数组，以便我输出到网页。

现在我所做的只是研究实际解析数据的方法，并且我已经查看了很多其他类似的答案，但我似乎无法拆分/替换/正则表达式。除了一长串，我什么也得不到。

这是我正在使用的代码（NodeJS）：

var ffmpeg = require('child_process').spawn('/usr/local/Cellar/ffmpeg/3.3.1/bin/ffmpeg', ['-f', 'avfoundation', '-framerate', '30', '-video_size', '640x480', '-pix_fmt', 'uyvy422', '-i', '0:1', '-f', 'mpegts', '-codec:v', 'mpeg1video', '-s', '640x480', '-b:v', '1000k', '-bf', '0', 'http://localhost:8081/test']);

ffmpeg.on('error', function (err) {
    console.log(err);
});

ffmpeg.on('close', function (code) {
    console.log('ffmpeg exited with code ' + code);
});

ffmpeg.stderr.on('data', function (data) {
    // console.log('stderr: ' + data);
    var tData = data.toString('utf8');
    // var a = tData.split('[\\s\\xA0]+');
    var a = tData.split('\n');
    console.log(a);
});

ffmpeg.stdout.on('data', function (data) {
    var frame = new Buffer(data).toString('base64');
    // console.log(frame);
});

我尝试使用新行、回车符、空格、制表符进行拆分，但我似乎无法获得可以使用的基本位数组。

另外需要注意的是，您是否会注意到日志是通过 stderr 返回的，我在网上看到过，显然很多人都这样做了？所以我不确定这是怎么回事？但代码是 sdterr 回调。

非常感谢任何帮助，因为我真的对自己做错了什么感到困惑。

谢谢。

Answer 1

对此的更新，我与 IRC 频道外的一个人一起工作：FreeNode 上的#ffmpeg。答案是通过管道将输出发送到标准输出。

例如，我在 FFMpeg 命令中附加了以下内容：

-progress pipe:1

进度标志用于每秒输出有关流的信息，因此这几乎是您每秒从 stderr 流中获得的所有内容，但以我可以解析的格式通过管道传输到 stdout 流。以下摘自文档。

-progress url (global) 向 url 发送程序友好的进度信息。进度信息大约每秒写入一次，并且在编码过程结束时写入。它由“key=value”行组成。 key 仅包含字母数字字符。进度信息序列的最后一个键始终是“进度”。

下面是我用来解析流信息的代码示例：

ffmpeg.stdout.on('data', function (data) {

    var tLines = data.toString().split('\n');
    var progress = {};
    for (var i = 0; i < tLines.length; i++) {
        var key = tLines[i].split('=');
        if (typeof key[0] != 'undefined' && typeof key[1] != 'undefined') {
            progress[key[0]] = key[1];
        }
    }

    // The 'progress' variable contains a key value array of the data
    console.log(progress);

});

感谢所有评论！

Answer 2

本着不重新发明轮子的精神，您可能想尝试使用fluent-ffmpeg。它发送带有许多有用字段的progress event

'progress'：转码进度信息

每次 ffmpeg 报告进度时都会发出进度事件 信息。它与带有以下内容的对象参数一起发出 键：

• 帧：处理的总帧数
• currentFps：FFmpeg 当前处理的帧率
• currentKbps：FFmpeg 当前处理的吞吐量
• targetSize：目标文件的当前大小，以千字节为单位
• timemark：当前帧的时间戳，以秒为单位
• 百分比：估计进度百分比

如果您对他们如何做到这一点感到好奇，您可以阅读源代码，starting from here

Ffmpeg 使用 stderr 输出日志信息，因为 stdout 用于将输出通过管道传输到其他进程。 stderr 中的东西实际上只是调试信息，而不是进程的实际输出。

---

奖金回合

我见过一些使用 websocket 流式传输视频的 hacky 视频播放器，但这种方法存在许多问题。我不打算讨论这些，但我会解释为什么我认为你应该使用hls.js。

支持还不错；除了旧的 IE 之外，基本上可以在任何地方使用。它使用MSE 升级标准视频元素，因此您不必为构建自定义播放器而苦恼。

这是hls format flag的文档

这是我用来从 IPTV 盒流式传输到网页的一些代码。

this.ffmpeg = new FFFmpeg()
this.ffmpeg.input(request(this.http_stream))
    .videoCodec('copy')
    .audioCodec('copy')
    .outputOptions([
        '-f hls',
        '-hls_list_size 6',
        '-hls_flags delete_segments'
    ])
    .output( path.join(this.out_dir, 'video.m3u8') )
    .run()

它会生成一个 .m3u8 清单文件以及分段的 mpeg-ts 视频文件。之后您需要做的就是将 m3u8 文件加载到 hls.js 播放器中，您就有了直播！

如果您要重新编码流，您可能会看到一些低 fps 和故障。我很幸运，因为我的源流已经编码为 mpeg-ts。