ChatGPT生成文件下载技术指南：从API调用到本地存储的完整实现

1次阅读

共计 2324 个字符，预计需要花费 6 分钟才能阅读完成。

当通过 ChatGPT API 生成文件（如 CSV 报告或 PDF 文档）时，API 返回的数据结构通常具有以下特点：

数据体量可能极大（如百万行 CSV），直接内存载入易导致溢出
响应可能是流式传输（chunked encoding），需要特殊处理
网络波动可能导致传输中断，缺乏重试机制会丢失进度

常见问题包括：

内存爆炸：一次性读取大文件响应导致 Node.js 进程 OOM 崩溃
超时中断：默认 HTTP 客户端超时设置不满足大文件下载需求
文件名缺失：API 返回的二进制流缺少原始文件名元数据

方案类型	内存峰值	耗时	失败恢复
直接下载	1.2GB	78s	不可续传
流式处理	15MB	82s	支持续传

文件名自动获取 ：解析Content-Disposition 响应头

Content-Disposition: attachment; filename="report_2023.csv"

分块下载优化：
使用 HTTP Range 头实现分段请求
并行下载提高吞吐量

import aiohttp
import asyncio

async def download_file(url, save_path):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as resp:
            # 获取原始文件名
            content_disp = resp.headers.get('Content-Disposition')
            filename = content_disp.split('filename=')[1].strip('"')

            # 流式写入
            chunk_size = 1024 * 1024  # 1MB 缓冲区
            with open(save_path, 'wb') as fd:
                while True:
                    chunk = await resp.content.read(chunk_size)
                    if not chunk:
                        break
                    fd.write(chunk)

# 使用示例
asyncio.run(download_file('https://api.openai.com/v1/files/123', 'report.csv'))

const fs = require('fs');
const axios = require('axios');

async function downloadFile(url, savePath) {const writer = fs.createWriteStream(savePath);

  const response = await axios({
    url,
    method: 'GET',
    responseType: 'stream',
    onDownloadProgress: (progress) => {console.log(` 下载进度: ${Math.round(progress.progress * 100)}%`);
    }
  });

  // 处理文件名
  const contentDisposition = response.headers['content-disposition'];
  const fileNameMatch = contentDisposition.match(/filename="?(.+)"?/);
  const fileName = fileNameMatch ? fileNameMatch[1] : 'default.bin';

  response.data.pipe(writer);

  return new Promise((resolve, reject) => {writer.on('finish', resolve);
    writer.on('error', reject);
  });
}

// 使用示例
downloadFile('https://api.openai.com/v1/files/123', './downloads/report.pdf');

记录已下载的字节位置（resume.txt）
后续请求添加 Range 头：
```
Range: bytes=102400-
```
校验文件完整性（MD5/SHA1）

操作类型	NTFS (Windows)	ext4 (Linux)	APFS (macOS)
小文件写入	中等	快	极快
大文件追加	快	极快	快

import hashlib

def verify_file(file_path, expected_md5):
    md5_hash = hashlib.md5()
    with open(file_path, "rb") as f:
        for chunk in iter(lambda: f.read(4096), b""):
            md5_hash.update(chunk)
    return md5_hash.hexdigest() == expected_md5