调用PUT API触发异步函数上传文件至GCP Bucket无效果且无报错排查

调用PUT API /api/ddr/:ticket_id 时，预期将请求体写入本地文件后上传至GCP Bucket，但功能未按预期生效，且无任何报错信息输出。

原代码片段 #

app.put('/api/ddr/:ticket_id', (req, res) => {
    const ticket_id = req.params.ticket_id;
    const requestBody = req.body;
    if(!requestBody || !ticket_id){
        res.status(404).send({message: 'There is an error'});
    }
    var fs = require('fs');
    var writer = fs.createWriteStream(filename,{ 'flags': 'a'
    , 'encoding': null
    , 'mode': 0666
    });
    writer.write(JSON.stringify(requestBody));
    res.status(201).send('all ok');
    uploadFile().catch(console.error);
  });

  async function uploadFile() {
    await storage.bucket(bucketName).upload(filePath);
    console.log("Trying to upload file to bucket");
    console.log(`${filePath} uploaded to ${bucketName}`);
  }

问题分析 #

• 核心变量未定义：直接使用filename和filePath但未赋值，导致文件创建、上传因路径无效静默失败
• 异步操作未同步：writer.write是异步操作，未等待写入完成就调用上传，可能上传空文件；且提前返回响应，无法感知后续操作状态
• 错误处理缺失：文件写入过程的错误未监听，uploadFile的错误仅简单捕获，无法定位问题根源
• 参数校验逻辑漏洞：校验不通过时未终止函数，后续无效代码仍会执行
• 模块引入不规范：fs在请求处理函数内重复引入，不符合Node.js最佳实践

修复方案 #

// 全局引入依赖模块
const fs = require('fs');
const { promisify } = require('util');
const writeFile = promisify(fs.writeFile);

app.put('/api/ddr/:ticket_id', async (req, res) => {
    const ticket_id = req.params.ticket_id;
    const requestBody = req.body;

    // 参数校验不通过时直接返回，终止后续流程
    if(!requestBody || !ticket_id){
        return res.status(400).send({message: '缺少必要参数'});
    }

    // 基于ticket_id生成唯一文件名，避免冲突
    const filename = `${ticket_id}.json`;
    const filePath = `./${filename}`;

    try {
        // 等待文件写入完成
        await writeFile(filePath, JSON.stringify(requestBody), { encoding: 'utf8', mode: 0666 });
        // 等待文件上传至GCP Bucket完成
        await uploadFile(filePath);
        res.status(201).send('文件已创建并成功上传');
    } catch (error) {
        console.error('操作失败:', error);
        res.status(500).send({message: '内部服务器错误'});
    }
});

async function uploadFile(filePath) {
    // 确保bucketName已在全局正确配置
    await storage.bucket(bucketName).upload(filePath);
    console.log(`文件 ${filePath} 已上传至Bucket ${bucketName}`);
}

关键修改说明 #

1. 全局引入模块：将fs移至顶部全局引入，避免重复加载
2. Promise化文件操作：用promisify将fs.writeFile转为Promise，通过await确保写入完成后再执行上传
3. 明确文件路径：基于ticket_id生成唯一文件名，避免文件覆盖冲突
4. 完善参数校验：校验不通过时用return终止函数，防止无效代码执行
5. 统一错误处理：用try/catch捕获全流程错误，便于排查并返回合规HTTP状态码
6. 同步异步流程：等待写入和上传完成后再返回响应，确保操作原子性
7. 修正HTTP状态码：参数错误返回400（客户端错误），而非404（资源不存在），符合HTTP规范

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