问题标签 [google-cloud-pubsub]

我从 git 存储库中获取了代码，并尝试按照readme.md说明运行该代码，但对于我获取 mojoException 没有任何作用。我使用 mavengcloud:run和gcloud:deploy命令作为项目运行。完整的细节错误信息如下---

建议我做错了什么？代码源是Git存储库链接如下

https://github.com/GoogleCloudPlatform/cloud-pubsub-samples-java/tree/master/appengine-push

我正在尝试让新的 Gmail 推送通知按此处详细说明工作

https://developers.google.com/gmail/api/guides/push

我已经设法让它的发布订阅端正常工作（创建主题、订阅并且可以发布和拉取消息），但它在步骤中失败了

授予您主题的发布权

我使用的客户端（.Net）不支持所需的方法，所以我使用的是 API Explorer。使用资源管理器我生成以下请求。

这会产生一个响应错误

不确定问题是什么 - 有没有人按照规定设置发布权成功？

我正在使用带有 Gmail 的 pubsub 来推送通知。

pubsub 订阅按预期接收消息。

但是，当我拉出消息时，我注意到如果没有消息可以拉出，则获得响应的延迟非常慢。

如果至少有 1 条消息要拉，那么响应是及时的

有没有其他人经历过这个？

我能想出的唯一解决办法是在队列上留言。

我一直在使用 Google App Script 上的 Pub/Sub REST API。

我尝试在 script.google.com 上创建一个带有推送端点的订阅者，但没有成功。推送端点 URL 是使用StateTokenBuilder API创建的，它要求端点 URL 上存在查询参数。查询参数进一步用于将 URL 上的任何请求转发到应用程序内的 javascript 函数。

是否允许有一个带有查询参数的推送端点 URL？

但是，即使允许，我也无法在域 script.google.com 上注册推送端点。我需要声明对 apppot.com 以外的任何域的所有权。

你们知道任何解决方法吗？难道我做错了什么？

这是我得到的错误：

谢谢！

通过https://cloud.google.com/nodejs/getting-started/using-pub-sub工作时出现错误。（我已经成功地完成了该系列之前的教程。）

使用命令“SCRIPT=worker.js PORT=8081 npm start”，我收到与 background.js 相关的错误：

想法/解决方案？

谢谢！

有没有办法为谷歌云发布/订阅中的消息指定保留期？假设我有一个订阅者开始消费消息，但服务崩溃并在错误修复后的一天后重新上线。它可以从最后一个检查点继续吗？消费者需要多久重新连接到 pub/sub 以保证它不会丢失任何消息？

同样，Amazon Kinesis 可以将消息保留长达 24 小时，而 Kafka 可以根据时间或/和磁盘空间制定保留策略。

我正在为 Google Pub/Sub 使用 PHP Client API，并注意到每当我尝试通过 PubSub 服务对象发出请求时，它都会生成错误的 API uri。

例如，我尝试请求项目主题列表如下：

API 附带一条错误消息：

Google_Service_Exception：调用 GET https://www.googleapis.com/v1beta2/projects/my-1/topics时出错：（404）未找到

问题是：生成的 Uri 是错误的。应该是https://pubsub.googleapis.com/v1beta2/projects/my-1/topics

有人知道解决方法吗？我正在使用来自以下位置的最新 API 代码：

github.com/google/google-api-php-client/blob/master/src/Google/Service/Pubsub.php

现在，我有以下代码：

我有一个正在运行的流数据流来读取 PUB/SUB 订阅。

经过一段时间或可能在处理一定数量的数据后，我希望管道自行停止。我不希望我的计算引擎实例无限期地运行。

当我通过数据流控制台取消作业时，它显示为失败的作业。

有没有办法做到这一点？我错过了什么吗？或者 API 中缺少该功能。

我有一个从 PubSubIO 读取的云流管道，其中“PipelineOptions”设置为“WorkerMachineType = n1-standard-1”。这台机器有3.75GB的内存。

我的问题是，如果订阅有很多消息，管道读取速度非常快，当开始处理许多元素时，它没有足够的内存。

有什么形式可以减少每秒读取的消息数量吗？还是内存消耗与分配给窗口的持续时间有关，我会减少这个持续时间？

谢谢是提前。