Невозможно использовать транзакции mongodb, используя драйвер mongo go - PullRequest
Новая
       28

Невозможно использовать транзакции mongodb, используя драйвер mongo go

1 голос
/ 29 мая 2019

Я создал набор реплик mongodb. Я могу запускать транзакции из оболочки Монго. Но когда я пытаюсь сделать это, используя mongo-go-driver, я всегда получаю эту ошибку (IllegalOperation) Transaction numbers are only allowed on a replica set member or mongos. Я не уверен, где я иду не так. Я использую это как ссылку https://github.com/simagix/mongo-go-examples/blob/master/examples/transaction_test.go.

Я создаю клиента вот так 

client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017,localhost:27018,localhost:27019?replicaSet=rs"))

Я могу подключиться к отдельным экземплярам mongodb, но не к реплике. Это транзакция, которую я пытаюсь запустить 

var session mongo.Session

coll := db.Collection("collectionname")

if session, err = client.StartSession(); err != nil {
    return "", fmt.Errorf("Could not start session: %q", err)
}

if err = session.StartTransaction(); err != nil {
    return "", fmt.Errorf("Could not start Transaction: %q", err)
}

if err = mongo.WithSession(ctx, session, func(sc md.SessionContext) error {

    newVal, err = coll.InsertOne(sc, val) // some val that I have
    if err != nil {
        sc.AbortTransaction(sc)
        return fmt.Errorf("Error during New address creation, aborting: %q", err)
    }

    if err = sc.CommitTransaction(sc); err != nil {
        return fmt.Errorf("Error While commiting New address Transaction: %q", err)
    }
    return nil
}); err != nil {
    return "", err
}

session.EndSession(ctx)

Есть ли что-то, чего мне не хватает. Может быть, есть другой пример, на который я могу сослаться? Спасибо за помощь / предложения.

...