如何用pipeThrough/pipeTo转换后流式上传至Azure Blob？

核心问题在于你混淆了Web Streams API和Azure Blob SDK的uploadStream适配逻辑——uploadStream支持直接传入异步迭代器，不需要自己实现WritableStream来中转。

修正后的代码可以直接将处理后的Web ReadableStream转换为异步迭代器，传给uploadStream：

export const generate = async (iterable) => {
  // 构建完整的Web Stream处理管道
  const processedStream = ReadableStream.from(iterable)
    .pipeThrough(new TextDecoderStream())
    .pipeThrough(new MyTransformer())
    .pipeThrough(new CompressionStream('gzip'));

  // 将Web ReadableStream转换为异步迭代器，传给uploadStream
  await blockBlobClient.uploadStream(
    processedStream,
    undefined, // 块大小，使用默认值（4MB）
    undefined, // 并发上传的块数，使用默认值
    {
      blobHTTPHeaders: { blobContentType: 'application/gzip' } // 按需设置Blob的Content-Type
    }
  );
};

关键说明 #

• Web Streams的ReadableStream原生实现了Symbol.asyncIterator接口，可直接作为uploadStream的输入，SDK会自动处理迭代器的消费逻辑。
• 无需自定义MyWriter这类WritableStream，uploadStream已经封装了分块上传、重试等所有写入Blob的底层逻辑。
• 若需优化上传性能，可手动传入块大小（如4 * 1024 * 1024即4MB）和并发数参数。

内容的提问来源于stack exchange，提问作者Dob