如何通过go应用程序在K8s中连接mongodb

Question

我有一个mongodb服务启动和运行。我端口转发到本地访问它，同时，我尝试检查与go应用程序的连接。但我得到下面的错误。

panic: error parsing uri: lookup _mongodb._tcp.localhost on 8.8.8.8:53: no such host

左前:

kubectl port-forward service/mongodb-svc 27017:27017

应用程序:

package main
import (
"context"
"fmt"
//"log"
"time"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/readpref"
)
func main() {
username := "username"
address := "localhost"
password := "password"
// Replace the uri string with your MongoDB deployment's connection string.
uri := "mongodb+srv://" + username + ":" + password + "@" + address + "/admin?w=majority"
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
client, err := mongo.Connect(ctx, options.Client().ApplyURI(uri))
if err != nil {
panic(err)
}
defer func() {
if err = client.Disconnect(ctx); err != nil {
panic(err)
}
}()
// Ping the primary
if err := client.Ping(ctx, readpref.Primary()); err != nil {
panic(err)
}
fmt.Println("Successfully connected and pinged.")
}

Answer 1

您的客户端正在尝试DNS服务查找，因为您在URI中指定了+srv连接类型。停止这样做并使用正确的连接字符串。我们确实支持集群内，但不是通过端口转发。我怀疑您正在尝试混合和匹配集群内和集群外的教程。你不能那样做。