python调用流cancel()后如何处理grpc流
在Python中调用流的cancel()方法后，可以通过以下步骤处理gRPC流：
- 确保已经正确导入所需的gRPC库和模块，例如
import grpc和import your_service_pb2_grpc。 - 创建一个gRPC通道，用于与服务器建立连接。可以使用
grpc.insecure_channel()方法创建一个不安全的通道，或者使用grpc.secure_channel()方法创建一个安全的通道。 - 使用生成的gRPC客户端存根（stub）创建一个流对象。例如，如果你的服务定义文件为
your_service.proto，则可以使用your_service_pb2_grpc.YourServiceStub(channel)创建一个存根对象。 - 调用流的cancel()方法来取消流。例如，如果你的流对象为
stream，则可以使用stream.cancel()来取消流。 - 在取消流后，你可以根据需要执行以下操作之一：
- 如果你希望立即停止流并关闭连接，可以调用
stream.cancel()后紧接着调用stream.cancelled()方法来检查流是否已被取消。如果返回True，则表示流已被取消，你可以关闭连接。 - 如果你希望在取消流后继续处理其他操作，可以使用
stream.cancelled()方法来检查流是否已被取消。如果返回True，则表示流已被取消，你可以根据需要执行其他操作。
- 如果你希望立即停止流并关闭连接，可以调用
请注意，以上步骤仅适用于处理gRPC流的取消操作。在实际应用中，你可能还需要处理其他异常情况、错误处理、重试机制等。
对于腾讯云相关产品，推荐使用腾讯云的云原生应用平台TKE（Tencent Kubernetes Engine），它提供了强大的容器化技术和云原生解决方案，适用于部署和管理容器化应用程序。你可以使用TKE来部署和管理gRPC服务，并使用腾讯云的其他产品和服务来增强你的应用程序的功能和性能。
更多关于腾讯云TKE的信息，请访问：腾讯云TKE产品介绍
相关·内容
关于zio-grpc双流关闭调用的咨询:何时关闭？我正在使用grpcurl来测试bistream，但是zio-grpc服务器端不会太快地关闭(过一段时间就会关闭)。
我正在通过Stream.ensuring观看grpc服务器端流关闭事件。详情如下：
请求流的：通过forkDomaen在光纤中使用请求流:我假设如果流关闭，grpc请求流将被关闭。
request
.mapM { reqItem =>
// do action here
UIO(println(s"test get some data from request item: ${
浏览 13提问于2022-10-17得票数 0
回答已采纳
第一个问题，下面的背景。如何根据取消带有异步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
回答已采纳
我正在尝试编写一个python客户端来终止gRPC流
原件：
rpc Start (StartParameters) returns (stream Progress) {}
在客户端中，当我准备终止流时，我尝试调用stream.cancel()，然后当我打印捕获的流的事件时，它不打印事件。我看到了例外
<_Rendezvous of RPC that terminated with:
status = StatusCode.CANCELLED
details = "Locally cancelled by application!"
debug_
浏览 41提问于2019-07-16得票数 0
回答已采纳
当使用dart中的gprc唤醒时，如果第一个rpc调用的响应类型是流响应，则客户端应用程序在请求流处理程序时无法连接到服务器。在构建来自helloworld的示例时，我发现了这个问题。
是否有任何方法来确保建立连接？还是我做错了什么？
我已经和await channel.getConnection();试过了，但没什么区别。
grpc版本: 3.0.2
helloworld.proto
// Copyright 2015 gRPC authors.
//
// Licensed under the Apache License, Version 2.0 (the "Lice
浏览 12提问于2022-02-10得票数 0
回答已采纳
我正在使用这个的代码来创建我的GRPC异步服务器：
#include <memory>
#include <iostream>
#include <string>
#include <thread>
#include <grpcpp/grpcpp.h>
#include <grpc/support/log.h>
#ifdef BAZEL_BUILD
#include "examples/protos/helloworld.grpc.pb.h"
#else
#include "helloworld
浏览 13提问于2020-10-10得票数 1
2回答
gRPC的Go库提供了创建您自己的自定义拦截器(即中间件函数)的接口，我正在尝试编写两个日志拦截器。第一个是Unary Server Interceptor，我可以使用传入拦截器函数的对象轻松地记录请求参数。
func loggingUnary(context context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
start := time.Now()
resp, err := handler(context,
浏览 1提问于2018-06-26得票数 4
1回答
我使用Node.js连接到使用执行长时间运行任务的服务器。
在作业进行期间，服务器向客户端( Node.js应用程序)发送单向流。我需要实现一个停止按钮，并被告知关闭将停止正在进行的工作。
这是我目前的代码：
let express = require('express'),
router = express.Router(),
grpc = require('grpc'),
srv = grpc.load(__dirname + '/job_handler.proto').ns;
let startJob = (job
浏览 3提问于2015-12-04得票数 2
回答已采纳
我正在gRPC流上的python线程中侦听，这个线程永远不会结束：
responses = some_grpc_stub.FunctionThatReturnsStream()
for response in responses:
on_event(response)
我想要这样做一段时间，然后停止监听，这样on_event就不会再次被调用，可能在流完成之前。
我该怎么做？是否有一种正确的方法只需关闭运行此循环的线程？或者是否有办法使responses结束过早，这样迭代结束，线程就可以运行到完成？
浏览 10提问于2022-05-11得票数 1
回答已采纳
使用Python gRPC，当设置了threading.Event时，我希望能够取消来自客户端的长时间运行的一元流调用。 def application(stub: StreamsStub, event: threading.Event):
stream = stub.Application(ApplicationStreamRequest())
try:
for resp in stream:
print(resp)
except grpc.RpcError as e:
print(e) 目前，我使用chann
浏览 27提问于2019-03-14得票数 0
2回答
我知道有足够的虔诚的人是危险的。我成功地将一个非常简单的python烧瓶应用程序部署到app中，该应用程序基本上将接收到的post数据作为消息发布到PubSub。这样做几乎与谷歌的完全相同。唯一的不同之处在于它使用了我与应用程序存储库一起推送的服务帐户来访问PubSub以规避。
到目前为止工作得很好，但我已经开始看到在threading.py中启动一个新线程时出现的少量错误
1)
Traceback (most recent call last):
File "src/python/grpcio/grpc/_cython/_cygrpc/credentials.pyx.pxi
浏览 0提问于2018-07-17得票数 1
回答已采纳
1回答
我有一个Go gRPC客户端连接到在我的k8s集群中的不同pod中运行的gRPC服务器。
它工作正常，可以接收和处理请求。
我现在想知道如何最好地在gRPC服务器pod被回收的情况下实现弹性。
据我所知，clientconn.go代码应该会自动处理重新连接，但我就是不能让它工作，我担心我的实现在第一个实例中是不正确的。
从main调用代码：
go func() {
if err := gRPCClient.ProcessRequests(); err != nil {
log.Error("Error while processing
浏览 364提问于2021-02-24得票数 3
回答已采纳
1回答
我有一个一元拦截器，它包含以下代码：
func (m Middlewares) LocationInterceptor(c context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
ctx := c.(HarmonyContext)
location, ok := req.(interface{ GetLocation() *corev1.Location })
if !ok {
panic
浏览 1提问于2020-08-17得票数 3
在gRPC的Node.js版本(grpc-js)中，是如何实现的？
对于Go实现(grpc-go)，逻辑主要在 (flowcontrol.go，bdp_estimator.go)中；同时，它被描述为。然而，我找不到任何关于grpc-js的东西。
我主要感兴趣的是Node.js接收器何时发送WINDOW_UPDATE帧。
浏览 17提问于2021-02-13得票数 0
我有一个grpc客户端应用程序，它可能会经常阻塞，这会导致它在一段时间内无法调用grpc Recv函数。在这种情况下，grpc服务器上的行为是什么？grpc服务器的Send调用会阻塞吗？在客户端调用Recv之前它会阻塞吗？
浏览 0提问于2020-04-30得票数 0
1回答
我仍然在忍受这个问题:我知道，有了Go lang，我们可以很容易地实现高性能的网络服务。我选择了gRPC协议，我最好实现异步操作，因为它比同步更强大：
您能告诉我更多关于使用异步操作比同步操作的好处吗？
你能指导我如何实现Go lang或Python异步服务，或者给我它的示例代码吗?我读过本文，但这类代码是我所不知道的。
非常感谢!
浏览 1提问于2018-06-29得票数 0
我不知道如何将RXJS的订阅者更改为Python的形式，这是无效的。 Typescript使用GRPC流形式并插入RXJS订户。Python不知道如何编写它。 RXJS代码 import * as grpc from 'grpc';
import { Observable, Subscriber } from 'rxjs';
export function subscribeToWorkspace(
input: WorkspaceSubscriptionInput,
): Observable<EventPayload> {
retur
浏览 8提问于2019-04-12得票数 0
1回答
我有一个将文件从本地机器传输到远程服务器的gRPC服务，并且我注意到一些严重的带宽问题。平均而言，它的下载速度约为1mb/s，一个连接共享多个流(通常约为8个)。
服务器使用TLS进行加密，但这似乎不是瓶颈，因为关闭TLS对性能的影响可以忽略不计。我还尝试使用iperf3直接测试客户端和服务器之间的带宽，结果是10mb/s。
Connecting to host <host>, port <port>
[ 7] local 10.0.0.112 port 59651 connected to <ip> port <port>
[ ID] Int
浏览 4提问于2019-05-29得票数 0
我正在通过gRPC cpp示例来尝试学习。在调试流示例时，我注意到服务器上对grpc_impl::ServerReaderWriter::Read的调用会一直阻塞，直到另一端写入或流结束。 我们应该如何使服务器足够健壮，使其能够处理客户端在发送初始消息后挂起或忘记关闭流？ 也许它会调用RPC并向我发送三条消息，但永远不会关闭。似乎不存在此调用的超时版本。 在这种情况下，不是所有客户端的整个通信线程都被阻塞了吗？
浏览 121提问于2020-10-21得票数 0
回答已采纳
1回答
我现在正在实现Raft算法，我想使用gRPC流来完成这个任务。我的主要想法是为每个节点创建3个流给其他节点，一个流将传输一种类型的RPC，有AppendEntries、RequestVote和InstallSnapshot。我在有限的帮助下编写了一些代码，因为在它的双向流演示RouteChat中，客户端在开始读取之前发送它的所有数据。
首先，我想在任何时候写入流，所以我编写了以下代码
void RaftMessagesStreamClientSync::AsyncRequestVote(const RequestVoteRequest& request){
std::strin
浏览 1提问于2019-02-01得票数 1
回答已采纳
我正在使用同步长寿命GET请求创建grpc python客户端：
def main():
with grpc.insecure_channel(target='localhost:50051') as channel:
stub = hello_pb2_grpc.HelloStub(channel)
def signal_handler(signal, frame):
print("")
logging.warning("Interrupt signal. Exit
浏览 0提问于2021-02-19得票数 0
2回答
让我们假设我们为gRPC开发了一个自定义的低级传输。我们如何才能将其“插入”到gRPC c++应用程序接口中，以便我们可以将其用于通道？
浏览 1提问于2017-11-06得票数 6
我在C++中使用gRPC。我有异步服务器和同步客户端。rpc是双向流类型。
下面是我用客户端发送消息的方式：
class ConnectionService {
public:
ConnectionService(std::shared_ptr<Channel> channel)
: stub_(Connection::NewStub(channel)) {}
void HearthBeat() {
ClientContext context;
std::shared_ptr<grpc::Client
浏览 0提问于2020-10-12得票数 3
如何以及在哪里处理此错误并阻止我的应用程序崩溃？ $ node app.js
Server Started at port 3000
events.js:200
throw er; // Unhandled 'error' event
^
Error: 14 UNAVAILABLE: Name resolution failed for target firestore.googleapis.com:443
at Object.callErrorFromStatus (D:\food_list\node_modules\@grpc\grpc-
浏览 124提问于2020-04-17得票数 2
我正在使用Protobuf和gRPC进行实验，并正在学习Go基础教程：
从关于的文档中可以看出，并发使用相同的ClientConn似乎是安全的。但我不能任何关于一个人创造的存根/客户端。
假设我通过HTTP请求接收数据，我希望通过gRPC作为protobuf转发该数据，然后响应该HTTP。我应该在每次处理HTTP请求时创建一个客户机/存根，还是在设置HTTP服务器时创建客户机/存根，并在设置HTTP处理程序时传递客户机/存根？
例句:我想这样可以。
var opts []grpc.DialOption
conn, err := grpc.Dial("127.0.0.1:1234"
浏览 8提问于2022-07-19得票数 1
回答已采纳
我是grpc和protobuf的新手，我正在努力理解grpc是否能满足我的需求。基本上，我有一个软件，它可以在特定的阶段调用脚本(bash或python)，并传递脚本的一些参数(例如，事务状态、一些值等)，所以我想通过grpc传递这些参数，即grpc通信必须由我的脚本启动。
我知道有grpc python库，所以我想利用脚本中的这些库。但是，我不太清楚我的脚本是充当grpc客户端还是服务器？我看到的例子非常简单-- request/reply，其中的请求是由客户端发出的，而服务器响应；这不是我想要的。
浏览 3提问于2021-12-29得票数 1
回答已采纳
我有一个gRPC服务器，其主要内容如下：
syntax = "proto3";
service MyServicer {
rpc DoSomething(stream InputBigData) returns (stream OutputBigData) {}
}
message InputBigData {
bytes data = 1;
}
message OutputBigData {
bytes data = 1;
}
我的服务器是用以下Python代码创建的：
server = grpc.server(futures.ThreadPoolExe
浏览 2提问于2020-09-24得票数 1
1回答
我只是发现在C++中，当使用AsyncService时，即使不请求新请求，gRPC仍然会从网络读取数据。这在我的系统中造成了巨大的内存使用量。
详细情况：
我有一个客户端，它将向服务器发送大量请求。
在服务器端，我没有请求任何请求。服务器在cq_->Next(&tag, &ok)中被阻塞，但一直在消耗内存。在我的系统里造成了一个OOM。
因此，我的问题是，当我不请求新请求时，如何防止服务器从网络中读取数据？也就是说，如何做服务器端的背压，这样我就可以节省内存？
有人能帮我吗？谢谢!
编辑:复制
我给您做了一个简单的例子来重现这个问题，代码是基于正式的v1.46.3代码库的
浏览 20提问于2022-05-29得票数 1
1回答
grpc低层遥测测井
、、、、
我试图在较低的级别上度量我的服务的延迟。环顾四周，我发现可以向grpc构建器添加一个addStreamTracerFactory。
我完成了这样一个简单的实现，并打印了日志：
val server = io.grpc.netty.NettyServerBuilder.forPort(ApplicationConfig.Service.bindPort).addStreamTracerFactory(ServerStreamTracerFactory)....
class Telemetry(fullMethodName: String, headers: Metadata) extends
浏览 1提问于2019-04-03得票数 0
回答已采纳
进程中的grpc请求 from multiprocessing import Process, Manager
def frames_process(self):
# fork process
self.frames_flag.value = True
self.f_process = Process(target=self.frames_handle)
self.f_process.start() 在frames_handle中，通过grpc客户端向服务器发出请求，结果通过default_cb异步回调 def default_cb(call_future
浏览 152提问于2018-12-23得票数 0
回答已采纳
我有一个grpc服务器和客户端，大部分时间都能正常工作，但偶尔也会收到“传输正在关闭”的错误：
rpc error: code = Unavailable desc = transport is closing
我想知道是不是我的设置有问题。客户端非常基础
connection, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())
pb.NewAppClient(connection)
defer connection.Close()
调用是在超时的情况下进行的，例如
ctx, cancel := context.W
浏览 0提问于2018-10-25得票数 7
回答已采纳
在http2-spec中，服务器半关闭流(服务器发送http2.END_STREAM)，客户机仍然允许发送数据(因为它是半关闭的)。
考虑以下gRPC场景：
客户端打开bidi流到服务器并开始发送数据。
服务器关闭响应流并发送状态拖车(转换为发送http2.END_STREAM)
客户端继续发送数据
语义在gRPC中定义得很好吗？
可能的方式：
遵循http2-spec:允许客户机继续发送服务器处理的数据。
不遵循http2-spec:如果服务器关闭流，则客户端连接将隐式终止。
注意:我刚刚进行了测试，看起来gRPC for Java遵循了“不遵循http2
浏览 0提问于2019-04-04得票数 0
回答已采纳
1回答
GRPC重新连接并保持连接
、、、、
StreamObserver<RouteSummary> responseObserver = new StreamObserver<RouteSummary>() {
@Override
public void onNext(RouteSummary summary) {
LOGGER.info("Action.");
}
@Override
public void onError(Throwabl
浏览 76提问于2020-09-08得票数 0
1回答
我有一个像这样运行的gRPC服务：
server.addService(PassportService, implementation);
server.bind(mfeConfig().grpc.passport, grpc.ServerCredentials.createInsecure());
server.start();
我可以从客户那里打电话给我：
const request = new GetConsoleUserRequest();
const meta = new grpc.Metadata();
meta.add('__.grpc.exchanged-token&#
浏览 6提问于2020-03-03得票数 0
回答已采纳
1回答
在尝试从排序器获取配置块时，我们在排序器端收到以下警告，尽管我们能够成功获取该块。有谁能告诉我们为什么这条警告消息是从订单方发出的？我们能安全地忽略同样的问题吗？
2019-03-18 05:37:47.304 UTC [common.deliver] Handle -> WARN 020 Error reading from 127.0.0.1:48474: rpc error: code = Canceled desc = context canceled
2019-03-18 05:37:47.304 UTC [comm.grpc.server] 1 -> INFO 021
浏览 0提问于2019-03-18得票数 0
我使用谷歌语音文本API文本语音到文本。当我们到达is_final=True时，我试图终止此服务。
requests = (types.StreamingRecognizeRequest(audio_content=message.chunk)
for message in messages)
responses = client.streaming_recognize(streaming_config, requests)
我试过了：responses.cancel()，但是它出现了错误
我发现在Java中有一种可以用来终止流识别服务的方法：
SpeechC
浏览 2提问于2018-11-04得票数 1
1回答
在“google.golang.org/ grpc /code”中引入了一些错误，一些错误可以由grpc生成，有些不能生成，grpc流应该对应于http2.0中的流。然后，我想知道这是否意味着当那些grpc流抛出异常时TCP连接有错误，所以我只需要重新连接TCP连接，还是我有一些只用于重新连接流的方法(例如重新连接流，等等)。
for {
request, err3 := stream.Recv()
if err3 == io.EOF {
return nil
}
if err3 != nil {
浏览 3提问于2022-07-28得票数 0
回答已采纳
2回答
如何用gRPC实现异步流？
、、、、
我正在尝试用dart(flutter)客户端和gRPC应用程序接口的python服务器进行实时图像分析。如何在gRPC中使用dart-client设置异步图像流？(如websockets)
浏览 0提问于2019-02-09得票数 2
1回答
我的messages.proto文件中有以下模式：
message Person {
string id = 1;
string first_name = 2;
string last_name = 3;
string email = 4;
string alias = 5;
}
//CREATE, DELETE, UPDATE RESPONSES AND REQUESTS Messages
message ListPersonsRequest {
ListOptions options = 1;
}
message ListPersonsResponse {
浏览 12提问于2022-11-04得票数 1
回答已采纳
Grpc.Core 2.38.0
我有一组应用程序参与使用grpc流进行进程间通信。我们不时地注意到服务器进程中的锁定和内存耗尽(由于锁)无法完成对IAsyncStreamWriter.WriteAsync(...)的调用
最近对grpc (.net)的更改已经将WriteAsync API更改为接受CancellationToken，但是在Grpc.Core包中不能使用。
浏览 8提问于2022-06-17得票数 0
现在我正在学习异步GRPC++中的双向流。感谢你的大师：。我得到了很多有用的信息来了解这个mode.But的实现原理我有一个问题:没什么好说的，代码如下：
if(!ok || mcounter >= greeting.size())//ctx_.IsCancelled() doesn't work
{
std::cout << "[ProceedMM]: Trying finish" << std::endl;
status_ = FINISH;
responder_.Finish(S
浏览 2提问于2020-06-21得票数 0
1回答
GRPC双向流配置
、、、
我将按照GRPC介绍的video在客户机和服务器之间实现一个简单的双向流 可能我在实现中遗漏了一些东西，实际上我收到了这个错误： 错误: 14不可用: GOAWAY已收到 这是我的代码： -Proto： syntax = "proto3";
package nbsb;
message EchoMessage {
string value = 1;
int32 value2 = 2;
}
service EchoService {
rpc Echo (EchoMessage) returns (EchoMessage);
rpc EchoClientStr
浏览 21提问于2020-06-10得票数 0
回答已采纳
我正在尝试使用gRPC访问。在中，我发现了一个关于如何编译一个原型文件以获得一些可供客户端使用的python代码的示例。提供的示例生成了一些python文件，但它们不可用，因为它们似乎导入了其他不存在的文件。
我用来编译的命令如下:编译的python -m grpc_tools.protoc -I./googleapis --python_out=. --grpc_python_out=. googleapis/google/home/graph/v1/homegraph.proto
当我尝试导入生成的文件时，我得到了以下错误。
(grpc_test) ➜ grpc_test git:(ma
浏览 0提问于2019-07-23得票数 0
1回答
假设我有多个客户端向服务器(gRPC服务)发送请求。我希望我的服务器能够收集，比方说8个请求，一次处理这些请求，然后只将结果发送回客户端。我不确定如何使用GRPC功能来做到这一点，甚至不知道这是否可能，或者我是否需要其他东西。
上下文:我的用例来自于为GPU上的神经网络提供服务。在这种情况下，批量处理多个请求的输入，进行一次推理，然后将结果发回，比每一次输入都进行一次推理要高效得多。
浏览 6提问于2020-10-20得票数 0
1回答
我编写了一个客户机，它启动到grpc服务器的多个连接来请求一些东西。一旦收到回复，我想停止所有其他的grpc调用。我使用一个事件来控制这个过程。
但是，我不知道如何优雅地终止grpc调用。以下是我所做的。代码将导致错误:打开的文件太多。有人能帮我吗？如何优雅地终止grpc调用？
def request_something(event):
with grpc.insecure_channel(ip) as channel:
stub = GrpcServiceStub(channel)
req = Request()
response_fu
浏览 4提问于2022-11-10得票数 0
我有python服务器，它有grpc服务和grpc网关。在python服务器端，它使用yield发送分块数据。我可以看到使用wireshark逐个发送数据。 我在UI端使用了angular框架。当请求发出时，我立即得到响应200，一段时间后，我收到了整个数据。 但是在浏览器中，一旦接收到完整的数据，我就会得到http调用的响应。即使当我尝试使用REST客户端时，响应也在一起，它不像流一样来。 看起来浏览器只有在接收到所有数据后才会进行处理。 有没有什么我遗漏的头文件导致了这个问题？ 如何解决这个问题？
浏览 20提问于2021-10-22得票数 1
2回答
我正在学习用gRPC实现node.js的东西。我读到gRPC和微服务间的通信是很好的结合。
gRPC在微服务间通信环境中解决不了REST的问题是什么？
为什么要使用gRPC进行微业务间的通信？
浏览 6提问于2021-07-13得票数 1
我使用的是“流式RPC”API，其中MyRequests和MyResponse都是流的。
service MyStreamedService {
rpc myOperation(**stream** MyRequest) returns (**stream** MyResponse)
}
下面是包装gRPC流的类的稍微简化的版本；
public class MyStreamWrapper implements StreamObserver<MyResponse> {
public MyStreamWrapper(ManagedChannel myChannel) {
浏览 2提问于2021-09-16得票数 1
回答已采纳
1回答
我想我理解gRPC中的客户机-服务器结构，但不知道如何使服务器能够在客户机上调用gRPC。我是在两边都实现了Client & Server (同时显示了服务器和存根)，然后有两个单独的通道，还是我错过了一个功能？
浏览 1提问于2021-01-04得票数 0
回答已采纳
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
回答已采纳
正在从BigQuery存储应用编程接口下载数据，并定期收到超过配额的429个错误(错误如下) File "/usr/local/lib/python3.8/site-packages/google/api_core/grpc_helpers.py"，第100行，在next six.raise_from(exceptions.from_grpc_error(exc)，exc中) File ""，第3行，在raise_from google.api_core.exceptions.ResourceExhausted: 429中，在超出'projects//
浏览 19提问于2020-07-17得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
