长效grpc流媒体RPC及退避策略
长效gRPC流媒体RPC是一种基于gRPC协议的流媒体远程过程调用（RPC）机制。它提供了高效、可靠的通信方式，可以用于在分布式系统中进行实时音视频传输、多媒体处理等任务。
gRPC是一种高性能、开源的跨语言RPC框架，它使用Protocol Buffers作为接口定义语言（IDL），支持多种编程语言。gRPC基于HTTP/2协议，并使用protobuf进行序列化，提供了高效的数据传输和序列化能力。
长效gRPC流媒体RPC具有以下优势：
- 高性能：gRPC使用HTTP/2协议进行通信，可以复用TCP连接、多路复用请求，减少了网络传输的开销，提供了更高的性能。
- 可靠性：gRPC使用基于流的传输方式，可以保证数据的有序性和完整性，提供了可靠的数据传输机制。
- 跨语言支持：gRPC支持多种编程语言，可以实现跨平台、跨语言的通信和协作。
- 灵活的扩展性：gRPC使用Protocol Buffers进行数据序列化，支持动态更新接口定义，可以方便地进行版本升级和扩展。
- 易于使用：gRPC提供了丰富的工具和库，可以简化开发过程，提高开发效率。
长效gRPC流媒体RPC适用于以下场景：
- 实时音视频传输：长效gRPC流媒体RPC可以用于构建实时音视频通信系统，实现高质量、低延迟的音视频传输。
- 多媒体处理：长效gRPC流媒体RPC可以用于构建多媒体处理系统，实现对音视频数据的编解码、转码、剪辑等操作。
- 分布式计算：长效gRPC流媒体RPC可以用于构建分布式计算系统，实现任务的分发和并行计算。
- 物联网：长效gRPC流媒体RPC可以用于构建物联网系统，实现设备之间的数据传输和通信。
- 人工智能：长效gRPC流媒体RPC可以用于构建人工智能系统，实现模型的训练和推理过程。
腾讯云提供了一系列与gRPC相关的产品和服务，推荐的产品包括：
- 腾讯云容器服务TKE：提供容器编排和管理能力，可以用于部署和管理gRPC服务。
- 腾讯云云原生应用管理TAM：提供云原生应用的开发、构建、部署和运维能力，支持gRPC应用的全生命周期管理。
- 腾讯云CDN：提供全球加速服务，可以加速gRPC服务的全球访问速度。
- 腾讯云函数计算SCF：提供事件驱动的无服务器计算服务，可以用于构建无服务器的gRPC应用。
更多关于腾讯云相关产品和服务的详细介绍，请参考腾讯云官方文档：
- 腾讯云容器服务TKE：https://cloud.tencent.com/product/tke
- 腾讯云云原生应用管理TAM：https://cloud.tencent.com/product/tam
- 腾讯云CDN：https://cloud.tencent.com/product/cdn
- 腾讯云函数计算SCF：https://cloud.tencent.com/product/scf
相关·内容
我正在尝试为grpc构建一个示例android应用程序。
hello_world.proto文件如下所示：
syntax = "proto3";
package helloworld;
option java_multiple_files = true;
option java_package = "io.github.caio.grpc";
option java_outer_classname = "HelloWorldProto";
// The greeting service definition.
service Greete
浏览 2提问于2016-04-20得票数 1
回答已采纳
大家好，我正在kubernetes中设置fabric default first-network。但是当我实例化链码时，它给了我错误。请检查以下是我的同行日志。
2019-07-22 07:25:02.134 UTC [endorser] SimulateProposal -> ERRO 066 [mychannel][c4b4e2ae] failed to invoke chaincode name:"lscc" , error: container exited with 0
github.com/hyperledger/fabric/core/chaincode
浏览 278提问于2019-07-24得票数 0
我正在为GRPC实现一个自定义负载均衡器，以在我的应用程序中启用客户端负载均衡。由于业务需求，我需要在负载平衡算法中使用基于响应时间的度量。 问题是，用于在负载均衡器中选择子通道的GRPC Picker接口没有任何在请求处理后调用的回调。所以我不能测量Picker中的执行时间。为了绕过这一点，我尝试使用客户端拦截器来测量RPC的确切时间，但是拦截器似乎没有任何关于作为负载平衡结果而选择的服务器地址的信息。 在GRPC中，有没有其他机制可以将负载平衡与测量RPC响应时间结合起来？
浏览 34提问于2021-10-12得票数 0
我们希望配置我们的gRPC客户端，以便在连接丢失后非常快地重新连接。(我相信将尝试在20秒后重新连接，每次尝试都会倒退到120秒。)在回顾了之后，我们尝试将grpc.initial_reconnect_backoff_ms和grpc.min_reconnect_backoff_ms设置为200。当连接丢失时，这会导致快速重新连接，但我们有时会看到(来自测试的) GRPC::Internal: 13:Completed without a response调用失败。从位于客户端和服务器之间的tcp反向代理进行日志记录，我看到一个连接持续时间略超过200 at，然后第二个连接持续时间更长。因此，看
浏览 7提问于2017-10-04得票数 0
回答已采纳
1回答
我设置了一个带流媒体的工作服务器/客户端，它在局域网上没有安全和dns的情况下就可以工作。 现在我已经准备好将其部署到一个公开的(公共)网络上，并且我第一次使用NGINX和来自letsEncrypt的服务器端证书设置了服务器，这样客户端就可以像这样连接。 creds := credentials.NewTLS(&tls.Config{
InsecureSkipVerify: true,
})
conn, err := grpc.Dial(host, grpc.WithTransportCredentials(creds)) 我想在某个时候实现身份验证，而gRPC似
浏览 29提问于2021-10-01得票数 1
回答已采纳
1回答
请帮助我理解grpc客户端连接错误处理。
我以前用过Micrsoft WCF。如果没有接受以下传入连接的服务，那么很容易尝试多次连接，然后放弃：
// this is pseudo code
int attemptCount = 0;
while (true)
try
{
client.Connect(); // exception is raised if there is not service listening for incoming connection
break;
}
catch (Exception)
浏览 0提问于2019-03-06得票数 1
我正在尝试使用基于node.js的负载均衡的haproxy负载均衡器，从单个node.js客户端对多个TCP后端的rpc调用进行负载均衡。在创建grpc客户端时，我提供了这个负载均衡器的dns-name:port，根据的说法，它应该被视为负载均衡器地址，并且应该打开与每个lb的后端服务器的子通道。但是我可以看到，打开的唯一通道是与负载均衡器，并且所有rpc仅发送到单个服务器，直到tcp空闲连接超时到达并且与新服务器建立了新的tcp连接。
我只想问一下grpc如何检测客户端是连接到负载均衡器还是连接到服务器？有没有办法告诉客户端它连接的地址是负载均衡器地址，因此它应该使用grpc-lb策略而不是
浏览 15提问于2017-08-23得票数 3
我正在创建Android应用程序，它使用gRPC与服务器进行通信。我几乎没有什么服务方法。使用简单的rpc方法进行通信没有问题，但是我对bidirectional streaming有问题。
我收到一条消息ServerToClient，然后收到错误：io.grpc.StatusRuntimeException: CANCELLED: Cancelled
这是我的服务：
service CommunicationGateway {
[...]
rpc CommunicationChannel(stream ClientToServer) returns (stream Serve
浏览 0提问于2018-09-13得票数 0
回答已采纳
1回答
目前正在阅读RPC和RMI，我对两者之间的区别感到有点困惑。
在实现RMI和例如gRPC时，语法基本相同。
它们都有确定方法、参数和响应的接口。
它们都可以在参数中发送对象(Java本机完成，C# gRPC和proto)。
它们都通过对某个对象的方法调用(基于接口)执行对服务器的请求。
那有什么区别呢？客户端和服务器之间的数据传输过程是如何发生的？
从表面上看，RMI只是RPC的一个Java实现，而gRPC是C#实现。
浏览 4提问于2021-01-09得票数 3
我正在考虑使用GRPC与DNS循环(通过dnsrr模式的码头群)。我想知道，如果启用enableRetry()时连接失败，它会路由到DNS-RR中的另一个IP吗？
浏览 1提问于2022-05-30得票数 0
回答已采纳
1回答
双向RPC调用是否会打开多个http2连接？
我正在编写一个GRPC客户端，它正在与我不拥有/控制的GRPC服务器对话。我正在使用包。有人问我这个库是否会打开到grpc端点的多个HTTP2连接，而且我对源代码还不太熟悉，无法回答这个问题。我打电话和打开流的代码如下所示
const protoLoader = require('@grpc/proto-loader')
const packageDefinition = protoLoader.loadSync(
__dirname + '/path/to/v1.proto',
{keepCase: tr
浏览 2提问于2020-03-31得票数 1
回答已采纳
1回答
我正在尝试使用python创建一个带有GCP发布/订阅的订阅服务器。根据文档，您可以在create_subscription上指定一个create_subscription arg来定制重试延迟，就像在UI中通过web所做的那样。然而，当我这样做时，我会得到错误。
Unknown field for Subscription: retry
subscriber = pubsub.SubscriberClient()
subscription_path = subscriber.subscription_path(env.GCP_PROJECT_ID, details['nam
浏览 5提问于2022-01-31得票数 0
回答已采纳
1回答
我正在考虑切换到gRPC。但是，在服务器启动时，我找不到关于gRPC行为的任何信息。如果服务器没有启动jet，那么gRPC调用会发生什么情况？当客户端和服务器同时启动时，不使用超时等等，需要考虑什么呢？
浏览 3提问于2022-07-29得票数 0
回答已采纳
我是google云平台的新手。我在google顶点AI上上传了一个模型之后，创建了一个端点。但是，当我运行示例请求中建议的预测函数(python)时，我得到了以下错误:-
Traceback (most recent call last):
File "C:\Users\My\anaconda3\lib\site-packages\google\api_core\grpc_helpers.py", line 67, in
error_remapped_callable
return callable_(*args, **kwargs)
File "C:\Users
浏览 2提问于2021-06-03得票数 1
我刚刚使用gRPC实现了一个数据库项目的分布式版本。当我尝试用makefile制作时，我一直使用protobuf和gRPC获取未定义的引用错误。make的部分输出如下。因为字数的限制，我只包括了其中的一部分。
g++ -o rundb benchmarks/ycsb_query.o benchmarks/tpcc_wl.o benchmarks/ycsb_wl.o benchmarks/ycsb_store_procedure.o benchmarks/tpcc_query.o benchmarks/tpcc_helper.o benchmarks/tpcc_store_procedure.o
浏览 0提问于2020-07-13得票数 3
最近发布的cloud.google.com/go/pubsub库(在v1.5.0中，参见)支持新的RetryPolicy服务器端功能。这方面的文档()目前为
我读过维基百科的文章，虽然它描述了离散时间的指数回退，但我看不出这篇文章与MinimumBackoff和MaximumBackoff参数有什么特别的关系。有关这方面的指导，我参考了github.com/cenkalti/backoff的文档。该库将ExponentialBackoff定义为
type ExponentialBackOff struct {
InitialInterval time.Duration
浏览 24提问于2020-07-30得票数 4
回答已采纳
我需要实现一个分布式数据库，我是基于gRPC实现的。以下是我的代码片段。sundial_sync_server.h
#ifndef SUNDIAL_GRPC_SYNC_SERVER_H
#define SUNDIAL_GRPC_SYNC_SERVER_H
#endif //SUNDIAL_GRPC_SYNC_SERVER_H
#include "sundial_grpc.grpc.pb.h"
#include "sundial_grpc.pb.h"
#include <iostream>
#include <memory>
#incl
浏览 0提问于2020-07-29得票数 1
I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_artifacts\platform\windows\workspace_csharp_ext_windows_x86\src\core\lib\surface\call.c:1802: grpc_call_start_batch(call=05BEFFD8, ops=05EFED58, nops=6, tag=05BC64E0, reserved=00000000) I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_ar
浏览 1提问于2017-08-04得票数 0
回答已采纳
1回答
有一个gRPC流服务器和客户机。客户端通过gRPC双向流拨号到服务器。服务器运行在一个昆宾女码头上。
在对kubeness服务器进行一次升级之后，当试图向流服务器发送请求时，客户端总是会收到EOF错误。我发现TCP连接是活动的。为什么？
我是否需要在grpc中调用"NewStream“API来重新创建一个新的strean？
func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
如果我在拨
浏览 2提问于2019-10-11得票数 0
1回答
我正在使用golang编写一个使用grpc的服务器处理数据流。在接收一个请求之后，我应该将这个流放到一个Chan中，然后一个goroutine处理这个请求并发送回去。但是，当我向goroutine中的客户端发信时，我会得到一个goroutine。所以我想知道我是否可以将stream传递给Channel，这个操作会关闭连接吗？
下面是协议缓冲区中的识别信息
service AsrService {
rpc Recognize(stream RecognizeRequest) returns (stream RecognizeResponse) {}
}
下面是使用grpc自动生成
ty
浏览 2提问于2021-09-15得票数 1
回答已采纳
我们使用protoc-gen-go v2 (v2是google.golang.org/protobuf，v1是github.com/golang/protobuf) 当我们试图编译我们的gRPC服务时，它告诉我们不再支持plugins，我们应该改用--go-grpc_out $ protoc --go_out=plugins=grpc:. *.proto
--go_out: protoc-gen-go: plugins are not supported; use 'protoc --go-grpc_out=...' to generate gRPC 当使用--go-grpc
浏览 136提问于2020-04-22得票数 3
1回答
更新:我发现如果我在contactRemote()中调用contactRemoteDone()，它会进行处理。但是如果我在contactRemote()的外部调用它，但紧跟在它之后，它就会抛出一个seg fault.So for(int x=0; x<10; x++){
c1->contactRemote(x,request,response[x]);
c1->contactRemoteDone(x,response[x]);
} 不起作用。 我试着写一个小程序来测试我的gRPC异步服务的实现。当我试图访问响应时，它抛出了一个seg错误，当我使用GDB进行调试时，我不能理解
浏览 75提问于2020-08-20得票数 0
我正在尝试使用google测试为我的C++ gRPC客户机编写单元测试。我同时使用同步和异步rpc，我不知道如何使用异步rpc的模拟版本。
在我的.proto文件中有：
rpc foo(EmptyMessage) returns (FooReply) {}
从这个protoc生成了同步调用和异步调用的模拟存根：
MOCK_METHOD3(foo, ::grpc::Status(::grpc::ClientContext* context, const ::EmptyMessage& request, ::FooReply* response));
MOCK_METHOD3(As
浏览 0提问于2021-09-07得票数 2
回答已采纳
1回答
我有一种奇怪的情况，消息名与我的proto定义中生成的类相同，即服务
例如: proto文件
service Dummy {
rpc Register(RegisterServiceRequest) returns Service {}
}
message Service {
string name = 1;
}
当我生成grpc服务时，它变成
pb.rb文件
module ...
module ...
class Service
include GRPC::GenericService
self.marshal_class_method =
浏览 1提问于2020-02-23得票数 0
回答已采纳
当尝试使用Google版本1.40.0解译密码字符串时，我将面临以下错误。
所用代码：
try (KeyManagementServiceClient keyManagementServiceClient = KeyManagementServiceClient.create()) {
CryptoKeyName name = CryptoKeyName.of("[PROJECT]", "[LOCATION]", "[KEY_RING]", "[CRYPTO_KEY]");
ByteString ciphertext
浏览 8提问于2020-10-06得票数 0
回答已采纳
1回答
我正在用Kotlin编写一个应用程序来连接到grpc服务器并获取数据。
下面是我的代码片段：
channel = ManagedChannelBuilder.forTarget("localhost:25001")
.usePlaintext()
.build()
stub = hello.HelloGrpc.newBlockingStub(channel)
我的GRPC服务器是down，但是我可以看到两个变量的值如下所示：
for channel = channelManagedChannelOrphanWra
浏览 3提问于2020-05-06得票数 0
回答已采纳
我正在努力学习如何在gRPC中异步使用C++。在上查看客户端示例
除非我误解了，否则我看不出有什么异步的东西被展示出来。只有一个RPC调用，它在主线程上阻塞，直到服务器处理它并将结果发回。
我需要做的是创建一个客户机，它可以进行一个RPC调用，然后在等待第一个从服务器返回的结果时启动另一个。
我不知道该怎么做。
有没有人有一个有用的例子，或者谁能描述如何实际使用gRPC异步？
它们的示例代码：
/*
*
* Copyright 2015 gRPC authors.
*
* Licensed under the Apache License, Version 2.0 (the "
浏览 3提问于2020-11-02得票数 11
回答已采纳
快速免责声明，我是gRPC和RPC的新手，所以请耐心。
我有两个gRPC服务器运行在同一个java应用程序上，Service A和Service B。Service A创建多个客户机( of Service B )，然后对Service B的各个实例进行同步调用。
服务器
Service A有一个rpc调用，由.proto文件定义为
rpc notifyPeers(NotifyPeersRequest) returns (NotifyPeersResponse);
服务器端的实现，
@Override
public void notifyPeers(NotifyPeersRequest req
浏览 3提问于2020-07-30得票数 5
回答已采纳
1回答
我使用下面的代码连接到grpc服务器，所有后续的rpc调用都使用clientConn对象。maxDelay设置为5秒。现在由于服务器上的一些问题，它不响应grpc调用。因此，我的客户每次调用rpc都要等待很长时间。我需要以不同的方式设置超时吗？ b := grpc.BackoffConfig{
MaxDelay: maxDelay,
}
clientConn, err := grpc.Dial(serverAddress, grpc.WithBackoffConfig(b), grpc.WithInsecure())
if err !
浏览 86提问于2020-09-18得票数 1
1回答
烧瓶+ gRPC故障
、、、
我有一个由apache + mod_wsgi插件在Win上运行的烧瓶API应用程序。我通过官方教程创建了grpc服务，创建了grpc服务器并将其作为win服务运行(某些win服务管理器无法再找到它)。作为grpc客户端，我使用了一个烧瓶端点：
@web.route( '/services/<service_name>', methods=[ 'POST' ] )
def run_service( service_name ):
#flask response object, little desinged
resp = EmptyRe
浏览 3提问于2020-04-23得票数 0
回答已采纳
请帮帮我，我已经试过了所有的grps设置都表明了他还需要我做什么
// client
sock, err := grpc.Dial(
config.Parser,
grpc.WithInsecure(),
grpc.WithDefaultCallOptions(
grpc.MaxCallRecvMsgSize(20*1024*1024),
grpc.MaxCallSendMsgSize(20*1024*1024)))
//...
m, err := d.Parser.UpdateSources(
ctx,
movie,
浏览 2提问于2021-10-21得票数 0
我有以下内容：
syntax = "proto3";
import "google/rpc/status.proto";
message Response {
google.rpc.Status status = 1;
}
message Request {
Type name = 1;
}
service Service {
rpc SomeMethod (Request) returns (Response);
}
我正在用节点编写一个客户端：
const path = require('path&
浏览 0提问于2018-10-12得票数 7
回答已采纳
1回答
构建我的第一个gRPC服务器应用程序。我不知道这是否是一个常见的问题，但我的rpc服务器正在变得相当大。
使用servicer，我指的是从生成的xxx_pb2_grpc.xxxServicer继承的类(至少在python中)。
目前，它有19个RPC调用。所以我的实现这些调用的类变得相当大。考虑到有些RPC调用是用于音乐播放的，有些是用于数据管理的，还有一些是用于与下载器通信的(可能还有更多)，考虑到有些RPC调用是用于音乐播放的，是否有任何方法将服务划分为逻辑段。
我可以在proto文件中创建多个service类型，但是xxx_pb2_grpc.add_xxxServicer_to_serv
浏览 2提问于2018-01-30得票数 3
回答已采纳
1回答
我在使用时遇到了一点麻烦。我正在尝试使用Java应用程序从我自己的Google下载一个电子表格。
根据Google ( )的文档，可以使用"text/ CSV“参数在csv中下载电子表格。我的问题是，当我试图下载我的文件在CSV，我是封存一个错误，但以其他格式，它的工作。
我得到的错误是：
Exception in thread "main" com.google.api.client.googleapis.json.GoogleJsonResponseException: 500 Internal Server Error
{
"code" :
浏览 3提问于2016-01-31得票数 3
回答已采纳
我正在尝试加载来自arduino-cli存储库的.proto文件。更具体地说，我加载的commands.proto依赖于同一目录中的其他几个.proto文件。 在提供给proto-loader的加载选项中，我指定了所有这些.proto依赖项的路径，但是弹出了一个错误，指出其中一个依赖项中定义的proto消息没有定义。 下面是我的代码： const grpcLib = require('grpc');
const protoLoader = require('@grpc/proto-loader');
const pathLib = require("p
浏览 100提问于2020-08-23得票数 0
回答已采纳
在我们的设置中，特使通过GRPC从控制平面消耗动态配置。控制平面发现被配置为STRICT_DNS：
- name: cplane
connect_timeout: 5s
type: STRICT_DNS
load_assignment:
cluster_name: cplane
endpoints:
- lb_endpoints:
- endpoint:
address:
socket_address:
address: control
浏览 10提问于2022-06-21得票数 0
我按照教程"Pre-training FairSeq RoBERTa on Cloud TPU using Pytorch“设置了一个可抢占(v2-8) TPU环境，并训练了我的RoBERTa模型。按照文档的说明，PyTorch环境基于torch-xla-1.6。但是，它不会像往常一样在GPU中输出任何训练日志，并且会在2-3天内(间隔12小时)抛出两次RPC故障警告(参见下文-此处删除网络端点)。 我的训练步数是161,529步。根据文档，根据我的配置，v2-8将在5个时期花费80小时。然而，我的工作似乎悬而未决。 有什么建议吗？ W 4566 tensorflow/cor
浏览 125提问于2020-09-09得票数 1
2回答
如果这个问题太天真，我很抱歉。(这里是gRPC新手)。但是，我想要理解这一点。
假设我有一个gRPC服务定义，如下所示：
service ABC {
// Update one or more entities.
rpc Write(WriteRequest) returns (WriteResponse) {
}
// Read one or more entities.
rpc Read(ReadRequest) returns (stream ReadResponse)
{
}
// Represents the bidirectional stream
浏览 2提问于2018-10-05得票数 4
回答已采纳
在创建通道和存根时，如何检查RPC客户端是否已成功连接到RPC服务器？ 我希望能够在连接失败时抛出异常或信号。我不确定什么方法有资格在这里尝试“操作”。我不想做任何我们定义的RPC调用，因为它们都有occur....unless的效果，唯一的选择是去实现一些“嗨，我在这里”的RPC方法，但这看起来很愚蠢，不是吗？ void ChatSyncClient::connect(QUrl const& endpoint)
{
disconnect();
// TODO - How do we tell if this fails?
// The com
浏览 643提问于2020-10-22得票数 1
回答已采纳
1回答
我有一个用Python语言实现的gRPC服务器，我正在从NodeJS调用一个RPC，但它给出了一个错误"Method not found“。当我使用python客户端调用时，请求成功。 stream_csv.proto syntax = "proto3";
package csv;
service Stream {
rpc csvToObject(CSVDataRequest) returns (stream CSVDataResponse) {};
rpc sayHello(HelloRequest) returns (HelloReply);
}
m
浏览 93提问于2020-10-18得票数 3
回答已采纳
2回答
按照下面的说明，我已经创建了一个grpc服务器和客户机：https://docs.microsoft.com/en-us/aspnet/core/tutorials/grpc/grpc-start?view=aspnetcore-3.0&tabs=visual-studio。 当我尝试从客户端调用服务时，客户端显示此错误消息：“发生了一个或多个错误。( status (StatusCode=Unknown，Detail="No status received"))” 服务器是这个： info: Microsoft.AspNetCore.Hosting.Diagnost
浏览 127提问于2019-06-28得票数 4
回答已采纳
1回答
我知道，当RPC调用失败时，指数退避是一件好事。到目前为止，在我的GAE/P应用程序中，我通过使用任务队列实现了指数退避：
deferred.defer(function_that_makes_RPC_call)
如果执行RPC调用的函数引发异常，那么任务队列的指数退避就会处理它，我不需要担心它。
然而，一个问题是，deferred.defer本身就是一个可能失败的RPC调用！有时我会遇到这样的错误：
DeadlineExceededError: API调用taskqueue.BulkAdd()花了很长时间才做出响应，并被取消。
因此，我似乎不能再懒惰了，不得不实现我自己的指数退避。:
浏览 3提问于2016-08-23得票数 1
回答已采纳
1回答
处理gRPC服务中的错误通常需要status消息和错误codes。两者都有两个定义：
Google定义() -为常见协议缓冲区类型生成的Go包，以及为谷歌的gRPC API生成的gRPC代码
gRPC定义() - gRPC的Go实现
用于Status和Codes定义的Go包是：
Google
现状：
代码：
gRPC
现状：
代码：
由于我是我自己的gRPC服务的客户机，而不是现有Google的客户端，所以我想使用gRPC和Code的gRPC定义。
但是，gRPC proto文件实际上是从Google 定义中复制的。见。go_package of
浏览 11提问于2021-11-03得票数 1
1回答
我在这里找些建议。usecase是一个网络设备(如路由器)，它通过gRPC执行网络操作。
假设有"n“模型对象，如路由器、接口、路由配置对象(如OSPF )等。每一次网络操作，比如最后是一个CRUD on或许多模型对象。
现在，当在gRPC服务上定义它时，似乎有两个选项：
定义通用的gRPC gRPC，如"SET“和"GET”。该参数将是对象和操作的列表。像SET(路由器，更新)，(接口，更新)..。
定义非常具体的RPC。比如"setInterfaceProperty_x"，“createOSPFInstance”。而且可能有许多这样的RPC。
浏览 0提问于2018-09-12得票数 0
我正在尝试实现异步ServerInterceptor grcp.aio.ServerInterceptor。我当前的同步ServerInterceptor看起来像这个。当我尝试使用grpc.aio.ServerInterceptor并启动服务器时，服务器代码
from grpc_opentracing import open_tracing_server_interceptor
from grpc_opentracing.grpcext import intercept_server
import PromServerInterceptor
class MyServicer():
浏览 9提问于2020-10-04得票数 2
在参数服务器分布式模式下，我正在使用tensorflow 2.1.0的估值器api训练一个模型。启动培训的代码如下：
# model_fn is defined with model logit
GATNE = tf.estimator.Estimator(model_fn=model_fn, model_dir=args.model_dir, params=model_params, config=config)
# obtain different train and eval files for different workers
# files are stored on share
浏览 10提问于2021-04-01得票数 1
回答已采纳
第一个问题，下面的背景。如何根据取消带有异步gRPC python服务器的客户端的RPC执行某些服务器端操作(例如，清理)？
在我的微服务中，我有一个asyncio gRPC服务器，它的主要RPC是双向流。
在客户端(也在使用异步)上，当我取消某项操作时，它会引发一个asyncio.CancelledError，该asyncio.CancelledError将被捕获，并且不会被grpc内核重新分配：
except asyncio.CancelledError:
_LOGGER.debug('RPC cancelled for servicer method [
浏览 2提问于2021-07-22得票数 1
回答已采纳
(M1)
操作系统: macOS BigSur(11.2)
Rails版本: 5.2.3
ruby版本: 2.5.3p105
捆绑清单：
google-protobuf (3.15.5)googleapis-common-protos-types (1.0.6)grpc (1.36.0)
$ rails c
dyld: lazy symbol binding failed: Symbol not found: _grpc_set_ssl_roots_override_callback
Referenced from: /Users/[hostname]/.rvm/gems/ruby-2.5
浏览 1提问于2021-03-08得票数 3
1回答
我有一个模型，它接受任意长度的数据流并执行分类。我使用Tensorflow服务来侦听gRPC请求，并在经过训练的模型上执行分类。
Google具有功能，在使用gRPC请求时可用，它“允许您将音频流传输到Cloud，并在处理音频时实时接收语音识别结果流”。
我相信这是可能的，因为中描述的双向流RPC“服务器和客户端可以”乒乓“：服务器收到请求，然后返回响应，然后客户端根据响应发送另一个请求，等等。
所以，现在我想知道我是否能够实现类似的流媒体识别，使用Tensorflow服务。在TF服务的正式文档中(除非我遗漏了什么)，我能找到的唯一参考是当：“服务器可以是任何类型和接口，支持灵活性和未来的改进
浏览 11提问于2018-01-08得票数 6
2回答
Python gRPC购物车服务
、、、、
.proto文件如下所示：
syntax = "proto3";
package bamboo;
// -----------------Cart service-----------------
service CartService {
rpc AddItem(AddItemRequest) returns (Empty) {}
rpc GetCart(GetCartRequest) returns (Cart) {}
rpc EmptyCart(EmptyCartRequest) returns (Empty) {}
}
message C
浏览 0提问于2019-05-08得票数 6
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
