我们希望在发布事件到发布/订阅失败的情况下有故障恢复机制。我正在使用"ListenableFutureCallback“来了解消息是否成功发布。在失败的情况下，它只是抛出异常，我需要事件详细信息来发布到内部消息服务。如何在onFailure()方法中获取事件详细信息。我使用的</em
浏览 15提问于2019-10-31得票数 1
回答已采纳
终端中是否有命令来获取Message body，如Google平台控制台订阅(与来自Nest门铃设备的事件触发器相关)所示？如果不是，我如何向Pub/Sub服务发出API请求并接收GCP控制台中显示的相同的JSON有效负载？
谢谢
浏览 9提问于2022-02-02得票数 0
回答已采纳
2回答
目前，我正在为Android设备开发一个可扩展的感知和数据处理框架。该框架将通过Android移动设备实现广泛的数据信号(例如位置、wifi、电池、加速度计)。我认为实现此功能的理想方法是在发布者和订阅者之间实现一个小型发布/订阅<
浏览 3提问于2014-03-14得票数 2
回答已采纳
我正在尝试GCP的cloudiot_pubsub_example_server.py示例代码。要给出一个概述，有两个代码客户机和服务器。客户端发布到GCP发布/订阅中的主题，并更新或发布随机温度。服务器订阅此主题并接收温度。此外，服务器发布到客户端的配置主题，并在某个温度升高或降低时打开或关闭风扇。
当我使用所有提供的凭据运行这两种代码时，客户机正在<e
浏览 1提问于2021-01-30得票数 1
回答已采纳
2回答
问题：如何使用WCF提供分布式、可伸缩和抗灾难的发布/子服务。请注意，除了消息传递/中间件解决方案(如Tibco )之外，还考虑了这种方法。在这篇文章中，作者试图解决拥有多个发布者的问题(就像一个跨几个盒子的服务层一样)。也就是说，没有人告诉publisher B客户端A希望得到有关事件的通知。作者建议以酒吧/分店服务作为解决方案。pub/ service将集中存
浏览 0提问于2008-12-24得票数 7
回答已采纳
1回答
我想知道是否有一种方法可以从单个方法中发布的事件中获得结果。DisplayMessageEventArg(message));
}
如您所见在发布事件之前，我可以做一些错误处理，但是如果在DisplayMessageEvent订阅服务器端发生了什么事情，我也希望返回有关此事件的</
浏览 3提问于2016-10-11得票数 1
回答已采纳
1回答
我的项目包括当文件到达云存储存储桶时，通过数据流摄取和处理文件。当我开发读取到达存储桶的文件并将其存储在BigQUery表中的pipeline.py时，这对我很有效。我还使用发布/订阅服务捕获当文件到达时的事件，此捕获是使用我的listener.py文件完成的。 我的问题是，如果我需要在文件到达存储桶后激活数据流，我如何在GCP云中部署使用python开
浏览 36提问于2021-11-03得票数 0
回答已采纳
1回答
我正在寻找一种使用Stackdriver在云构建失败时监控和创建警报的选项。很多人正在使用发布/订阅和云函数(example)来解决这个问题，但我更喜欢将所有的监控/警报都放在Stackdriver中。Stackdriver确实有一个名为Cloud Build的资源类型，但就检测失败的构建而言，没有任何Metrics有任何意义。我猜这是一个缺失的特征？ ? 第二种选择是分析GCP日志(日志查看器)，并根据这些事件</e
浏览 26提问于2019-10-13得票数 2
回答已采纳
我的应用程序基于Micronaut和GraalVM (java 11)，并对http://httpbin.org/get进行简单调用。/app"]
一切都在我当地的环境中运作。但是，当我将映像推送到，将其部署到Cloud，并尝试访问端点/api/fb时，它会使容器崩溃，并且503服务不可用。日志中的错误是“请求失败，因为到实例的HTTP连接有一个错误”。但是无论我做什么，当我使用Micronaut Http客户端时，它
浏览 2提问于2020-02-07得票数 4
回答已采纳
在我的存储帐户中，我创建了一个事件订阅：我选择了自定义输入模式但是，我得到了这个错误：
"CustomInputSchema“不能与主题的EventGridSchema输入模式结合使用
浏览 2提问于2019-05-21得票数 2
我们正在评估向微服务的转变。每个微服务都是独立开发的自己的项目。在规划期间，我们已经确定一些微服务将通过REST调用、发布/订阅、消息传递(即，订单服务需要来自产品服务的产品信息)。如果一个微服务依赖于从另一个微服务检索数据，那么它如何在开发过程中独立运行呢？例如，当您的订单服务请求产品详细信息，但没有响应该请求时会发生什么情况？
浏览 1提问于2017-01-13得票数 3
背景:我在我的移动应用程序中添加了android穿戴支持，并且在WearableListenerService中使用otto总线事件时遇到了问题。并获取新任务。一旦我从网络中获得新的任务，并再次使用bus.post发布响应。在TasksService中，我订阅了回复，并将其发送给穿戴应用程序。问题：
问题是，当我进行HTTP并得到响应时，WearableListenerService被破坏了，而订阅事件</e
浏览 3提问于2016-03-10得票数 0
回答已采纳
我的GCP帐户中运行的Google云传输作业很少，它将数据从Azure传输到GCS存储桶。%22%7D，"get“方法可以获取作业的详细信息，如名称、描述、bucketName、status、includePrefixes、storageAccount等。01T06:13:32.460934533Z",
"latestOperationName": "transferOperations/
浏览 19提问于2021-07-16得票数 0
回答已采纳
我有一个奇怪的DDD问题要解决。我有两个有界上下文(BC)，一个用于订阅，另一个用于Alerts。
订阅BC具有业务规则形式的警报类型元数据，用于指示订阅者可以订阅什么类型的警报。一旦订阅者订阅了一种警报类型，另一个系统就开始将这些警报发布到alerts BC并持久化。在发布时，Alerts BC知道警报类型id，但不知道它的元数据，如警报名称和描述。需要
浏览 3提问于2015-05-21得票数 0
在活动A中，我有一个AsyncHttpClient从一个网站获取一些数据。一旦接收到数据，我就在活动A中刷新RecyclerView。但是，如果有人切换到活动B，则当数据被获取时，我希望在完成数据提取时刷新活动B的RecyclerView。创建您的事件类，这将存储您正在通信的数据。在SecondActivity中先注册<
浏览 2提问于2016-05-24得票数 0
回答已采纳
3回答
在GCP上是否有类似的系统经理的解决方案/服务？我的最终目标是在GCP上对特定事件运行一个shell脚本。与AWS一样，通过EventBridge，我能够触发Lambda函数，而这个函数又触发了针对特定VM的SSM命令。
这在GCP上有可能吗？
浏览 3提问于2020-04-24得票数 1
回答已采纳
作为与大量用户沟通的一部分，我每天需要发送超过75,000封电子邮件。我正在联系的用户的电子邮件存储在CSV文件中。我一直使用Postman Runner通过SendGrid (Email API)发送这些请求，但由于数据量如此之大，我的计算机要么变慢，要么Postman在批处理完成之前完全崩溃。我想将包含电子邮件的CSV上传到云存储存储桶中，然后使用云函数访问文件，以便为每封电子邮件发送POST请求。这样，所有的处理都可以由GCP处理，而不是由我<e
浏览 20提问于2021-01-14得票数 1
3回答
我正在编写一个应用程序，将支持应用程序内订阅。订阅将使我的用户能够使用Android世界之外的许多服务和福利。我知道我可以使用Google Play Developer API来查询订阅的状态，但由于所提供的服务和福利的性质，这样做并不是很方便。我想知道是否有一种方法可以在订阅状态发生变化时得到通知。例如，像web钩子这样的东西。
浏览 10提问于2015-05-08得票数 13
使用下面的配置在8085上成功启动本地仿真器，也设置了PUBSUB_EMULATOR_HOST=localhost:8085
注意:当连接到实际的谷歌PubSub主题时，一切都很正常。
浏览 0提问于2018-07-12得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
