我正在研究Dgraph
和Go
集成。我正在尝试访问Dgraph
查询,Go
为此我正在使用github.com/dgraph-io/dgo
库。
这是代码:
package main
import (
"bytes"
"context"
"fmt"
"io/ioutil"
"log"
"github.com/dgraph-io/dgo"
"github.com/dgraph-io/dgo/protos/api"
"google.golang.org/grpc"
)
func main() {
query := `{
people(func: has(name)) {
name
follows{
name
}
}
}`
conn, err := grpc.Dial("x.x.x.x:8000", grpc.WithInsecure())
if err != nil {
log.Fatal(err)
}
ctx := context.Background()
dgraphClient := dgo.NewDgraphClient(api.NewDgraphClient(conn))
txn := dgraphClient.NewTxn()
txn.Query(ctx, query)
request := &api.Request{
Query: query,
}
response, err := txn.Do(ctx, request)
if err != nil {
log.Fatal(err)
}
fmt.Println(string(response.Json))
}
我收到错误rpc error: code = Unavailable desc = connection closed当我试图运行代码时。由于我是新手,Go
而且DGraph Database
我的知识非常有限。
任何人都可以帮助解决此错误需要进行哪些确切的更改。