草庐IT

google-realtime-api

全部标签

api - 如何从 HTTP 处理程序中的 URL 获取参数

我正在开发一个endpoint/crypto/rates接受两个货币“符号”作为输入的网络服务应用程序。web服务应该在数据库中搜索这些字符之间的货币兑换数据,如果数据库中没有值,或者时间戳值与当前值相差超过1分钟,则向服务API发出请求:https://min-api.cryptocompare.com/documentation所以,我创建了结构和go-chi路由器。但我不知道如何构建一个工作处理程序来从URL获取参数,例如:https://min-api.cryptocompare.com/data/price?fsym=BTC&tsyms=USDpackagemainimpor

google-app-engine - 如何使用结构数组实现 google datastore propertyloadsaver

当你有一个结构数组时,你如何为谷歌数据存储实现Load()和Save()?这显然是可能的,但如何实现呢?首先,当您允许数据​​存储本身使用Phone对象列表序列化一个Person时,您可以使用反射来查看它在内部创建了一个列表>*datastore.Entity对象:packagemainimport("fmt""reflect""cloud.google.com/go/datastore")typePhonestruct{TypestringNumberstring}typePersonstruct{NamestringPhone[]Phone}funcmain(){person:=P

go - 使用 google.protobuf.Timestamp 在 Go 中解析具有时区偏移的日期时间戳

我正在创建一个将使用GRPC和protobuf的Go应用程序。我的RPC服务应接收包含google.protobuf.Timestamp类型的消息,对其进行解析并最终将其保存在数据库中或对其执行更多操作。对于google.protobuf.Timestamp类型的有效输入,我感到很困惑。我希望对带有时区偏移量的日期时间戳使用以下格式。2019-02-15T13:00:00+01:00这是我正在使用的原型(prototype)文件。syntax="proto3"packageexample;import"google/protobuf/timestamp.proto"serviceTes

go - 如何使用go客户端查询kubernetes自定义api(networking.gke.io/v1beta1)?

我想用gke玩kubernetesapi。但是gke使用特殊的api(networking.gke.io/v1beta1)。我想查询它,但是kubernetes的go-client没有这个api。如何查询?我尝试了RESTAPI,但完全不知道如何使用它,而且文档也不清楚。 最佳答案 GKE网络api和客户端在此repo中:gke-managed-certs客户端在这个包中:/pkg/clients 关于go-如何使用go客户端查询kubernetes自定义api(networking.g

google-app-engine - 在 Google App Engine 上从 main.go 传递出去时上下文值发生变化

有一个问题,当我将context.Context传递给GoogleAppEngine上的另一个包后,我不知道为什么会发生更改。以下代码在AppEngine上运行时运行良好:packagemainimport("net/http""log""google.golang.org/appengine")funcmain(){http.HandleFunc("/",myHandler)appengine.Main()}funcmyHandler(whttp.ResponseWriter,r*http.Request){ctx:=r.Context()account,err:=appengine

go - 如何从集群内 client-go api 调用中检索 kubectl describe pods <namespace> 中的所有数据

我需要获取一些pod信息,这些信息将用于一些将在集群内运行的单元测试。我需要kubectldescribepo提供的所有信息,但来自集群api调用。我有一些工作代码可以对apis/metrics.k8s.io/v1beta1/pods进行api调用,并在minikube上安装了metrics-server进行测试,这一切正常并给我这样的输出:Namespace:kube-systemPodname:heapster-rgnljSelfLink:/apis/metrics.k8s.io/v1beta1/namespaces/kube-system/pods/heapster-rgnljC

go - Apache Beam - 使用 Go SDK 进行 API 调用的批处理元素?

我正在使用GoSDK构建Beam管道。我必须通过调用云端某处的ML模型来丰富数据。由于我要处理很多元素,我不能只对每个元素进行API调用,这会引入巨大的延迟。我需要发送一批元素。我知道在python中有一个BatchElements()PTransform,如何在Go中制作类似的东西? 最佳答案 目前BeamGoSDK中没有这样的转换。您需要翻译GroupIntoBatches[1,2]实现到Go代码中。这将是对ApacheBeam的宝贵贡献,因此如果您这样做,请贡献它。 关于go-Ap

google-app-engine - 使用 GO 在 appengine 上调用 channel.Create 时出错

我正在使用ChannelApiGoReference中的示例代码.当我运行时,出现以下错误:channel.Create::调用错误1:调用/channel.CreateChannel没有注册我找不到任何引用资料。有人知道吗? 最佳答案 根据https://groups.google.com/forum/#!topic/google-appengine-go/cetKWCkoHfg这是AppEngine运行时中的一个已知错误:http://code.google.com/p/googleappengine/issues/detail

eclipse - 如何将外部包添加到 Google App Engine 的 GoClipse 项目?

我编译了Goauth,这样我就可以在我的GoGoogleAppEngine项目中使用OAuth。我应该把goauth.a文件放在哪里,这样我既可以在项目中使用它,又可以在部署到GAE服务器时使用它?如果我把它放在$GOROOT/pkg的子文件夹中,我可以让它在本地工作,但是在部署时编译时找不到它。GoClipse设置了一个包含很多文件夹的项目,我不太确定它们的用途是什么,我应该把goauth.a放在哪里以及如何导入它? 最佳答案 为了解决这个问题,我最终在我的应用程序的目录树中包含了包的源代码,正如google-appengine-

http - Go 中的 Google App Engine 自定义 IP 端口

我想用Go在GAE上创建一个网络应用程序,我需要它来监听自定义端口。我该如何设置?我尝试在沙箱中使用http.ListenAndServe(":12345",nil),但在我的控制台中得到了这个:WARNING2011-10-0720:01:01,252urlfetch_stub.py:108]Nosslpackagefound.urlfetchwillnotbeabletovalidateSSLcertificates.INFO2011-10-0720:01:01,847appengine_rpc.py:159]Server:appengine.google.comINFO2011-