如何使用 Transform 流验证 Node.js 中的数据？

如何解决如何使用 Transform 流验证 Node.js 中的数据？

我想将数据从可读流传输到可写流，但要在两者之间进行验证。

就我而言：

• 可读流：http 响应作为流（Axios.post 响应作为流更具体）
• 可写流：AWS S3

Axios.post 响应采用 XML 格式。因此，这意味着可读流将读取代表 XML 的块。我将每个块转换为字符串并检查 c（开）和 DebugAgendaEventListener 闭是否可用。这两项检查都将在不同的或任意的块中完成。

如果两个开始/结束标记都正常，那么我必须将块传输到 Writable 流。

我正在编码：

<specificTag>

我还为 </specificTag> 定义了 let openTagFound: boolean: false; let closingTagFound: boolean: false; readableStream.pipe(this.validateStreamData()).pipe(writableStream); 方法，例如：

_tranform

现在，您可以看到我在以下位置使用了变量 validateStreamData()：

private validateStreamData(): Transform {
  let data = '',transformStream = new Transform();
  let openTagFound: boolean = false;
  let closingTagFound: boolean = false;
  try {
    transformStream._transform = function (chunk,_encoding,done) {
      // Keep chunk in memory
      data += chunk.toString();
      if(!openTagFound) {
        // Check whether openTag e.g <specificTag> is found,if yes
        openTagFound = true;
      }
      if(!closingTagFound) {
        // parse the chunk using parser
        // Check whether closingTag e.g </specificTag> is found,if yes
        closingTagFound = true;
      }
      // we are not writing anything out at this
      // time,only at end during _flush
      // so we don't need to call push
      done();
    };
    transformStream._flush = function (done) {
      if(openTagFound && closingTagFound) {
        this.push(data);
      }
      done();
    };
    return transformStream;
  } catch (ex) {
    this.logger.error(ex);
    transformStream.end();
    throw Error(ex);
  }
}

我想摆脱这个。我不想显式地利用内存。最终目标是从 data 获取数据并将其传输到 // Keep chunk in memory data += chunk.toString(); ，前提是我的验证成功。如果不是，则不应写入 S3。

非常感谢任何帮助。

提前致谢！！！

解决方法

所以，我最后做的是，让管道结束并保留一些标志以检查它是否有效或无效，然后 on('end') 回调，如果标志显示无效明确销毁目标对象。