如何解决atlas mongodb 无服务器和 aws lambda 连接问题？

我在 atlas (https://www.mongodb.com/serverless) 上有一个无服务器数据库。我用的是ATLAS推荐的连接字符串：

mongodb+srv://<username>:<password>@xyz.esxbh.mongodb.net/myFirstDatabase?retryWrites=true&w=majority

但是，一旦我尝试创建记录，就会收到以下错误：

{"errorType":"Runtime.UnhandledPromiseRejection","errorMessage":"MongoParseError: Text record must only set `authSource` or `replicaset`","reason":{"errorType":"MongoParseError","errorMessage":"Text record must only set `authSource` or `replicaset`","name":"MongoParseError","stack":["MongoParseError: Text record must only set `authSource` or `replicaset`","

我认为连接字符串不正确，另一方面，服务器的 dns 条目确实回复了 2 个服务器。

我尝试删除 ''+srv'' 部分，但是在那种情况下，来自 mongoose 的保存函数会永远挂起，使 lambda 函数超时。

我在谷歌上找不到任何类似的问题。

来自DNS服务器的TXT条目记录显示：

"TXT    "authSource=admin&loadBalanced=true"

您如何配置无服务器数据库以使其正常工作？

产生错误的代码依赖于mongoose，如下：

        try {
          const customer = new Customer(cust);
          console.log(''new cusotmer created'');
          const returnedCustomer = await customer.save();
          console.log(returnedCustomer);
          return serverResponse(200,returnedCustomer);
        } catch(err){
          console.log(err);
          return errorHandler(500,err)
        }

似乎与数据库的连接没问题：

try {
    await dbTools.connectMongoose();
    console.log(''*** connected ***'');

} catch(err){
    console.log(''error when connecting'');
    return errorHandler(500,err);
}

现在，看看源代码，没什么太复杂的：

if (Object.keys(record).some(key => key !== ''authSource'' && key !== ''replicaset'')) {
  return callback(
    new MongoParseError(''Text record must only set `authSource` or `replicaset`'')
  );
}

我现在真的很难理解出了什么问题，因为 authSource 似乎存在于 TXT 记录中。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

const toggleChecked = ({ _id, isChecked }) => {
  TasksCollection.update(_id, {
    $set: {
      isChecked: !isChecked
    }
  })
};

func updateOneMovie(movieId string) model.Netflix {
    id, _ := primitive.ObjectIDFromHex(movieId)
    filter := bson.M{"_id": id}
    update := bson.M{"$set": bson.M{"watched": bson.M{"$not": "$watched"}}}
    var updateResult model.Netflix

    result, err := collection.UpdateOne(context.Background(), filter, update)

    err = collection.FindOne(context.Background(), filter).Decode(&updateResult)

    if err != nil {
        log.Fatal(err)
    }

    fmt.Println(result)
    return updateResult
}

filter := bson.M{"_id": id}
update := []any{
    bson.M{"$set": bson.M{"watched": bson.M{"$not": "$watched"}}}
}

DATABASES = {
    ''default'': {
        ''ENGINE'': ''djongo'',''NAME'': ''DBProd'',''CLIENT'': {
          ''host'': "mongodb+srv://XXX:YYY@ZZZ.pc4rx.mongodb.net/DBProd?retryWrites=true&w=majority",}
    }
}