Javascript 仅从NodeJS.ReadableStream获取第一个项目

发布于11月28日

我想知道是否有可能只从Fetch Response Body中的可读流中获取第一项，而不遍历它.

数据以原始字符串的形式出现，如下所示:

...
2023-11-28T00:00:00.0000000Z { "data": { ..., "p": "36966.01000000", ... } }
...

我不能简单地用JSON.parse()来解析它，所以我找到了一种方法来读取流，如下所示:

import split from 'split2'
import fetch from 'node-fetch'

const response = await fetch(<url>, <options>)
const lines = response.body.pipe(split())
for await (const line of lines) {
    let value = parseFloat(JSON.parse(line.split(' ')[1]).data.p)
    break
}

这种方法涉及在for...of个循环中穿过管道的线路，并在第一次迭代后将其断开.

有没有更高效、更优雅的方法呢？

推荐答案

您的代码对于处理可读的流和提取第一项来说已经相当合理了，而不需要迭代整个流. 您可能希望处理错误，并确保在处理所需数据后正确关闭流.

import split from 'split2';
import fetch from 'node-fetch';

try {
  const response = await fetch(<url>, <options>);

  if (!response.ok) {
    throw new Error(`HTTP error! Status: ${response.status}`);
  }

  const lines = response.body.pipe(split());
  for await (const line of lines) {
    try {
      const value = parseFloat(JSON.parse(line.split(' ')[1]).data.p);
      // Do something with the value
      console.log(value);
      break; // Stop after the first line
    } catch (error) {
      console.error('Error parsing line:', error.message);
    }
  }
} catch (error) {
  console.error('Fetch error:', error.message);
} finally {
  if (response && response.body) {
    response.body.destroy(); // Close the stream
  }
}

这有助于防止潜在的资源泄漏.