问题标签 [google-cloud-pubsub]

在他的 Google I/O 2009“App Engine 上的离线处理：前瞻”演示文稿（视频、幻灯片）中，Brett Slatkin 介绍了任务队列服务。

他说

Pub-sub 系统最大化交易，解耦：

• 每秒大量的小事务
• 具有更改接收器的一对多扇出
• 保证排序、过滤、两阶段提交

并特别强调

我们的新 API 实现了排队，而不是 pub-sub

我只对这些功能的一部分感兴趣：

• 一对多扇出改变选定/固定的内部接收器处理程序
• 保证订购, 过滤, 两阶段提交

目标是简化同一 Web 应用程序的不同模块之间的通知/消息的发布。示例使用场景案例将是：

• 使支付模块知道收到账单。
• 使用户能够跟踪他决定关注/加注的特定域对象的更改。

在任务队列服务之上实现这些的正确方法是什么？

我正在尝试使用 Google App Engine 实现 pubsub 消息传递。我希望能够将回调存储到其他服务器，然后在可用时向它们发送新数据。

我已经环顾四周，但除了自己实施之外似乎无法提出任何建议。我看过 pubsubhubbub： https ://code.google.com/p/pubsubhubbub/wiki/DeveloperGettingStartedGuide 但我希望能够存储查询参数。例如，Xmpp xep 60 包括使用附加数据（称为选项）配置订阅的功能。

App Engine 中的 XMPP 服务似乎没有 pubsub 扩展。

将我们自己的收件人列表管理为： https ://groups.google.com/forum/#!topic/google-appengine/CaBcX0EWO00 似乎是唯一的选择？

App Engine 似乎已经考虑使用设备实现： javascript 通道： https://developers.google.com/appengine/docs/python/channel/

设备的 CloudBackendMessaging： https ://developers.google.com/cloud/samples/mbs/pubsub_messaging

我需要直接从浏览器使用 Google Cloud Pub/Sub API（类似于 GA 脚本）。我想知道如何在不需要通过后端服务器的情况下处理 Auth。

我想直接从浏览器调用 Cloud Pub/Sub API。我试过了，它说我需要先进行身份验证，我的问题是如何保护 Auth Token。

是否有任何可用的 javascript 库可供我在浏览器（而不是后端）中使用来调用 Google Pub/Sub API。

提前致谢

我是 pubsub 服务的新手，无论我在网站或 java 示例中尝试了什么，我都无法让它工作。我打开了这个链接https://cloud.google.com/pubsub/reference/rest/v1beta2/projects/subscriptions/create 然后打开“使用 OAuth 2.0 授权请求”然后在name字段中写“aaa”并单击执行。结果如下（我在java App中得到的结果相同）

我创建了一个使用推送端点订阅的主题。端点是一个简单的 AppEngine Web 服务。Google PubSub 文档声明端点必须由 HTTPS 保护。

我没有收到推送端点的任何流量。AppEngine Web 服务未显示任何请求。我已通过 Google PubSub 仪表板验证消息已成功发布在该主题上。仪表板显示推送订阅的unreachable_ssl_error。为什么 Google PubSub 会报告此错误？

当我尝试通过浏览器访问 SSL AppEngine 端点时，我也会收到 SSL 证书错误。这对于 AppEngine 网站是否正常？

我们想在 Google Cloud 上构建一个主从模式。我们计划为此使用 Pub/Sub（类似于JMS模式）让每个工作人员从队列中获取任务并在完成后确认。

但是，订阅者似乎无法在开始之前收到发送的消息。而且我们不确定如何确保每条消息都由单个“从属”处理。

有没有办法做到这一点？或者谷歌云上的另一种机制？

我已经使用 Google Cloud Dataflow SDK 编写了一个流式传输管道，但我想在本地测试我的管道。我的管道从 Google Pub/Sub 获取输入数据。

是否可以使用 DirectPipelineRunner（本地执行，不在 Google Cloud 中）运行访问 Pub/Sub (pubsubIO) 的作业？

以我的普通用户帐户登录时遇到权限问题。我是项目的所有者，我尝试访问的 pub/sub 主题。

我想使用 com.google.cloud.dataflow.examples.PubsubFileInjector 将 GCS 文件转换为 pubsub 事件。

但是，当我提交管道时，如下所示：

管道运行时出现以下错误：

但是我确定我的主题名称是正确的。它遵循https://cloud.google.com/pubsub/overview#names中所述的规则。当我列出我所有的主题时，主题就会出现。

我有两个问题

1) 我想将 Kafka 与 Google Cloud Dataflow Pipeline 程序一起使用。在我的管道程序中，我想从 kafka 读取数据有可能吗？

2) 我创建了启用 BigQuery 的实例，现在我想启用 Pubsub 我该怎么办？

I've been working in pubsub where I can successfully pull the data from a particular topic under a particular project in java. If I've to show these data in html, first I've to call the servlet method, then the servlet will call pubsub api to get the data, then I've to include that data in the response.

Since it involves an additional one layer (java) to access the data, is it possible to directly fecth the data in javascript call by skipping the java call..? Is there any api's available in google pubsub to serve for that purpose?