首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >使用结构化(或protobuf消息)作为数据更新Golang中的修复文档

使用结构化(或protobuf消息)作为数据更新Golang中的修复文档
EN

Stack Overflow用户
提问于 2020-10-30 12:57:55
回答 1查看 1.2K关注 0票数 1

考虑到以下API:

代码语言:javascript
复制
syntax = "proto3";

service FooService {
  rpc UpdateFoo(UpdateFooRequest) returns (Foo) {}
}

message Foo {
  string name = 1;
  string description = 2;
  string action = 3;
}

message UpdateFooRequest {
  Foo foo = 1;
  // The list of fields to be updated. For the `FieldMask` definition,
  // see https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#fieldmask
  google.protobuf.FieldMask update_mask = 2;
}

此API与后端Firestore "foos“集合对话。

执行工作在戈朗进行。套餐有一个Update()方法,但它需要提供一个firestore.Update结构列表:

代码语言:javascript
复制
type Update struct {
    Path      string // Will be split on dots, and must not contain any of "˜*/[]".
    FieldPath FieldPath
    Value     interface{}
}

我在编写RPC UpdateFoo的实现时遇到了问题:我无法轻松地构造firestore.Update结构。同时,我希望确保在中提供的路径是有效的。

这就是我想要做的:

代码语言:javascript
复制
func (s *Server) UpdateFoo(ctx context.Context, req *pb.UpdateFooRequest) (*pb.Foo, error) {

var updates []firestore.Update
// Loop all paths in the update_mask
for _, p := range req.GetUpdateMask().GetPaths() {
   // Check that path is valid field of Foo message.
   // How to do this?
   ...
   ...
   if path is not valid {
       return nil, status.Errorf(codes.InvalidArgument, "invalid path %s", p)
   }
   // When path is valid, I need to take the value from the req.GetFoo() message
   // How to do this?
   newValue := req.GetFoo().Get????<this is p variable>

   update = append(update, &firestore.Update{Path: p, Value: newValue}
}

任何提示都将不胜感激。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-11-13 06:54:18

我遇到了一个类似的问题,试图在Golang使用与protobuf一起使用的防火墙。似乎不支持使用proto字段掩码和结构来进行更新。

这里有一个Set现场掩码-实用程序的解决方案

代码语言:javascript
复制
import (
  "github.com/golang/protobuf/protoc-gen-go/generator"
  fieldmask_utils "github.com/mennanov/fieldmask-utils"
)

var (
  id      string
  request UpdateFooRequest
)

mask, err: = fieldmask_utils.MaskFromProtoFieldMask(request.FieldMask, generator.CamelCase)
// handle err...

m := make(map[string]interface{}) // a map to copy to
err := fieldmask_utils.StructToMap(mask, request.Foo, m)
// handle err..

_, err = r.client.Collection(r.collection).Doc(id).Set(ctx, m, firestore.MergeAll)
// handle err..
票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/64608798

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档