【问题标题】:headObject never throws an error when object doesn't exist当对象不存在时,headObject 永远不会抛出错误
【发布时间】:2021-02-25 03:13:48
【问题描述】:

我目前正在尝试检查文件是否存在,使用 Amazon s3 的 aws-sdk(更准确地说,函数 headObject)。

正如我在任何地方都可以读到的那样,这是在尝试检查文件是否存在时应该使用的函数(为了然后通过 getSignedUrl 获取其 URL),但是我不能让它工作。

看来,无论我做什么,函数 s3.headObject 都会告诉我该对象存在。我尝试检查现有项目、不存在项目,甚至是不存在的存储桶:所有这些都让我得到了完全相同的输出。我尝试了不同的调用函数的方式(异步与否,使用或不使用回调),但没有区别。

这是我如何实现对函数的调用:

var params = {
    Bucket: 'BUCKET NAME',
    Key: ""
}

// Some more code to determine file name, confirmed working

params.Key = 'FILE NAME'
try {
    s3.headObject(params)
    // Using here the file that is supposed to exist
} catch (headErr) {
    console.log("An error happened !")
    console.log(headErr)
}

我也尝试使用回调:但是,似乎从未输入过回调。这是我的代码的样子:

var params = {
    Bucket: 'BUCKET NAME',
    Key: ""
}

// Some more code to determine file name, confirmed working

params.Key = 'FILE NAME'
s3.headObject(params, function(err: any, data: any) {
    console.log("We are in the callback")
    if (err) console.log(err, err.code)
    else {   
    // Do things with file
    }
})
console.log("We are not in the callback")

使用此代码,“我们在回调中”从未出现,而“我们不在回调中”正确出现。

无论我做什么,都不会发现任何错误。 根据我对函数应该如何工作的理解,如果文件不存在,它应该抛出一个错误(然后被我的 catch 捕获),从而使我不能使用 getSignedUrl 函数创建错误的 URL。

我在这里做错了什么?

谢谢大家的回答。如果您还有其他问题,我将非常乐意尽我所能回答。

【问题讨论】:

  • 我找到了一种解决方法来确定文件是否存在(使用 axios 检查 getSignedUrl 生成的 URL,因为如果 URL 不起作用,我会收到错误 404)。但是,我仍然对为什么这不起作用感兴趣,所以我很乐意接受任何答案!
  • 你能显示完整的代码吗?在 Lambda 内部运行?带有try/catch 的版本永远不会按原样工作,因为headObject 是异步的(await s3.headObject(...).promise() 可以工作)。如果您可以提供更多背景信息,请提供更多信息。
  • 很抱歉回答迟了。我现在几乎无法显示整个代码,因为我解决了问题并继续前进,代码与原来的代码有很大不同。但是,我可以给出上下文:它不在 Lambda 中,整个代码是作为 express 处理的 API 请求的一部分执行的。这是请求的控制器。如果需要,我可以尝试提供更多信息,以帮助未来需要帮助的人。
  • 添加了一个答案,使用async/await语法检查对象存在的正确方法(返回解析为true/false的promise的函数)。
  • 我会把它标记为答案,以供将来寻找答案的人使用。谢谢!

标签: node.js amazon-s3 aws-sdk


【解决方案1】:

这是使用async/await 语法检查对象存在的正确方法:

// Returns a promise that resolves to true/false if object exists/doesn't exist
const objectExists = async (bucket, key) => {
  try {
    await s3.headObject({
      Bucket: bucket,
      Key: key,
    }).promise(); // Note the .promise() here
    return true; // headObject didn't throw, object exists
  } catch (err) {
    if (err.code === 'NotFound') {
      return false; // headObject threw with NotFound, object doesn't exist
    }
    throw err; // Rethrow other errors
  }
};

【讨论】:

  • 这行得通。我完全被困在正确的方法上。 .promise() 是缺失的部分。谢谢!
【解决方案2】:

我确实尝试了语法,但它不起作用。它在我的 lambda 函数中。

params 和 params2 是一组预定义的 bucket 和 key。

var url = s3.getSignedUrl('getObject', params);
    const objectExist = async (par) => { 
        try{
            console.log(s3.headObject(par).response); //I honestly couldn't find any 
            //section in the resoonse,
            // that make a DNE file different from a existing file.
             const ext = await s3.headObject(par).promise((resolve, reject) =>{
                  console.log("bbbbbbbbbbb");
                if(err) { // it keeps saying the err is not global variable. 
                //I am wondering why this is not defined.
                //Really had no idea of what else I could put as condition.
                    console.log("aaaa"); //never reach here.
                    return reject(false);}
                return resolve(true);
             });
             console.log(ext); //always true. 
             if(!ext){url = url = s3.getSignedUrl('getObject', params2, callback); }
            }catch(err){
                console.log("reeeeeeeeee"); //when the method failed it execute. 
                url = s3.getSignedUrl('getObject', params2, callback);
                console.log(url); //even though I am sure that params2 are valid key, but url in the log always returned undefined.
            }
      
  };
  objectExist(params);

【讨论】:

    猜你喜欢
    • 2020-06-06
    • 1970-01-01
    • 1970-01-01
    • 2021-08-10
    • 1970-01-01
    • 1970-01-01
    • 2019-12-27
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多