问题标签 [google-cloud-pubsub]

我正在通过 pub/sub 将来自 gmail 的通知发送到网络服务器，

我已经阅读了他们提到的启用范围的文档

我通过代码指定以下范围

即使在为特定用户调用 watch() 之后指定了这些范围之后，它也给了我

那么我需要从谷歌控制台启用这些范围吗？如果是，那么你能告诉我们这样做的方向吗？

当前形式的 Google PubSub 看起来非常以 JSON 为中心。

假设我想发布可以被 hadoop 集群轻松摄取的数据。我的自然选择是在发布者端将数据序列化为 Avro，然后从 Hadoop 轻松使用它。

使用 PubSub 执行此操作的选项/最佳实践是什么？我想我可以将 Avro 打包到 JSON 结构的“数据”字段中，但这感觉有点尴尬。是否有二进制版本的 PubSub 即将推出？互联网上谈论了一些关于 gRPC 的支持，这对我有帮助吗？

我有两个项目 Project-A 和 Project-B。

在 Project-A 上，我有一个服务帐户loader@project-a.iam.gserviceaccount.com，我想用它来阅读来自 Project-B PubSub 主题的消息。

我在 Project-B 上创建了一个主题订阅projects/project-b/subscriptions/data。然后loader@project-a.iam.gserviceaccount.com在权限选项卡中添加为Subscriber. 我相信它应该给我访问权限。

但如果我尝试：

它返回空的权限列表。

对于实际的拉取请求：

它失败了：

我已经仔细检查了服务帐户是否在订阅者列表中，还尝试再次删除/添加它，等等。尝试了不同的项目。它不会改变任何东西。

如果我在同一个云项目下有 PubSub 主题订阅和服务帐户，那么它对于两者testIamPermissions和pull请求都可以正常工作。这是否意味着 IAM 服务帐户不能用于从另一个项目获取对 PubSub 的访问权限？

请注意，它适用于其他项目的存储访问。这意味着该问题仅针对 PubSub。这就是为什么我认为我在 PubSub 配置方面遗漏了一些东西。但究竟是什么？

我有一个相当简单的设置，其中有许多不同的工作人员监控不同的资源。当他们中的一个人发现新内容时，他们会向 Google PubSub 发布一条消息，然后我让一名工作人员拉取 PubSub 主题以获取消息并通过 Google Cloud Messenger 发送它们。

这应该非常简单，并且大部分都有效。但是，我遇到了一个有趣的情况，当我拉取时，我有时只会返回消息，如果 PubSub 主题为空，这将是有意义的。然而，这个话题并不是空洞的，而且还在不断扩大。我的工人拉的消息现在通常晚了大约 45 分钟。

根据 Stack Driver，我的 PubSub 消息队列现在有 10,000 条消息等待传递。:(

这是进行拉动的工人的代码：https ://github.com/Regner/en-notifications

显示消息队列的堆栈驱动程序图

其他一些信息： * 这一切都作为带有 Google Container Engine 的容器运行 * 我已经尝试启动更多的拉取容器副本，但它似乎并没有改变拉取消息的速度。

我真的很感激任何帮助弄清楚为什么会这样。这真的让我很困惑。

提前感谢您提供的任何帮助。

雷格纳

今天早些时候，我在日志中注意到以下错误：

我尝试搜索允许的同时拉取请求的确切数量，但似乎无法在任何地方找到它。我发现此错误的唯一提及是在 docs中，但同样没有说明数字。

我从订阅中提取了 40 个进程。

我正在设置一个主题并尝试授予 gmail 向该主题发送电子邮件通知的权限，但 API 调用抛出“用户无权执行此操作”。当我从https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/setIamPolicy尝试时，我得到了同样的错误。顺便说一句，我最近开始看到这个问题。它以前工作正常。

感谢任何帮助，谢谢。

在 android 中使用 Google Cloud Messaging 时遇到问题。我尝试在 developer.google.com 中运行示例，完成了所有步骤，还安装了 Google Play 服务。但是当我运行项目以获取 InstanceID 令牌时，我收到错误消息：“在获取 instanceID 令牌、将获取的令牌发送到服务器或订阅 PubSub 主题时发生错误。请尝试再次运行示例"

我正在尝试使用 'returnImmediately' = False 设置用户定义的消息拉取超时：

当超时 < 90 秒时，我收到以下错误：

谢谢。

I have a topic on PubSub, and I want to create a pipeline on dataflow that reads from the topic classifies them according to message data and further read the attribute key value pairs. Is there a way to differentiate between the message and attributes after they have transformed to PCollection using the PubSubIO's read transform?

我们一直在将我们的 api 从 python 移动到 node。我们在 Python 应用引擎 API 中使用了任务队列。随着应用引擎现在支持 node.js，您是否建议我们使用任务队列或云发布/订阅来执行任务？每种方法的优缺点是什么，包括可靠性、便携性等。