google-cloud-pubsub

3热度

2回答

我无法找到使用java从pub/sub读取消息的方法。我用我的POM这个Maven的依赖 <dependency> <groupId>com.google.cloud</groupId> <artifactId>google-cloud-pubsub</artifactId> <version>0.17.2-alpha</version> </dependency

0热度

1回答

谷歌的Pub/Sub在GAE

在GAE应用程序中使用的pub/sub Java客户端库不工作，我得到一个异常 Caused by: java.security.AccessControlException: access denied ("java.lang.RuntimePermission" "shutdownHooks") at java.security.AccessControlContext.checkPermi

0热度

3回答

Google PubSub Python客户端中的内存泄漏

我使用Python无限期地向Google PubSub发布消息。我正在分批发布消息。我已将batch_size设置为20.我在5个进程中发布消息。我在GCE的脚本下执行了1个CPU和3.75内存。跑了一个多小时之后，GCE已经失去记忆，发行商崩溃了。 import json from multiprocessing import Process from google.cloud impo

0热度

1回答

如何接收PubSub中的属性

任何人都可以帮助我从PubSub-Message接收属性吗？消息显示正确，但没有属性。我接收级看起来是这样的： public class ReceiveMessageServlet extends HttpServlet { @Override public final void doPost(final HttpServletRequest req, final Htt

1热度

1回答

如何通过Google Cloud Pub/Sub API接收长时间运行的结果

当在Google Cloud API中启动长时间运行的操作时，该服务可能会返回具有“Operations”形状的对象。然后可以通过此对象查询操作的状态，并在完成时查询结果。我想避免为这些结果设置自己的轮询过程，我希望可以利用Google云端发布/订阅服务提供帮助。我的希望是来自阅读本线in the doc：（强调） ...客户端可以使用该接口通过轮询异步接收真实的反应操作资源，或通过操作资源添

0热度

1回答

云数据流窗口触发器覆盖从关闭窗口中的值

我在写一个从Pub/Sub读取的Dataflow（Beam SDK 2.0.0），计算窗口中的元素，然后将计数作为时间序列存储在BigTable中。窗户固定时间为1分钟。我的意图是使用触发器每秒更新当前窗口的值，以获得当前时间窗口的实时更新。但这似乎并不奏效。该值每秒都会正确更新，但一旦Dataflow在下一分钟开始工作时，第一个更新为零。所以基本上只有我的最后一个值是正确的，其余的都是零。

1热度

1回答

如何从python启动测试pubsub仿真器进行自动测试

我正在研究一个API API，其中一个端点是接收消息并将其发布到PubSub。目前，为了测试该端点，我必须从命令行手动启动一个PubSub仿真器，并在测试过程中保持它运行。它工作得很好，但它不适合自动化测试。我想知道是否有人知道一种方法来从python启动一个测试PubSub仿真器？或者如果任何人有更好的解决方案来测试这样的API？

4热度

1回答

Apache Beam - 无界PCollection集成测试

我们正在为Apache Beam管线构建集成测试，并且遇到了一些问题。请参阅下面的场景... 我们的管道详情：我们使用PubsubIO作为我们的数据源（无界PCollection）中级变换包括自定义CombineFn和一个非常简单的窗/触发策略我们最终的变换是JdbcIO，使用org.neo4j.jdbc.Driver写的Neo4j 电流测试方法：在机器上运行谷歌Cloud的发布/订阅模拟

0热度

2回答

使用Google云端pub实现MQTT

我想用python中的google app引擎的pubsub API实现MQTT。我如何在标准库中运行pub子库。如果我需要运行这个API的旧版本，任何人都可以提供样本。最新库的一个问题是它是alpha版本。稍后我将使用GCP-IOT协议连接MQTT客户端。

2热度

1回答

无法在c＃中运行Google Cloud PubSub，DLL问题

我正在将Google Cloud PubSub集成到我的c＃项目中，我使用NuGet安装1.0.0-beta11，完全没有任何错误。当我跑我的项目，当它到达使用发布订阅的代码，我得到以下错误： An unhandled exception of type 'System.IO.FileLoadException' occurred in Google.Api.Gax.dll Addition