问题标签 [google-cloud-pubsub]

我正在尝试做的事情

我正在使用 Gmail API + Google Pub/Sub API 向我在 EC2 实例上运行的节点服务器发送推送通知，每次我在watch()ed 收件箱上收到一封电子邮件。我将服务器的域添加到console.developers.google.com的 Push 部分，然后对于 Pub/Sub API，我创建订阅并添加 Push Endpoint URL。端点看起来像这样：https://example.com/receive.

我想做的是在本地进行测试。

问题

如何让 Google 向我的本地主机服务器发送推送通知？当我测试时，我希望将新电子邮件的通知发送到http://localhost:8080/receive. 我正在考虑使用ngrok来公开 localhost - 但问题是每次 ngrok URL 更改时我都必须手动上传 Google 的证明（我拥有该域），这是一个非常令人头疼的问题。

在我的本地主机服务器上接收新电子邮件通知是否存在更好的方法？

我想使用 Google Cloud Dataflow 将来自主题的 PubSub 消息数据插入到 BigQuery 表中。一切都很好，但在 BigQuery 表中，我可以看到不可读的字符串，例如“ ∈���”。这是我的管道：

我简单的 StringToRowConverter 函数是：

这是我通过 POST 请求发送的消息：

我错过了什么？谢谢！

在为现有主题创建订阅时，似乎 api 正在超时。我的验证这一点的测试一直有效，直到几分钟前，但现在它们开始失败。我什至无法使用 Google 的控制台创建订阅。

尽管谷歌的仪表板显示服务正在运行。还有人看到这个吗？我不确定我还能做些什么来收集更多信息。

我有一个 Google Cloud 项目，其中包含一个计算引擎实例，我想将其配置为 Cloud Pub/Sub 服务的推送订阅者。我已经在实例上设置了一个带有自签名证书的 apache 网络服务器，并且还创建了一个指向具有静态 IP 地址的实例的 DNS 条目 (abc.mydomain.com)。我已经是网站管理员上域 (mydomain.com) 的经过验证的所有者。

每当我从云控制台添加订阅时，它都会失败并显示错误：“无法添加订阅”并且不显示任何其他有用信息。

请帮忙。

我正在尝试在需要连接到同一项目中的 Pub/Sub 请求订阅的 Dataproc 集群中运行 Spark (scala) 作业，但我收到以下错误消息。我认为我的 Dataproc 集群中的机器缺少“ https://www.googleapis.com/auth/pubsub ”范围。

我可以向 Dataproc 集群的机器添加额外的身份验证范围吗？

PS：如有必要，重新创建集群不会有问题。

我正在尝试将Google Cloud PubSub与我的Google Cloud Dataproc集群一起使用，但我收到了如下所示的身份验证范围错误：

如何解决此问题，以便在 Cloud Dataproc 上运行的 Spark/Hadoop 项目中使用 PubSub（和其他 Google Cloud）产品？

我目前正在试验 Google Cloud PubSub 的go 库并同时查阅文档。

我的代码测试了PullWait函数的行为，根据文档执行以下操作：

PullWait 从订阅中拉取消息。如果订阅队列中没有足够的消息，它将阻塞，直到至少有 n 条消息到达或发生超时，并且 n 不能大于 100。

但是，我的测试表明，无论n指定的值如何，我总是会立即收到mm <= n 的消息。我在这里错过了什么吗？

使用的代码摘录：

当时队列只包含一条消息，立即返回给我：

2015/11/04 11:45:15 消息 [msg-id=2384294654226]: '你好，我的朋友'

我在我的项目Project 1中创建了一个主题，并且我在 Google 应用引擎上有一个应用程序，它每分钟都会向该主题发布一条消息。

我在第二个项目（项目 2 ）中有一台谷歌云计算机，它订阅了这个主题并接收消息。

我没有在我的Project 2上授予对机器的任何访问权限，但即使没有访问权限，它也设法接收消息。更准确地说，我没有写与我创建的主题相关的特定权限。

我的问题是：

1-这是正常的吗？Project 2上的机器不应该出现“禁止访问错误”吗？

2-如何限制对某个主题的访问？

这是我的订阅部分的代码：

这个问题是无法配置 Google Cloud Pub/Sub 推送订阅者的后续问题

根据答案，使用推送订阅者时不支持自签名证书。是否支持通过letsencrypt客户端生成的证书？是否建议使用 letencrypt ？

我正在尝试获取有关我在电子邮件中收到的所有新收件箱消息的推送通知。我已经按照 pubsub 文档中的说明配置了 pubsub 客户端。以下是代码：

当我运行上述程序时，遇到以下错误：

回溯（最近一次通话最后）：文件“/home/kmittal/workspace/engine/workers/newPubSubClient.py”，第 82 行，在 service.users().watch(userId='me', body=request).execute () 文件“/usr/local/lib/python2.7/dist-packages/oauth2client/util.py”，第 135 行，在 positional_wrapper 中 return Wrapper(*args, **kwargs) 文件“/usr/local/lib/ python2.7/dist-packages/googleapiclient/http.py"，第 723 行，在执行 raise HttpError(resp, content, uri=self.uri) googleapiclient.errors.HttpError: https://www.googleapis.com/gmail /v1/users/me/watch?alt=json 返回“无效的 topicName 与项目不匹配/SOME_ANOTHER_PROJECT/topics/*”>