GetCheckpoint gRPC Method

参数

sequence_number

字符串

正在加载...

摘要

字符串

正在加载...

read_mask

对象

正在加载...

paths

数组

正在加载...

退货

checkpoint

对象

正在加载...

sequenceNumber

字符串

正在加载...

摘要

字符串

正在加载...

请求

1
grpcurl \
2
  -import-path . \
3
  -proto sui/rpc/v2/ledger_service.proto \
4
  -H "x-token: YOUR_TOKEN_VALUE" \
5
  -d '{
6
    "sequence_number": "1000",
7
    "read_mask": {
8
      "paths": [
9
        "sequence_number",
10
        "digest"
11
      ]
12
    }
13
  }' \
14
  docs-demo.mainnet.quiknode.pro:9000 \
15
  sui.rpc.v2.LedgerService/GetCheckpoint
16

1
grpcurl \
2
  -import-path . \
3
  -proto sui/rpc/v2/ledger_service.proto \
4
  -H "x-token: YOUR_TOKEN_VALUE" \
5
  -d '{
6
    "sequence_number": "1000",
7
    "read_mask": {
8
      "paths": [
9
        "sequence_number",
10
        "digest"
11
      ]
12
    }
13
  }' \
14
  docs-demo.mainnet.quiknode.pro:9000 \
15
  sui.rpc.v2.LedgerService/GetCheckpoint
16

1
包 main
2

3
import (
4
	"上下文"
5
	"crypto/tls"
6
	"encoding/json"
7
	"fmt"
8
	“日志”
9
	“时间”
10

11
	"google.golang.grpc"
12
	"google.golang.grpc"
13
	"google.golang.org/protobuf/encoding/protojson"
14
	"google.golang.org/protobuf/types/known/fieldmaskpb"
15

16
	pb "sui" // 您生成的 .pb.go 文件路径
17
)
18

19
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
20
// For eg: QN Endpoint: https://docs-demo.sui-mainnet.quiknode.pro/abcde123456789
21
// endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
22
// token will be : abcde123456789
23

24
var (
25
	token    = "您的令牌编号"
26
	endpoint = "您的QN端点:9000"
27
)
28

29
// Auth structure for x-token
30
类型 auth 结构体 {
31
	token 字符串
32
}
33

34
func (a *auth) GetRequestMetadata(ctx 上下文.Context, uri ...字符串) (map[字符串]字符串, error) {
35
	返回 map[字符串]字符串{
36
		“x-token”: a.令牌,
37
	}, nil
38
}
39

40
func (a *auth) RequireTransportSecurity() bool {
41
	返回 true
42
}
43

44
func main() {
45
	// TLS credentials
46
	creds := credentials.NewTLS(&tls.Config{})
47
	opts := []grpc.DialOption{
48
		grpc.WithTransportCredentials(creds)，
49
		grpc.WithPerRPCCredentials(&auth{令牌}),
50
	}
51

52
	conn, err := grpc.Dial(endpoint, opts...)
53
	如果 err != nil {
54
		log.Fatalf("连接失败：%v", err)
55
	}
56
	推迟 conn.关闭()
57

58
	client := pb.NewLedgerServiceClient(conn)
59

60
	// Request for checkpoint with sequence_number = 1000
61
	seq := uint64(1000)
62
	req := &pb.GetCheckpointRequest{
63
		CheckpointId: &pb.GetCheckpointRequest_SequenceNumber{
64
			SequenceNumber: seq,
65
		},
66
		ReadMask: &fieldmaskpb.FieldMask{
67
			Paths: []string{"sequence_number", "digest"},
68
		},
69
	}
70

71
	ctx, 取消 := context.带超时(context.Background(), 10*时间.第二次)
72
	推迟 取消()
73

74
	resp, err := client.GetCheckpoint(ctx, req)
75
	如果 err != nil {
76
		log.Fatalf("GetCheckpoint failed: %v", err)
77
	}
78

79
	marshaler := protojson.MarshalOptions{
80
		UseProtoNames:   true,
81
		EmitUnpopulated: true,
82
		缩进:          "  ",
83
	}
84

85
	jsonBytes, err := marshaler.Marshal(resp)
86
	如果 err != nil {
87
		log.Fatalf(“序列化失败：%v”, err)
88
	}
89

90
	var pretty map[字符串]接口{}
91
	if err := json.Unmarshal(jsonBytes, &pretty); err != nil {
92
		log.Fatalf("Failed to unmarshal: %v", err)
93
	}
94

95
	formatted, _ := json.MarshalIndent(pretty, "", "  ")
96
	fmt.Println(string(formatted))
97
}
98

1
包 main
2

3
import (
4
	"上下文"
5
	"crypto/tls"
6
	"encoding/json"
7
	"fmt"
8
	“日志”
9
	“时间”
10

11
	"google.golang.grpc"
12
	"google.golang.grpc"
13
	"google.golang.org/protobuf/encoding/protojson"
14
	"google.golang.org/protobuf/types/known/fieldmaskpb"
15

16
	pb "sui" // 您生成的 .pb.go 文件路径
17
)
18

19
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
20
// For eg: QN Endpoint: https://docs-demo.sui-mainnet.quiknode.pro/abcde123456789
21
// endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
22
// token will be : abcde123456789
23

24
var (
25
	token    = "您的令牌编号"
26
	endpoint = "您的QN端点:9000"
27
)
28

29
// Auth structure for x-token
30
类型 auth 结构体 {
31
	token 字符串
32
}
33

34
func (a *auth) GetRequestMetadata(ctx 上下文.Context, uri ...字符串) (map[字符串]字符串, error) {
35
	返回 map[字符串]字符串{
36
		“x-token”: a.令牌,
37
	}, nil
38
}
39

40
func (a *auth) RequireTransportSecurity() bool {
41
	返回 true
42
}
43

44
func main() {
45
	// TLS credentials
46
	creds := credentials.NewTLS(&tls.Config{})
47
	opts := []grpc.DialOption{
48
		grpc.WithTransportCredentials(creds)，
49
		grpc.WithPerRPCCredentials(&auth{令牌}),
50
	}
51

52
	conn, err := grpc.Dial(endpoint, opts...)
53
	如果 err != nil {
54
		log.Fatalf("连接失败：%v", err)
55
	}
56
	推迟 conn.关闭()
57

58
	client := pb.NewLedgerServiceClient(conn)
59

60
	// Request for checkpoint with sequence_number = 1000
61
	seq := uint64(1000)
62
	req := &pb.GetCheckpointRequest{
63
		CheckpointId: &pb.GetCheckpointRequest_SequenceNumber{
64
			SequenceNumber: seq,
65
		},
66
		ReadMask: &fieldmaskpb.FieldMask{
67
			Paths: []string{"sequence_number", "digest"},
68
		},
69
	}
70

71
	ctx, 取消 := context.带超时(context.Background(), 10*时间.第二次)
72
	推迟 取消()
73

74
	resp, err := client.GetCheckpoint(ctx, req)
75
	如果 err != nil {
76
		log.Fatalf("GetCheckpoint failed: %v", err)
77
	}
78

79
	marshaler := protojson.MarshalOptions{
80
		UseProtoNames:   true,
81
		EmitUnpopulated: true,
82
		缩进:          "  ",
83
	}
84

85
	jsonBytes, err := marshaler.Marshal(resp)
86
	如果 err != nil {
87
		log.Fatalf(“序列化失败：%v”, err)
88
	}
89

90
	var pretty map[字符串]接口{}
91
	if err := json.Unmarshal(jsonBytes, &pretty); err != nil {
92
		log.Fatalf("Failed to unmarshal: %v", err)
93
	}
94

95
	formatted, _ := json.MarshalIndent(pretty, "", "  ")
96
	fmt.Println(string(formatted))
97
}
98

1
import * 作为 grpc from grpc;
2
import * 作为 protoLoader from grpc;
3
import * 作为 路径 from '路径';
4

5
const PROTO_PATH = path.join(__dirname, 'protos/proto/sui/rpc/v2/ledger_service.proto');
6

7
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
8
// For eg: QN Endpoint: https://docs-demo.sui-mainnet.quiknode.pro/abcde123456789
9
// endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
10
// token will be : abcde123456789
11

12
const endpoint = 'docs-demo.mainnet.quiknode.pro:9000';
13
const 令牌 = 'abcde123456789';
14

15
// Load protobuf definitions
16
const 包定义 = protoLoader.loadSync(PROTO_PATH, {
17
  keepCase: true,
18
  多头: 字符串,
19
  枚举: 字符串,
20
  默认值: true,
21
  oneofs: true,
22
  includeDirs: [路径.join(__dirname, 'protos/proto')],
23
});
24
const proto = grpc.loadPackageDefinition(packageDefinition) 作为 any;
25
const LedgerService = proto.sui.rpc.v2.LedgerService;
26

27
// Create secure client
28
const client = new LedgerService(endpoint, grpc.credentials.createSsl());
29

30
// Metadata for authentication
31
const 元数据 = new grpc.元数据();
32
元数据.添加('x-token', token);
33

34
const 请求 = {
35
  sequence_number: 1000, // Replace as needed
36
  read_mask: {
37
    paths: ['sequence_number', 'digest'],
38
  },
39
};
40

41
client.GetCheckpoint(request, metadata, (err: grpc.ServiceError | null, response: any) => {
42
  如果 (err) {
43
    console.error('gRPC Error:', {
44
      代码: err.代码,
45
      消息: err.消息,
46
      详细信息: err.详情,
47
    });
48
  } else {
49
    console.log('Checkpoint Response:');
50
    控制台.日志(JSON.stringify(response, null, 2));
51
  }
52
});
53

1
import * 作为 grpc from grpc;
2
import * 作为 protoLoader from grpc;
3
import * 作为 路径 from '路径';
4

5
const PROTO_PATH = path.join(__dirname, 'protos/proto/sui/rpc/v2/ledger_service.proto');
6

7
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
8
// For eg: QN Endpoint: https://docs-demo.sui-mainnet.quiknode.pro/abcde123456789
9
// endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
10
// token will be : abcde123456789
11

12
const endpoint = 'docs-demo.mainnet.quiknode.pro:9000';
13
const 令牌 = 'abcde123456789';
14

15
// Load protobuf definitions
16
const 包定义 = protoLoader.loadSync(PROTO_PATH, {
17
  keepCase: true,
18
  多头: 字符串,
19
  枚举: 字符串,
20
  默认值: true,
21
  oneofs: true,
22
  includeDirs: [路径.join(__dirname, 'protos/proto')],
23
});
24
const proto = grpc.loadPackageDefinition(packageDefinition) 作为 any;
25
const LedgerService = proto.sui.rpc.v2.LedgerService;
26

27
// Create secure client
28
const client = new LedgerService(endpoint, grpc.credentials.createSsl());
29

30
// Metadata for authentication
31
const 元数据 = new grpc.元数据();
32
元数据.添加('x-token', token);
33

34
const 请求 = {
35
  sequence_number: 1000, // Replace as needed
36
  read_mask: {
37
    paths: ['sequence_number', 'digest'],
38
  },
39
};
40

41
client.GetCheckpoint(request, metadata, (err: grpc.ServiceError | null, response: any) => {
42
  如果 (err) {
43
    console.error('gRPC Error:', {
44
      代码: err.代码,
45
      消息: err.消息,
46
      详细信息: err.详情,
47
    });
48
  } else {
49
    console.log('Checkpoint Response:');
50
    控制台.日志(JSON.stringify(response, null, 2));
51
  }
52
});
53

1
import grpc
2
导入 json
3
来源 谷歌.protobuf.field_mask_pb2 导入 FieldMask
4
来源 谷歌.protobuf.json_format import MessageToDict
5
from sui.rpc.v2 import ledger_service_pb2, ledger_service_pb2_grpc
6

7

8
def get_checkpoint():
9
    #Quicknode 由两个关键组成部分构成：endpoint 和相应的令牌
10
    # 例如：QNEndpoint：mainnet
11
    # endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
12
    # 令牌将为：abcde123456789
13

14
    endpoint = 'docs-demo.sui-mainnet.quiknode.pro:9000';
15
    token = 'abcde123456789';
16

17
    频道 = grpc.secure_channel(endpoint, grpc.ssl_channel_credentials())
18
    stub = ledger_service_pb2_grpc.LedgerServiceStub(channel)
19

20
    # You can specify a checkpoint by sequence_number or digest
21
    # Using sequence_number here as an example
22
    sequence_number = 1000  # Replace with the actual checkpoint sequence number you want to retrieve
23
    
24
    # Create a field mask to specify which fields to include in the response
25
    read_mask = 字段掩码(路径=[
26
        "sequence_number",
27
        "digest"
28
    ])
29

30
    # Prepare the GetCheckpointRequest
31
    request = ledger_service_pb2.GetCheckpointRequest(
32
        sequence_number=sequence_number,
33
        read_mask=read_mask
34
    )
35

36
    元数据 = [("x-token", token)]
37

38
    return stub.GetCheckpoint(request, metadata=metadata)
39

40

41
def parse_response_to_json(response):
42
    返回 json.dumps(
43
        MessageToDict(response, 保留_proto_字段_名称=True),
44
        缩进=2
45
    )
46

47

48
def main():
49
    试一试：
50
        response = get_checkpoint()
51
        打印(parse_response_to_json(response))
52
    除了 grpc。RpcError 作为 e:
53
        print(f"{e.code().name}: {e.details()}")
54

55

56
如果 __name__ == "__main__":
57
    主()
58

1
import grpc
2
导入 json
3
来源 谷歌.protobuf.field_mask_pb2 导入 FieldMask
4
来源 谷歌.protobuf.json_format import MessageToDict
5
from sui.rpc.v2 import ledger_service_pb2, ledger_service_pb2_grpc
6

7

8
def get_checkpoint():
9
    #Quicknode 由两个关键组成部分构成：endpoint 和相应的令牌
10
    # 例如：QNEndpoint：mainnet
11
    # endpoint will be: docs-demo.sui-mainnet.quiknode.pro:9000  {9000 is the port number for Sui gRPC}
12
    # 令牌将为：abcde123456789
13

14
    endpoint = 'docs-demo.sui-mainnet.quiknode.pro:9000';
15
    token = 'abcde123456789';
16

17
    频道 = grpc.secure_channel(endpoint, grpc.ssl_channel_credentials())
18
    stub = ledger_service_pb2_grpc.LedgerServiceStub(channel)
19

20
    # You can specify a checkpoint by sequence_number or digest
21
    # Using sequence_number here as an example
22
    sequence_number = 1000  # Replace with the actual checkpoint sequence number you want to retrieve
23
    
24
    # Create a field mask to specify which fields to include in the response
25
    read_mask = 字段掩码(路径=[
26
        "sequence_number",
27
        "digest"
28
    ])
29

30
    # Prepare the GetCheckpointRequest
31
    request = ledger_service_pb2.GetCheckpointRequest(
32
        sequence_number=sequence_number,
33
        read_mask=read_mask
34
    )
35

36
    元数据 = [("x-token", token)]
37

38
    return stub.GetCheckpoint(request, metadata=metadata)
39

40

41
def parse_response_to_json(response):
42
    返回 json.dumps(
43
        MessageToDict(response, 保留_proto_字段_名称=True),
44
        缩进=2
45
    )
46

47

48
def main():
49
    试一试：
50
        response = get_checkpoint()
51
        打印(parse_response_to_json(response))
52
    除了 grpc。RpcError 作为 e:
53
        print(f"{e.code().name}: {e.details()}")
54

55

56
如果 __name__ == "__main__":
57
    主()
58

还没有账号吗？

endpoint 几秒钟endpoint 创建您的Quicknode endpoint ，并开始构建

免费开始使用