使用Ballerina连接MongoDB Atlas时出现500内部服务器错误

从你给出的错误信息能定位到核心问题：

{
"timestamp": "2024-10-08T03:07:38.336267800Z",
"status": 500,
"reason": "Internal Server Error",
"message": "Exception authenticating MongoCredential{mechanism=SCRAM-SHA-256, userName='ballerina', source='Users', password=, mechanismProperties=}",
"path": "/customers",
"method": "GET"
}

关键问题点：

• 身份凭证里的password=为空，说明密码参数没正确加载或赋值
• 当前用的host=localhost和port=27017是本地MongoDB配置，不适用MongoDB Atlas集群

修复步骤： #

1. 修正MongoDB连接基础配置

MongoDB Atlas需要用集群提供的SRV地址（不是localhost），且强制要求SSL连接。更新你的可配置参数：

configurable string host = "cluster0.mongodb.net"; // 替换成你的Atlas集群SRV地址（不带mongodb+srv://前缀）
configurable int port = 27017;
configurable string username = "ballerina";
configurable string password = "你的Atlas用户密码";
configurable string database = "Users";

2. 调整MongoDB客户端初始化代码

添加SSL配置，确保凭证参数正确传递：

final mongodb:Client mongoDb = check new (
    {
        connection: {
            serverAddress: {
                host,
                port
            },
            auth: <mongodb:ScramSha256AuthCredential>{
                username,
                password,
                database
            },
            ssl: {
                enabled: true // Atlas强制要求SSL
            }
        }
    }
);

更推荐直接用Atlas提供的完整连接字符串初始化客户端：

configurable string connectionString = "mongodb+srv://ballerina:你的密码@cluster0.mongodb.net/Users?retryWrites=true&w=majority";

final mongodb:Client mongoDb = check new (connectionString);

3. 验证Atlas权限与白名单

• 确认Atlas中ballerina用户拥有Users数据库的读写权限
• 检查Atlas的IP白名单，已添加当前运行Ballerina服务的服务器IP（可临时允许所有IP用于测试）

4. 检查配置参数加载

确保可配置参数（尤其是密码）已通过环境变量、配置文件或命令行参数正确传递给Ballerina程序，避免参数为空。

修正后的完整示例代码 #

import ballerina/http;
import ballerinax/mongodb;
import ballerina/io;

// MongoDB Atlas配置
configurable string connectionString = "mongodb+srv://ballerina:你的密码@cluster0.mongodb.net/Users?retryWrites=true&w=majority";

final mongodb:Client mongoDb = check new (connectionString);

service on new http:Listener(9091) {
    private final mongodb:Database db;

    function init() returns error? {
        io:println("Connecting to database...");
        self.db = check mongoDb->getDatabase("Users");
        io:println("Connected to database.");
    }

    resource function get root() returns string {
        return "Welcome to the VitaCam backend!";
    }

    resource function get customers() returns Customer | error {
        io:println("Fetching a single customer...");
        mongodb:Collection customersCollection = check self.db->getCollection("VitaCam_Auth");
        
        Customer? customer = check customersCollection->findOne({});
        if (customer is ()) {
            return error("No customer found");
        }
        return customer;
    }
}

type Customer record {| 
    string id; 
    string name; 
    string email; 
    string address; 
    string contactNumber; 
|};

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