腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
在
来自
google
pubsub
的
轮询
消息
中
找不到
资源
google-cloud-platform
、
google-cloud-pubsub
我
在
google
pub/sub(q_0和q_abc)上
的
一个服务账户上创建了两个主题。当我从q_0读取
消息
时,它工作得很好,但在从q_abc
轮询
时,我得到了以下异常。这两个队列具有授予它
的
相同权限。Sep 30, 2019 3:23:51 PM com.
google
.cloud.
pubsub
.v1.StreamingSubscriberConnection$1 onFailure SEVERE:at com.
google
.
浏览 18
提问于2019-09-30
得票数 0
2
回答
如何在apache camel
中
并行处理gcp
pubsub
消息
apache-camel
、
google-cloud-pubsub
下面的代码从->源主题获取
消息
,并根据模板
pubsub
对其进行转换,然后将转换后
的
消息
发布到目标主题。但是为了提高性能,我需要在parallel.That
中
完成这个任务,我需要
轮询
500条
消息
,然后并行转换它,然后将它们发布到目标主题。从camel gcp组件文档
中
,我相信maxMessagesPerPoll和concurrentConsumers参数会做job.Due,因为缺少文档,我不确定它内部是如何工作
的
。我
的</
浏览 4
提问于2020-04-29
得票数 1
1
回答
有没有一种方法可以
在
Apache Beam作业中使用同步拉取来消费谷歌
PubSub
消息
google-cloud-platform
、
google-cloud-dataflow
、
apache-beam
、
publish-subscribe
、
apache-beam-io
我已经在下面的文档
中
浏览了
google
提供
的
客户端库。给定
的
客户端库只是从
PubSub
轮询
消息
,但在我们创建无界源连接器之前,它不会连续
轮询
。https://cloud.
google
.com/
pubsub
/docs/pull#synchronous_pull 由于我正在尝试构建
的
源连接器是无界源,因此我需要注意检查点标记,实现
PubSub</
浏览 19
提问于2021-01-10
得票数 0
回答已采纳
1
回答
用triggerTopic创建云函数时如何设置
pubsub
消息
过滤器
google-cloud-platform
、
google-cloud-functions
、
publish-subscribe
、
google-cloud-pubsub
、
google-deployment-manager
我正在尝试创建一个可以由
pubsub
主题触发
的
google
云函数。我使用
google
部署管理器模板来创建它。但我
找不到
任何方法来设置云功能
的
订户
消息
过滤器。我尝试
在
创建云函数
资源
之前和之后创建订阅。但从根本上说,它是行不通
的
。如果我
在
创建云函数之前创建它,那么
在
创建
资源
之后,它会覆盖subscriber函数并删除过滤器。是否可以使用
google
部
浏览 45
提问于2021-02-25
得票数 3
回答已采纳
1
回答
未指定
Google
/Sub错误解析订阅
资源
google-cloud-platform
、
google-cloud-pubsub
我使用
Google
控制台设置Pub/Sub,并实现异步拉以从订阅获取
消息
。这是带有错误
消息
的
命令行,上面写着错误解析订阅。使用错误
消息
,如何找到项目信息并正确设置属性属性?C:\Program Files (x86)\
Google
\Cloud SDK>gcloud beta
pubsub
subscriptions pull GmailSub 错误:(gcloud.beta.
pubsub
.subscriptions.pull未正确指定
浏览 3
提问于2018-01-01
得票数 1
1
回答
是否可以使
轮询
器(或PollableMessageSource)以列表形式
轮询
消息
?
spring-integration
、
spring-cloud
、
spring-cloud-stream
https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cloud-gcp-samples/spring-cloud-gcp-
pubsub
-polling-binder-sample中找到
的
有关
来自
PubSub
订阅
的
轮询
消息
的
示例,我想知道...>>,而不是每次
轮询
浏览 31
提问于2021-01-14
得票数 0
1
回答
Google
Pub/Sub与推送消费者
c#
、
google-cloud-platform
、
rabbitmq
、
google-cloud-pubsub
我们想使用
Google
pub/sub来消费
消息
。
在
rabbitMQ
中
,每当
消息
发布时,我们都会获取并处理它。我们
的
流程操作需要3-4个小时,正因为如此,我们
的
使用者是windows服务。我们不想使用发布/订阅拉取,因为我们不想
轮询
。但是发布/订阅推送发布到web端点。由于我们
的
长时间运行进程,我们不能使用web应用程序或web api。有没有可能像rabbitmq
中
那样使用pub
浏览 12
提问于2019-07-26
得票数 0
回答已采纳
1
回答
春云流- gcp耻骨结合剂maxFetchSize?
java
、
spring-boot
、
google-cloud-pubsub
、
spring-cloud-stream-binder
尝试使用绑定库从gcp发布子主题
轮询
消息
。
的
参考文献。一次使用spring.cloud.stream.gcp.
pubsub
.default.consumer.maxFetchSize
轮询
获取N条
消息
( maxFetchSize
的
值),但甚至我也设置了该属性我已经收到了一条
来自
主题
的
消息
,甚至主题还有其他
消息
。这里有人有别的主意吗?org.springframework.messaging.Messa
浏览 11
提问于2022-07-19
得票数 0
1
回答
将标签应用于Cloud、BigQuery和
PubSub
python-3.x
、
google-bigquery
、
label
、
google-cloud-sql
、
google-cloud-pubsub
我们需要将标签应用于下面的GCP ServicesBigquery,
Pubsub
服务
的
数量将跨越多个GCP projects我们将一次将标签应用于所有
资源
,利用
来自
Python下面的PATCH方法实现APIs自动化。https://cloud.
google
.com/bigquery/docs/reference/rest/v2/da
浏览 3
提问于2020-09-06
得票数 0
回答已采纳
1
回答
Spring Cloud Stream +
Google
Pub/Sup:功能绑定而不是woring
spring-cloud-stream
、
google-cloud-pubsub
、
spring-cloud-gcp
我尝试
在
同一个应用程序中使用
来自
不同
PubSub
主题
的
多个
消息
。其中一个是
轮询
的
,其他
的
应该是函数绑定。我
的
函数式消费者不工作。: cloud:
pubsub
: consumer: <em
浏览 52
提问于2020-05-07
得票数 1
回答已采纳
1
回答
来自
Apache Camel路由
的
手动确认
Google
pubsub
消息
java
、
apache-camel
、
google-cloud-pubsub
我有一个主驼峰路由(
轮询
器),它从
Google
组件启动,并调用去往
PubSub
端点
的
次要路由。如果我得到任何异常,如网络或端点关闭(HTTP500,400等),那么我不希望
消息
为nACKED,而是希望所有
消息
都为ACKed,而不管路由是否成功。我知道这并不理想,但我有一个这样
的
要求。我尝试过使用一个自定义<em
浏览 11
提问于2020-02-18
得票数 1
2
回答
如何使用Apache Beam传播
PubSub
元数据?
google-cloud-storage
、
google-cloud-dataflow
、
apache-beam
上下文:我有一个监听
pubsub
的
管道,发送给
pubsub
的
消息
是由
来自
google
云存储
的
对象更改通知发布
的
。流水线使用拆分文件
的
XmlIO来处理文件,到目前为止一切顺利。问题是:
在
pubsub
消息
中
(以及存储
在
google
云存储
中
的
对象
中
),我希望将一些
浏览 19
提问于2020-01-10
得票数 0
回答已采纳
1
回答
使用Firebase函数重试
pubsub
消息
firebase
、
google-cloud-functions
、
google-cloud-pubsub
我有一个由
PubSub
消息
触发
的
Firebase函数,它处理需要对
Google
Drive API进行
的
一系列调用。当对
Google
Drive API
的
调用由于速率限制错误而失败时,我想重试这些调用。我将调用添加到一个新
的
PubSub
消息
中
,并将其添加到队列
中
。此
消息
将立即送达。因此,我
在
消息
中
设置了dela
浏览 1
提问于2018-03-06
得票数 1
1
回答
如何通过
Google
/Sub API接收长期运行
的
操作结果
google-app-engine
、
google-cloud-platform
、
google-cloud-pubsub
、
google-cloud-speech
在
Google
中
启动长时间运行操作时,该服务可能返回一个具有"“形状
的
对象。然后,操作
的
状态可以通过该对象进行
轮询
,并在完成时获得结果。我想避免为这些结果设置自己
的
轮询
过程,我希望能够利用
Google
/Sub服务来提供帮助。我
的
希望
来自
于阅读这行 ..。客户机可以通过
轮询
操作
资源
或将操作
资源
传递给另一个API
浏览 1
提问于2017-06-15
得票数 9
1
回答
使用
Google
PubSub
和Golang。最有效(成本)
的
服务
轮询
方式
go
、
google-compute-engine
、
google-cloud-pubsub
我们正在从AMQP转移到
Google
的
Pubsub
。func main() { jsonKey, err
浏览 3
提问于2016-04-11
得票数 5
回答已采纳
2
回答
主题是
在
云pub/sub上创建
的
,但无法对该主题创建监视。
cloud
、
gmail-api
、
google-cloud-platform
、
google-cloud-pubsub
content-type': 'application/json',}, 'https://mail.
google
.comProjectId/topics/TopicId",}); }),function(error, re
浏览 3
提问于2015-06-20
得票数 4
回答已采纳
1
回答
google
.cloud.
pubsub
_v1和
google
.cloud.
pubsub
有什么区别?
google-cloud-pubsub
、
google-cloud-python
、
google-python-api
我发现这两种方法都在
Google
的
不同文档中使用:载于: from
google
.cloud import
pubsub
_v1
在
以下文件中找到:
浏览 1
提问于2018-01-10
得票数 14
回答已采纳
1
回答
识别谷歌
PubSub
订户信息
google-cloud-platform
、
google-cloud-pubsub
我有一个
google
pubsub
主题,只有一个订阅。我已经与第三方共享了连接信息,他们以拉入订户
的
身份使用
来自
我
的
pubsub
主题/订阅
的
消息
。然而,他们报告说他们看不到主题/订阅
中
的
消息
。那么,
在
Google
Cloud
中
是否有一个日志/视图可以为我提供关于谁正在访问我
的
pubsub</
浏览 0
提问于2019-10-08
得票数 0
1
回答
如何使用
Google
并运行以处理
资源
密集型
的
长期运行任务?
google-cloud-platform
、
google-cloud-pubsub
、
long-running-processes
、
google-cloud-python
、
google-cloud-run
我有一个
Google
主题,它有时包含数千条
消息
,有时甚至没有
消息
。这些
消息
表示每个任务可能需要超过一个小时
的
任务。问题是
PubSub
有600秒的确认超时时间。这意味着,为了让云运行这些
消息
,它们必须在600秒内完成。那么,是否有可能通过代码确认
PubSub
请求并继续处理,而不让
Google
交出
资源
呢?还是有更好
的
解决方案我不知道? 因为这些过程是如此
的
代码/
资源<
浏览 0
提问于2019-08-05
得票数 11
1
回答
GCP数据流无法找到
pubsub
订阅
google-cloud-platform
、
google-cloud-dataflow
我
的
GCP数据流作业立即失败,并显示以下错误
消息
: Workflow failed.订阅确实存在,我可以在数据流UI
中
单击它。我以前已经能够运行这个作业,并且它起作用了。只有当我尝试重新部署它时,它才会给出错误。编辑:这就是我获取
pubsub
订阅
的
方式 pipeline.fromSubscription(options.getSubscription
浏览 27
提问于2021-04-28
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
订单超时未支付自动取消-实现简述
PubSub可以帮助减轻网站压力
替代 Kafka?Pinterest 推出高效可扩展云原生系统 MemQ
分布式之延时任务方案解析
9012年了,我不允许你还不会玩IPFS!
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券