Google Cloud Pubsub Async Streaming API in C++



我正在尝试查找有关通过异步 grpc 使用 Pubsub Streaming API 的文档,但找不到任何文档。

我有这个简单的代码来读取主题中的所有消息:

auto creds = grpc::GoogleDefaultCredentials();
auto stub = std::make_unique<Subscriber::Stub>(
grpc::CreateChannel("pubsub.googleapis.com", creds));
ClientContext context;
std::unique_ptr<ClientReaderWriter<
StreamingPullRequest, StreamingPullResponse>> stream(
stub->StreamingPull(&context));
StreamingPullRequest request;
request.set_subscription(
"projects/test/subscriptions/test-subscription");
request.set_stream_ack_deadline_seconds(10);
stream->Write(request);
StreamingPullResponse response;
while (stream->Read(&response)) {
StreamingPullRequest ack_request;
for (const auto &message : response.received_messages()) {
ack_request.add_ack_ids(message.ack_id());
}
stream->Write(ack_request);
}

基本上我想做同样的事情,但使用异步 rpc 调用,所以这段代码在回调中调用:

StreamingPullRequest ack_request;
for (const auto &message : response.received_messages()) {
ack_request.add_ack_ids(message.ack_id());
}
stream->Write(ack_request);

你能帮我举一个简单的异步代码示例吗?

目前Google Cloud Platform C++Pub/Sub 库尚未由供应商正式宣布,并且没有用于实现的 ETA,因此代码库作为概念证明存在,仍然没有完整的文档,没有像样的使用示例。您可以跟踪社区在此 Github 线程之后进一步开发库的工作。

据我所知,您正在寻找通过异步 gRPC 调用执行 StreamingPull 的任何见解,查看 @Manuel Menzella 发布的答案,我建议您查看他在概念上适合您的用例的方法。

相关内容

  • 没有找到相关文章

最新更新