-
3 votesanswersviews
GMB API - 与PubSub合作以获取实时审核通知
我已经在我们的平台中集成了GMB API,并与PubSub合作以获得实时评论通知 .我已经完成了以下步骤: 在google PubSub Cloud 上 Created topic . 使用有效的https网址创建了subscription of push type . Updated Google Business Account Notification,主题在第一步中创建,包含所... -
4 votesanswersviews
推送机制:在webhook endpoints 上进行身份验证
我很好奇auth如何适用于Push机制 . 它需要订户上的 endpoints 必须可以通过互联网访问,因此pubsub客户端将验证推送的消息是否确实来自谷歌?或是由订户实施? 如果它留给订阅者建议的方式来实现它? -
3 votesanswersviews
继续使用Google Cloud PubSub获取'Error sending test message to Cloud PubSub…'
我正在尝试将Google推送PubSub设置到我的服务器以接收Gmail推送通知 . 我得到以下范围: https://mail.google.com/ https://www.googleapis.com/auth/cloud-platform https://www.googleapis.com/auth/pubsub https://www.googleapis.com/au... -
0 votesanswersviews
当我们使用Google Cloud PubSub和Fluentd订阅者时,如何使消息具有幂等性?
我正在尝试使用Google Cloud PubSub和Fluentd订阅者生成日志数据 . 该体系结构是,首先,一组Web服务器将其访问日志发送到同一PubSub endpoints ,其次,Fluentd服务器从PubSub endpoints 提取日志并将它们发送到Google BigQuery和其他子系统 . 我的问题是如何在这样的架构中保持信息幂等 . 根据Google Cloud Pub... -
2 votesanswersviews
在app引擎上推送pubsub消息导致403错误
我正在尝试将google pubsub集成到我的项目中 . 到目前为止,我设法让每一个工作(创建/删除主题/订阅发布和拉取消息)除了推送 endpoints ,我无法向他们发送消息 . 我正在使用app engine flex环境,并使用此代码作为示例:https://github.com/GoogleCloudPlatform/cloud-pubsub-samples-java/tree/mas... -
0 votesanswersviews
无法在我的终端上看到Google Pub / Sub Push Notifications
我已经配置了Google Pub / Sub主题,可以从中成功拉出 . 我还配置了Push订阅,但我的 endpoints 似乎没有从它接收任何消息 . 我有一个可公开访问的HTTPS服务器,其中有一个由证书颁发机构签名并可由DNS路由的有效SSL证书 . 我已经注册了 endpoints ,首先验证我是否可以访问域,然后根据here说明在Google Cloud Platform Console... -
0 votesanswersviews
从pub / sub流入大查询python时出错
我通过插入以下两个来创建将pub / sub源连接到大型查询接收器的dataflowRunner作业时遇到问题: apache_beam.io.gcp.pubsub.PubSubSource apache_beam.io.gcp.bigquery.BigQuerySink 分别在github上的beam / sdks / python / apache_beam / examples / str... -
0 votesanswersviews
在Dataflow管道中写入BigQuery时捕获失败
我有一个Dataflow管道从PubSub主题读取事件数据 . 收到消息时,我会执行转换步骤,以使事件数据适合我想要的BigQuery架构 . 但是,如果我创建的输入不适合模式,我会遇到问题 . 显然,写入BigQuery是无限重试的: Count: 76 RuntimeError: Could not successfully insert rows to BigQuery table 目... -
1 votesanswersviews
从Dataflow流式传输时从BigQuery中删除数据
是否可以在从Apache Beam管道将数据加载到BigQuery表中时从BigQuery表中删除数据 . 我们的用例是这样的,我们需要根据时间戳字段(Dataflow从Pubsub主题中提取消息的时间)从表中删除3天的先前数据 . 建议做这样的事吗?如果是的话,有没有办法实现这个目标? 谢谢 . -
0 votesanswersviews
根据消息内容从Dataflow作业写入动态PubSub主题
我想根据字段的内容动态地将PCollection的不同元素路由到不同的PubSub主题 . 主题不是持久的,但是假设它们在运行时执行PubSubIO.Write()时存在 . 因此,Dataflow应该仅在每个消息的基础上在运行时推断它们的名称 . BigQuery和动态表名称存在此功能:https://beam.apache.org/documentation/sdks/javadoc/2.0.... -
0 votesanswersviews
Apache Beam Dataflow:'NoneType'对象没有属性'parts'
我正在尝试编写一个管道来读取pubsub中的流,并使用带有apache beam的谷歌 Cloud 数据流将其写入bigquery . 我有这个代码: import apache_beam as beam from apache_beam.transforms.window import FixedWindows topic = 'projects/???/topics/???' table =... -
3 votesanswersviews
如何使用Java通过Push in Cloud Pub / Sub接收消息
我正在尝试使用Java实现Google Cloud Pub / Sub来接收消息(通过Push)但我找不到Java的文档 . 我能够通过pull接收消息,也可以在本地设置和测试 endpoints 的任何线索都非常有帮助 . 我已经验证并添加了域名作为 endpoints ,想知道下一步该做什么以开始在该 endpoints 接收消息 . -
11 votesanswersviews
推送订阅中的Google Cloud Pub / Sub - INVALID ARGUMENT错误
我创建了一个主题,然后尝试使用"Push"交付类型创建订阅 . 当我使用域https://www.omnea.com/push/google-handler(链接不存在)时,它的工作原理 . 但是,当我使用url https://apidev2.omnea.org/push/google-handler时,它会抛出INVALID_ARGUMENT错误 . 两者都具有相同的证书颁... -
2 votesanswersviews
GCloud Pub / Sub Push订阅:限制最大未完成消息
推送订阅配置中是否有一种方法可以限制未完成消息的最大数量 . 在高级订户文档(https://cloud.google.com/pubsub/docs/push)中它说"With slow-start, Google Cloud Pub/Sub starts by sending a single message at a time, and doubles up with each s... -
2 votesanswersviews
Google Cloud Pub / Sub支持Letsencrypt证书吗?
这个问题是对Unable to configure Google Cloud Pub/Sub push subscriber的跟进 根据答案,使用推送订户时不支持自签名证书 . 是否支持通过letsencrypt客户端生成的证书?是否建议使用letsencrypt? -
5 votesanswersviews
Google Pub / Sub订阅创建期间推送 endpoints 错误无效
我已经浏览了Google网站上的所有prereqs . 在服务器上获得并安装了SSL证书(来自Let的加密) . 在Google Search Console上注册并验证了域名(是的,https网址)(例如https://example.org) . 已将域添加到我的API Credential的Domain Verification . topic ='projects / m... -
0 votesanswersviews
Google Cloud Pub / Sub:无法从GAE endpoints URL获取请求PUSH
我已将myapp部署到Google App Engine,并进行了设置 runtime: nodejs env: flex 我的应用域名是 https://myapp.appspot.com 但它被自动重定向到 https://myapp.appspot-preview.com 我还创建了Google Pub / Sub主题并添加了订阅,将Push endpoint url设置为 ht... -
2 votesanswersviews
无法使用服务帐户订阅Google Pub子主题
我试图了解此链接中存在的Google Cloud 端示例中给出的示例 IAM Example 此示例创建服务帐户,VM和发布/订阅主题 . VM作为服务帐户运行,并且服务帐户具有订阅者对Pub / Sub主题的访问权限,从而使在VM上运行的服务和应用程序访问Pub / Sub主题 . 但是,当我尝试部署此示例时,我遇到了错误 The fingerprint of the deployment i... -
6 votesanswersviews
我可以在不同的Google Cloud 项目中使用Google Cloud Pub / Sub吗?
假设我在Google Cloud中有项目A,B和C,每个项目都有几个 Cloud 功能 . 我想在项目C中设置一个Pub / Sub,这样A和B中的函数就可以订阅 . 这可能吗?我是否需要使用自定义权限设置某种服务帐户? 谢谢 -
0 votesanswersviews
GCP App Engine,Spring Boot和Pub Sub结果为403
我可以将Spring Boot(2.1.1.RELEASE)部署到App Engine,并且可以访问/并获得一个hello world . 出现的问题是当我将Googles Pub Sub库包含到Gradle构建文件中时 . 当我在403中部署击中/结束时,所以我不太确定会发生什么 . 幕后可能存在某种依赖问题?我的build.gradle就是这个 buildscript { ext.k... -
0 votesanswersviews
GCP PubSub主题推送问题
我有一个部署在gke(gcp)上的nodejs docker image app . 这个应用程序只是一个等待通知的消息订阅者 . 我创建了一个主题(pubsub) . 我试图添加订阅,以便我的应用程序可以得到通知 . 但我没有设法做到这一点 . 我试图在谷歌凭证(API和服务/凭证)中添加IP(域),但过程非常阴暗 . 为什么要验证在gcp中部署的应用?有办法吗?谢谢 -
3 votesanswersviews
Dataflow管道和pubsub模拟器
我正在尝试设置我的开发环境 . 我一直在使用pubsub模拟器进行开发和测试,而不是在 生产环境 中使用google cloud pubsub . 为此,我设置了以下环境变量: export PUBSUB_EMULATOR_HOST=localhost:8586 这适用于python google pubsub库但是当我切换到使用java apache beam for google dataf... -
1 votesanswersviews
Google Cloud 监控:如果发布成功并且订阅失败,请添加提醒
我想在Google Cloud Monitoring上添加一个提醒,以便对于给定的主题和订阅,我想知道某个主题是否正在发布,那么订阅在给定的时间范围内不会以相同或相似的速率进行确认 . 我们如何使用Google Cloud Monitoring或StackDriver中的提醒来实现这一目标? 我尝试了一种方法,我有两个条件来满足: 如果发布操作> 0.016 /秒,持续2分钟(意味着每分... -
9 votesanswersviews
如何限制Google Cloud Pub / Sub Queue
我正在使用Google的Pub / Sub队列来处理服务之间的消息 . 一些订户连接到速率限制API . 例如,我正在将街道地址推送到pub / sub主题 . 我有一个Cloud功能,可以订阅(通过推送)到该主题,并呼叫外部速率限制地理编码服务 . 理想情况下,我的街道地址可以毫不拖延地推送到主题上,主题将保留这些消息 - 以限速的方式呼叫订户 . 无论如何配置这样的延迟或消息分发率限制?增加A... -
0 votesanswersviews
Gmail观看 - 发布/订阅 - 订阅者停止接收推送通知
我在我的应用程序的Google Cloud 项目中启用了Pub / Sub . 我有一个主题和订阅,许多用户订阅了这个主题 . 我的服务器正在接收除一个用户以外的所有用户的收件箱更新通知 . 我们收到该用户的推送通知,直到几周前 . 我尝试为该主题重新订阅用户,并且呼叫成功 . 不过,我的服务器还没有获得该用户的推送通知 . 关于为什么会发生这种情况以及如何解决这个问题的任何想法? 感谢致敬, 拉... -
2 votesanswersviews
Gmail API推送通知提供错误403
我正在尝试获取有关我在电子邮件中收到的所有新收件箱邮件的推送通知 . 我已经配置了pubsub doc中提到的pubsub客户端 . 以下是代码: import httplib2 from apiclient import discovery from oauth2client import client as oauth2client from lib.common.models.main.u... -
0 votesanswersviews
NoSuchMethodError:com.google.api.gax.rpc.ApiClientHeaderProvider $ Builder.setGeneratorHeader
我已经开始使用谷歌 Cloud pub / sub,当我试图发布消息到一个主题低于错误 . 线程“main”中的异常java.lang.NoSuchMethodError:com.google.api.gax.rpc.ApiClientHeaderProvider $ Builder.setGeneratorHeader(Ljava / lang / String; Ljava / lang / ... -
3 votesanswersviews
无法配置Google Cloud Pub / Sub推送订阅者
我有一个由计算引擎实例组成的Google Cloud项目,我希望将其配置为Cloud Pub / Sub服务的推送订阅者 . 我已经在实例上设置了一个带有自签名证书的apache webserver,并且还创建了一个DNS条目(abc.mydomain.com),该条目指向具有静态IP地址的实例 . 我已经是网站管理员的域名(mydomain.com)的经过验证的所有者 . 每当我从Cloud控制... -
4 votesanswersviews
Kubernetes动态工作扩展
我终于在kubernetes池中浸泡我的脚趾,并希望得到一些建议,以解决我遇到的问题的最佳方法: Tech we are using: GCP GKE GCP Pub / Sub We need to do bursts of batch processing spread out across a fleet and have decided on the following a... -
0 votesanswersviews
为什么可迭代操作会在Apache Beam函数中抛出错误?
我在一个 Iterable Java集合上调用此函数,由 GroupByKey 函数产生: static class FindCompleteOrder extends DoFn<KV<String, Iterable<Order>>, Order> { String COMPLETE_EVENT_NAME = "COMPLETE"...