我在mongodb云平台中有一个节点js应用程序，它将用于发布100万条消息到GCP pubsub.Since中的一个主题平台不支持npm包@google- cloud /pubsub，我们使用APIreference for Pubsub.Upon负载测试应用程序来实现它，我可以看到每条消息发布到topic.Ideally需要50秒它应该花费不到5 secs.It大约3
浏览 20提问于2021-02-04得票数 1
下面的代码从->源主题获取消息，并根据模板pubsub对其进行转换，然后将转换后的消息发布到目标主题。但是为了提高性能，我需要在parallel.That中完成这个任务，我需要轮询500条消息，然后并行转换它，然后将它们发布到目标主题。我的意思是a)如果我轮询了500条消息，它是否会创建500条并行路由来处理消息并将其发布到目标主题b)消息
浏览 4提问于2020-04-29得票数 1
是否可以从GCP外部将事件发布到云发布/订阅？ 让我来澄清一下我的疑问。在亚马逊网络服务中，我们可以通过API Gateway从非云客户端(https://github.com/cdk-patterns/serverless/blob/master/the-big-fan/README.md)调用REST API来直接将事件发布到SNS主题中，那
浏览 16提问于2020-09-07得票数 1
我正在使用PubSub来捕获实时数据。然后使用GCP数据流将数据流式传输到BigQuery中。我正在使用Java进行数据流。目前，我正在将字符串格式的消息发送到PubSub (这里使用Python )。但是数据流中的模板只接受JSON消息。python
浏览 18提问于2018-02-21得票数 0
我的Apache Camel应用程序从gcp pubsub subscrption producer-sub获取消息，然后在处理和转换消息后将它们放入gcp pubsub topic1中。这是我的camel订阅代码
from("google-pubsub://mygcpcloudpubsub-270721:producer-sub?to("google-pubsub://mygcpcloudp
浏览 7提问于2020-05-28得票数 0
我们正在GCP数据流中运行管道，并遇到pubsub消息1的最大消息大小。当发生这种情况时，管道延迟时间将开始累积，最终将陷入停顿…… 此日志消息是在GCP堆栈驱动程序的'dataflow_step‘下生成的， 我的问题是，有没有一种方法来定义管道中的错误处理... .apply.to("topic")
.withTimestampAttribute(Instant.now().toString
浏览 14提问于2019-01-15得票数 1
需要帮助来获得一些帮助，以发布来自GCP(Google Cloud Pubsub)的所有消息到远程运行的Kafka主题
我使用了"“中的连接器代码，并且能够将数据从GCP移动到Kafka主题。Kafka和连接器在同一台机器上运行，现在我只需要有连接器代码，并将来自PubSub的消息添加到远程运行Kafka主题
浏览 0提问于2019-04-15得票数 0
我正在使用以下GCP发布/订阅REST API来拉取和确认消息。拉取消息：-{"returnImmediately": "false",
"maxMessa
浏览 5提问于2021-11-25得票数 0
有人有关于如何通过CURL类型的命令直接从PubSub发布消息到GCP PubSub主题的工作示例吗？
我有一个服务
浏览 5提问于2018-01-11得票数 7
回答已采纳
1回答
我们需要将标签应用于下面的GCP ServicesBigquery,Pubsub服务的数量将跨越多个GCP projects我们将一次将标签应用于所有资源，利用来自Python下面的PATCH方法实现APIs自动化。/docs/reference/rest/v1/projects.topics/patch
https:/
浏览 3提问于2020-09-06得票数 0
回答已采纳
我正在尝试使用与gcloud PubSub相同的凭据将消息发布到GCP CLI，但并未取得太大成功。我可以通过执行以下操作来确认我可以发布到某个主题
gcloud pubsub topics publish myTopic --project "myProject" --message "Hello但是，当我尝试使用与gcloud完全相同的凭据时，请使用</em
浏览 0提问于2020-03-10得票数 0
我正在升级以前使用RabbitMQ的队列处理系统。
我目前正在导入RabbitMQ中的死信和指数回退功能，但是我似乎遇到了一些问题。主要的问题是，当我使用死信策略创建一个新的订阅时，它似乎没有必要的相关权限，以便Google将消息转发到我的死信订阅。如下所示，在检查订阅详细信息时，google强调了项目的pubsub服务帐户需要发布者角色和订阅者角色，以便发布和转发到死信主题。有没有人知道我到底漏掉了什么，我已经看了所有的文档，但不完全清楚，我试着将I
浏览 1提问于2020-09-28得票数 2
是否可以通过基本的PubSub请求发布到GCP PubSub主题？我有一个Cloudflare工作人员，我想从它直接发布到一个主题。似乎在PubSub API上不支持API密钥，而且在我的一生中，我无法在不使用SDK的情况下找到使用服务帐户的方法。
浏览 5提问于2019-09-20得票数 1
当上传文件到GCP桶时，我面临下面的错误。很少有记录超过GCP允许的(10000000字节)。我有一个可以在GCP中上传文件的Python脚本，它使用上传blob功能。google.cloud.pubsub_v1.publisher.exceptions.MessageTooLargeError：：错误:正在发布的消息将产生太大的发布请求，超过后端上允许的最大大小(10000000
浏览 1提问于2021-08-31得票数 0
我使用的是Google发布/订阅教程中的示例代码。尝试发布消息时，抛出异常: 503无法连接到所有地址。我为服务帐户分配了发布/订阅发布者角色。直到前天，一切都很好。从控制台或gcloud命令发布消息时没有问题。Cloud Functions是我的订阅。_client.api.publish(
File "E:\gcp-pubsub-cs\lib\site-pack
浏览 176提问于2021-07-23得票数 0
回答已采纳
我正在使用spring boot与pubsub主题进行交互。;import org.springframework.cloud.gcp.pubsub.support.PublisherFactory;impor
浏览 2提问于2020-01-08得票数 0
我有一个AppEngine应用程序，可以向PubSub发布消息。现在，我想从一个不同的GCP项目中阅读这些消息。使用com.google.apis/google-api-services-pubsub v1-rev8-1.21.0和服务帐户密钥是可能的。
我以的例子为指导。代码的某些部分有点难看(例如需要一个RetryHttpInitializerWrapper)，所以我想知道是否可以使用com.google.cloud&#
浏览 5提问于2016-11-17得票数 0
回答已采纳
1回答
我们很难将消息发布到Google AppEngine上的Google主题。使用应用程序默认凭据在本地工作非常完美。但是，一旦部署到Google AppEngine上，就会出现以下错误：
<HttpError 403 when requesting https://pubsub.googleapis.com/v1/projectsPlease pass a valid API key wit
浏览 2提问于2015-09-15得票数 3
回答已采纳
我正在尝试使用GCP Java SDK通过以下代码向发布/订阅主题发送消息(在此代码片段中用占位符替换实际的项目ID和主题名称)：ProjectTopicName()Z at com.google.cloud.pubsub.v1)
at com.weston
浏览 8提问于2019-07-28得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
