google-cloud-pubsub

0热度

1回答

简单gcloud数据流管道： PubsubIO.readStrings（）fromSubscription - >窗口 - >帕尔 - > DatastoreIO.v1（）写（）当负载被施加到。 PubSub的话题，消息读取而不能ACKED： 2017年7月25日下午4点20分38秒org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource $

1热度

1回答

App Engine中的PubSub标准Java 8：ApiProxyImpl上的NullPointerException $ CurrentRequestThreadFactory.newThread（ApiProxyImpl.java:1267）

在新的App Engine标准Java 8环境中，尝试发布到PubSub主题时出现以下错误： io.grpc.internal.ChannelExecutor drain: Runnable threw exception in ChannelExecutor (ChannelExecutor.java:89) java.lang.NullPointerException at com

0热度

1回答

摄入系统应该在哪里出现？

我试图设计一个物联网系统，它将许多物联网设备发送不同类型的传感器数据到前端负载均衡服务器，然后将消息发送到摄取系统（目前认为Google Cloud PubSub）。然后有消费者使用消息并将它们写入不同的数据库和表。每个传感器数据类型都有自己的数据库。扇出发生在哪里？之前发布订阅系统：如果前端做扇出，那么它必须被缩放足够大，有足够的处理能力来看待每封邮件的内容找出将其发送结束这话题。然后，我将

0热度

1回答

不能看到我的终点

我已经配置了谷歌发布/订阅主题，可以从它成功地拉谷歌发布/订阅推送通知。我也配置了一个Push订阅，但我的端点似乎没有收到任何消息。我有一个公开访问HTTPS服务器，由证书颁发机构和路由通过DNS签订了有效的SSL证书。我已经注册了端点，首先验证我是否有权访问该域，然后按照说明here在Google Cloud Platform控制台上注册端点。我没有防火墙，并检查了我的端点的日志。我可以从

1热度

1回答

谷歌pubsub流量控制

我试图实现一个服务，消费谷歌pubsub订阅在自己的步伐。由此，我的意思是我需要良好的控制，当我需要消费消息，即获得一批消息，暂停一段时间，不会得到超过X消息... 使用谷歌客户端库，我没有找到作为MessageReceiver在其自己的线程中运行的一种方式，并且我无法控制究竟发生了什么。基本上，能够以同步方式使用消息应该可以解决我的问题。你知道我怎么可以同步使用google客户端库吗？或者我

0热度

1回答

错误从发布/订阅洒进大查询蟒蛇

我无法创建一个发布/订阅源连接到一个大的查询水槽dataflowRunner工作，通过插入两个： apache_beam.io.gcp.pubsub.PubSubSource apache_beam.io.gcp.bigquery.BigQuerySink 成线59和74分别在github上的beam/sdks/python/apache_beam/examples/streaming_wo

0热度

1回答

如何将超时设置为Google Pubsub发布者和订阅者？

在我的java代码中，我使用Google -pubsub。我怎样才能设置用户超时 - 等待消息，直到超时？（我如何设置重试策略？）发布者 - 等到邮件发送时间为timeout时。（如何设置一个重试策略？）我看到这个post但没能翻译JS后去渣这是我如何设置我的子 final Subscriber subscriber = Subscriber .defaultBuild

0热度

1回答

如何配置谷歌pubsub使用队列机制？

我使用Google pub-sub（java）作为pub和sub。我找不到启用队列机制的方法。如果出版商发送消息之前，用户达含义，则消息不会丢失，并等待用户来获取。也许当我创建频道？ public void init(final String projectId, final InputStream inputStream) throws IOException { this.p

0热度

1回答

谷歌云pubsub订阅是否可以自动删除？

从DOC：订阅没有活动（推成功或拉请求）31天可自动删除我需要设置其使用率可能会非常推送消息订阅低（每年几封邮件），但对应用程序至关重要。从官方文档上面的句子让我跳！我应该依赖谷歌pubsub还是远离它？有关于此自动机制的更多信息吗？需要建议。

5热度

1回答

错误的请求，从谷歌的AppEngine到酒馆子

后，我进行了更新app engine (1.9.54)和Java version (1.8)当我做出的发布 - 订阅的请求，我得到这个错误：您正在使用 java.lang.IllegalAccessError: com/google/appengine/repackaged/com/google/common/base/Platform at com.google.appengine.