Google pubsub模拟器不断地推送相同的消息？
基础概念
Google Pub/Sub 是一个完全托管的消息传递服务，它使您能够在应用程序之间发送和接收消息。它类似于发布-订阅模式，其中发布者发送消息到主题，而订阅者接收这些消息。
相关优势
- 可扩展性：Pub/Sub 可以处理大量的消息和订阅者。
- 可靠性：消息持久化存储，确保消息不会丢失。
- 灵活性：支持多种消息传递模式，如推送和拉取。
- 解耦：发布者和订阅者之间解耦，发布者不需要知道订阅者的存在。
类型
- 主题（Topic）：消息发布的地方。
- 订阅（Subscription）：接收消息的地方，可以配置为推送或拉取模式。
- 消息（Message）：实际传输的数据。
应用场景
- 事件驱动架构：用于处理异步事件。
- 微服务通信：用于微服务之间的消息传递。
- 日志处理：用于集中式日志收集和处理。
- 数据流处理：用于实时数据处理和分析。
问题分析
如果 Google Pub/Sub 模拟器不断地推送相同的消息，可能有以下原因：
- 消息重复发布：发布者代码可能存在问题，导致消息被重复发布。
- 订阅配置问题：订阅者可能配置为自动确认消息，导致相同的消息被再次推送。
- 模拟器配置问题：模拟器本身可能存在配置问题，导致重复推送消息。
解决方法
- 检查发布者代码： 确保发布者代码没有逻辑错误，导致消息被重复发布。可以添加日志记录来跟踪消息发布情况。
- 检查发布者代码： 确保发布者代码没有逻辑错误，导致消息被重复发布。可以添加日志记录来跟踪消息发布情况。
- 检查订阅配置： 确保订阅者配置为手动确认消息，而不是自动确认。这样可以避免消息被重复处理。
- 检查订阅配置： 确保订阅者配置为手动确认消息，而不是自动确认。这样可以避免消息被重复处理。
- 检查模拟器配置： 确保模拟器配置正确，没有重复推送消息的设置。可以参考官方文档或联系技术支持获取帮助。
参考链接
通过以上方法，您应该能够解决 Google Pub/Sub 模拟器不断推送相同消息的问题。
相关·内容
我和我的团队非常希望在我们的应用程序中包括Google /Sub，因为它将解决一些耦合问题。我们面临的问题是如何结合服务器进行本地集成测试。
我到目前为止所做的事：
启动发布子模拟器并设置PUBSUB_EMULATOR_HOST环境变量
在java服务器中启动我们的应用程序，它创建主题和订阅，然后向主题发送一些消息。
我想我做错了什么是因为：
云中创建的主题和订阅(当然它们应该在pubsub模拟器中创建？)
消息被推送，我们接收回消息in，但是没有到达端点，或者在云中或模拟器中报告错误。
由此，我非常肯定的是，这个模拟器并不是由dev服务器获取的。
对于我们的测
浏览 3提问于2016-07-30得票数 8
回答已采纳
我已经使用本教程部署了简单的PubSub云函数触发器：
为了测试，我将大消息(超过8MB)推送到PubSub主题。
结果，云函数在日志中返回了以下错误消息：Function execution could not start, status: 'request too large'
问题是，Cloud Function开始不断地启动，产生持续的资源使用和日志消息。只有在我手动清除相关的PubSub主题后，它才会停止。
是否有防止此类行为的机制/配置？理想情况下，云函数触发器执行后，PubSub消息不会被再次拾取。
浏览 0提问于2020-08-04得票数 0
我们的要求是，我们有一个Azure服务总线主题，我们希望将其设置为在谷歌PubSub主题中的推送订阅者。这样，发布到Google PubSub主题的任何消息都将被推送到Azure主题，而不涉及任何中间层。
在纸上，这应该工作，因为消息可以发布到Azure SB主题使用API框架和谷歌PubSub也可以配置API作为推送订户。
我已经通过了以下文章，但无法使这个链接锻炼。
Azure SB as API：
谷歌PubSub推送订阅：
以前有人做过这种链接吗？
提前谢谢
浏览 0提问于2019-07-15得票数 1
我已经用指向本地PubSub仿真器的根url设置了Pubsub.Builder (在我的例子中是localhost:8036)。它似乎在工作，我看到模拟器正在接收我的测试推送，但给我错误400错误的请求。
发布代码：
auth = GoogleCredential.getApplicationDefault(HTTP_TRANSPORT, JSON_FACTORY)
.createScoped(PubsubScopes.all());
client = new Pubsub.Builder(HTTP_TRANSPORT, JSON_FACTORY, auth)
浏览 0提问于2016-01-27得票数 2
我尝试在本地运行pubsub模拟器，并使用我在pubsub上运行的现有服务向其发送消息。没有收到消息，我得到的都是日志中的身份验证错误。
[pubsub] Jan 22, 2017 3:43:16 PM com.google.cloud.iam.testing.v1.shared.authorization.AuthInterceptor interceptCall
[pubsub] INFO: Authentication interceptor: Header value is null
[pubsub] Jan 22, 2017 3:43:16 PM com.google.cloud.i
浏览 10提问于2017-01-23得票数 1
回答已采纳
1回答
我试图使用pubsub的仿真器发送推送消息，我也使用spring引导，这是我的配置：
受抚养人：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-gcp-starter-pubsub</artifactId>
</dependency>
我的豆子：
@Configuration
@AutoConfigureBefore(value= GcpPubSubAutoConfiguration.cl
浏览 10提问于2020-01-04得票数 1
回答已采纳
我有一个使用Camel的SpringBoot应用程序，我希望使用谷歌PubSub组件将消息推送到某个主题。但是，当我的代码通过以下方式使用ProducerTemplate到PubSub时：
producer.sendBody("google-pubsub://<my-project-id>:<my-topic-name>");
我得到了com.google.api.client.repackaged.com.google.common.base.Strings.的NoClassDefFoundErr
在我的build.gradle中有：
编译组：'
浏览 3提问于2021-02-03得票数 0
我已经设法创建了一个c#工具来将消息推送到google cloud pubsub。我似乎找不到如何将消息发布到仿真器的方法。根据我所读到的内容，下面的代码应该通过将端点传递给ClientCreationSettings来工作。但是我从模拟器得到了一个错误的请求响应...
public static async Task PublishMessage()
{
var endpoint = new ServiceEndpoint("localhost", 8085);
ClientCreationSettings clientSettings
浏览 3提问于2020-05-10得票数 0
我们正在设计Google PubSub的监听端，并将为此使用Google功能。有两个选择，推送和后端函数。使用Http推送并将消息推送到函数。后端函数使用触发来调用该函数。
我们遇到困难的地方是决定哪种方法可能更适合我们的应用程序。我们无法在Google文档中找到这两种方法之间的差异列表。
我们注意到的一些事情是：
Http函数使用的是一个快速表达式结构，其中后端函数只是一个函数。似乎消息替换只适用于后端函数。不清楚死信队列是否和如何与后端函数一起工作。，每秒可以处理的消息数量是否存在差异？<代码>H19</code>还有许多我们不想问的事项.<code>H
浏览 9提问于2021-01-22得票数 2
回答已采纳
我正在尝试通过模拟器在本地运行我的Firebase函数。我已经构建了一个体系结构，其中的流程链由PubSub事件调用。当尝试调用这些事件时，仿真器日志显示如下： Sorry, we cannot connect to Cloud Services without a project ID. You may specify one with an environment variable named "GOOGLE_CLOUD_PROJECT". 我正在用--project {projectID}运行模拟器。我也像这样构造我的PubSub事件： const pubsub = n
浏览 27提问于2020-07-10得票数 0
1回答
我正在标准环境中开发一个python应用程序，该应用程序需要将消息发布到Google PubSub主题，该主题将进一步推送到另一个端点。但我无法在GAE性病中找到PubSub。环境。有什么可替代的呢？
谢谢。
浏览 1提问于2016-11-14得票数 0
回答已采纳
1回答
在使用Pub/Sub服务修改了图像之后，我试图读取发送的通知，但我无法使其工作。我遵循了这里描述的步骤：
我为主题foo (此主题已经存在)创建了订阅projects/[PROJECT-ID]/topics/gcr，并将权限授予服务帐户。
我用从文档中获取的ruby创建了以下脚本来测试订阅：
需要'google/cloud/ pubsub‘pubsub= Google::Cloud::Pubsub.new( project_id：’project_id‘，凭据：’my-凭据. puts‘) sub = pubsub.subscription 'foo’订户= sub.l
浏览 0提问于2018-02-05得票数 0
我创建了一个主题，我订阅它使用一个push端点。端点是一个简单的AppEngine web服务。Google文档指出，端点必须由HTTPS保护。
我没有接收到推送端点的任何流量。AppEngine web服务不显示任何请求。我已经通过Google PubSub仪表板验证了关于这个主题的消息正在被成功发布。仪表板显示用于推送订阅的unreachable_ssl_error。为什么Google PubSub要报告这个错误？
当我试图通过浏览器访问SSL AppEngine端点时，我也会收到一个SSL证书错误。这对AppEngine站点来说是正常的吗？
浏览 5提问于2015-03-21得票数 0
回答已采纳
我想知道，当你推送一条特定的消息时，是否有办法禁止从Google Pub/Sub接收来自订阅者的确认消息？如果消息不知何故丢失或未被订阅者接收，则将Google PubSub配置为不发送或尝试发送相同的消息，以避免重复。这个是可能的吗？
浏览 16提问于2020-07-15得票数 0
我对Node.js的Node.js模块有个问题。我使用Docker和PubSub模拟器创建了一个本地环境。我能够发布一条消息并使用异步拉检索它(如这里所记录的：)。然而，当我试图使用同步拉()时，我一直有以下错误：
错误:无法加载默认凭据。浏览到以获得更多信息。在GoogleAuth。(/var/code/node_modules/google-auth-library/build/src/auth/googleauth.js:167:23) at next (本机)在实现的(/var/code/node_modules/google-auth-library/build/src/auth/
浏览 0提问于2018-11-29得票数 1
回答已采纳
1回答
我们需要将标签应用于下面的GCP Services
Cloud SQL , BigQuery and PubSub
Bigquery,Pubsub服务的数量将跨越多个GCP projects，跨越数千个。我们将一次将标签应用于所有资源，利用来自Python下面的PATCH方法实现APIs自动化。
https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets/patch
https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.top
浏览 3提问于2020-09-06得票数 0
回答已采纳
我想要创建一个Log Sink来侦听Stack驱动程序中的特定消息，并将事件推送到Cloud /Sub，这将触发一个Cloud函数。
这里是我的Terraform模板的一部分。
resource "google_pubsub_topic" "dataflow_events" {
name = join("-", concat(["dataflow-events", var.environment, terraform.workspace]))
}
resource "google_logging_project_si
浏览 1提问于2020-11-13得票数 7
回答已采纳
这可能会导致云发布/订阅服务出现问题。但到目前为止，GCP支持并不是很有帮助，所以我在这里发布了这个问题。 根据here的说法，Pubsub消息应该有一个messageId属性，无论它是来自pull还是push。 所以我试着看看消息是什么样子的：(这里的事件是推送到云函数的pubsub消息) exports.my_cloud_function = (event) => {
logger.debug(`Event: ${util.inspect(event)}`);
} 我所期待的： { '@type': 'type.googleapis.com/goog
浏览 25提问于2019-10-05得票数 0
回答已采纳
1回答
Google服务控制限制提到了：
在受服务范围保护的项目中，无法创建新的推送订阅。
在服务边界之前创建的Pub/Sub推送订阅不会被阻塞。
问题
1.是否意味着为了在VPC中使用PubSub推送订阅，必须：
先创建一个推送订阅，然后再创建
定义VPC服务边界
2.是否推荐使用PubSub服务控件创建使用PubSub推送订阅？
3.还是谷歌建议完全避免在PubSub服务控件中使用PubSub推送订阅？
浏览 1提问于2021-02-08得票数 0
回答已采纳
3回答
我有一个Google云功能，它是由Pubsub订阅触发的。
我希望知道给定消息的当前传递尝试。
在拉订阅中，它通过设置死信主题来工作，但是我无法获得推送订阅消息属性中的传递尝试。尝试配置一个死信主题，而delivery_attempt属性不在消息属性中。
是否有方法获得推送订阅中的传递尝试参数？
浏览 11提问于2021-03-03得票数 1
在使用Google启动PubSub模拟器并相应地加载环境变量之后，Google仍然使用我们的PubSub生产帐户进行身份验证。基本上，我们做到了：
# Starting the emulator in one shell
gcloud beta emulators pubsub start
# In a different shell
$(gcloud beta emulators pubsub env-init)
gcloud pubsub topics list
然而，我们的生产主题在这里列出。预期的输出将是一个空列表，因为我们试图从刚启动的PubSub模拟器中列出主题，该模拟器在启动时
浏览 5提问于2017-12-08得票数 6
3回答
出于各种原因，我们遇到了一些情况，我们希望“暂停”推送来自Google平台(GCP) Pubsub订阅的通知，只允许它们排队，然后最终“取消暂停”，允许推送继续而不会丢失任何消息。
这是内置功能吗？
你能提出一个解决办法吗？
浏览 4提问于2016-11-17得票数 5
回答已采纳
我正在不断地从谷歌PubSub中提取信息。一切顺利，除了获取消息所需的时间约为12至15秒，在我们的情况下是不可接受的。以下是我的CallTiming设置：
public CallSettings GetPullSetting()
{
CallTiming timing = CallTiming.FromRetry(new RetrySettings(
retryBackoff: new BackoffSettings(new TimeSpan(0, 0, 0, 0, 50), new TimeSpan(0, 0, 5), 1),
浏览 2提问于2017-02-27得票数 0
回答已采纳
下面的代码从->源主题获取消息，并根据模板pubsub对其进行转换，然后将转换后的消息发布到目标主题。
但是为了提高性能，我需要在parallel.That中完成这个任务，我需要轮询500条消息，然后并行转换它，然后将它们发布到目标主题。
从camel gcp组件文档中，我相信maxMessagesPerPoll和concurrentConsumers参数会做job.Due，因为缺少文档，我不确定它内部是如何工作的。
我的意思是a)如果我轮询了500条消息，它是否会创建500条并行路由来处理消息并将其发布到目标主题b)消息的排序如何c)我是否应该考虑将并行处理EIP作为替代方案
等。
这
浏览 4提问于2020-04-29得票数 1
背景:我们将云发布主题配置为在多个应用程序引擎服务中进行交互，在那里我们已经配置了基于推送的订阅者。我们已将其确认截止日期设置为600秒。
问题:我们已经观察到pubsub已经将相同的消息两次(从其他主题上推了两次以上)给它的订阅者，从日志中我可以看到这个消息推送的间隔只有1秒，理想的情况下，由于我们已经将ackDeadline配置为600秒，所以pubsub应该在600秒后重新尝试消息传递。
需要以下答案：
为什么同一条消息仅在1秒内被传递超过一次
在重新尝试消息传递之前，pubsub不遵守ackDeadline配置吗？
参考资料：-
浏览 2提问于2018-11-29得票数 8
我正在尝试使用Google c2dm来实现Android的推送通知。我有一个注册的服务器，一个注册的Android模拟器设备。每次我从服务器向已注册的Android模拟器发送消息时，应用服务器都会收到来自Google服务器的401响应。所以我有一个问题: c2dm能在Android模拟器上工作吗？提前谢谢。
浏览 3提问于2011-10-13得票数 1
回答已采纳
1回答
我正在尝试让firebase模拟器使用pubsub发布来触发云函数。基本设置在云函数之外工作。尝试连接云函数时，不会出现任何消息。 我有种感觉，我做了一些根本错误的事情。 发布代码： import { PubSub, Topic } from '@google-cloud/pubsub';
const topicName = 'MyTopic';
const [taskTopic] = await pubsub.createTopic(topicName);
await this.taskTopic.publish(Buffer.from(msg)); “手
浏览 9提问于2021-01-30得票数 1
回答已采纳
我有一个Google主题，它有时包含数千条消息，有时甚至没有消息。这些消息表示每个任务可能需要超过一个小时的任务。最好我能够使用Cloud来实现这一点，因为它能够很好地适应需求，如果发布了一千条消息，我希望云运行实例的100多个可以旋转起来。这些运行实例是通过推送订阅启动的。问题是PubSub有600秒的确认超时时间。这意味着，为了让云运行这些消息，它们必须在600秒内完成。如果没有，PubSub将其超时，并再次发送，导致任务重新启动，直到第一个任务最终确认它为止(这将导致同一任务多次运行)。云运行通过返回2** HTTP状态代码来确认消息。文件说明
当运行在云运行上的应用程序完成处理请求时
浏览 0提问于2019-08-05得票数 11
是否可以触发HTTP云函数来响应pubsub消息？
在编辑订阅时，谷歌可以将消息推送到HTTPS端点，但由于滥用原因，用户必须能够证明您拥有该域名才能做到这一点，当然，您不能证明您拥有谷歌自己的*.cloudfunctions.net域名。
我正在尝试订阅的特定主题是一个公共主题，projects/pubsub-public-data/topics/taxirides-realtime。答案可能是使用后台函数，而不是HTTP触发，但由于不同的原因，这不起作用：
gcloud functions deploy echo --trigger-resource projects/pubsub-pub
浏览 1提问于2018-07-29得票数 5
我正在尝试构建一个流/批处理管道，它从发布/订阅中读取事件，并使用python3.6将它们写入BigQuery 根据文档，云发布/订阅会为每条消息分配唯一的message_id和timestamp，用于检测订阅者收到的重复消息。(https://cloud.google.com/pubsub/docs/faq) 要求如下: 1)消息可以以任意顺序传入(异步消息) 2)唯一Id和时间戳(当记录被推送到pubsub主题/从主题拉取时)需要捕获到已有的记录中。 Input Data :
Name Age
xyz 21 Output Record to bigquery:
Name Age
浏览 13提问于2019-10-16得票数 0
我正面临一个问题，当发布一个谷歌云公共消息订阅与订购启用。
我有一个公共主题:带有消息顺序的推送订阅的test_order_topic (enableMessageOrdering: true)。
但是，当使用python Google函数发布到此主题时：
publisher.publish(
'projects/project_id/topics/test_order_pubsub',
json.dumps({ "index": len(WORDS) }).encode('utf-8'),
ordering_key='
浏览 2提问于2021-10-18得票数 1
回答已采纳
1回答
我需要使用Pub/Sub仿真器测试具有回调功能的pubsub用户。有几个例子
PullRequest pullRequest = PullRequest.newBuilder()
.setMaxMessages(1)
.setReturnImmediately(true) // return immediately if messages are not available
浏览 9提问于2020-06-26得票数 1
2回答
似乎GCP云函数在调用时总是确认Pubsub推送消息，即使函数崩溃或失败。
这阻止了新的发布/订阅“死信”主题功能的使用，该功能要求在将消息转发到不同的主题之前，消息传递失败。目前，消息从不会失败。
有没有办法利用“死信主题”或使用云函数的pubsub重新交付？除了在函数本身设置“重试”标志之外，这并不能解决这个问题。
浏览 1提问于2020-05-15得票数 4
1回答
我正在运行项目，该项目将消息发布到PubSub主题并触发后台云功能。
我读到，在大量的消息中，它执行得很好，但是对于每秒几百条甚至几十条消息这样的较小数量的消息，Pub/Sub可能会产生很高的延迟。
发布单个消息的代码示例：
const {PubSub} = require('@google-cloud/pubsub');
const pubSubClient = new PubSub();
async function publishMessage() {
const topicName = 'my-topic';
const dat
浏览 4提问于2020-03-23得票数 0
我正在尝试使用Google PubSub、Node和来可视化流媒体数据。我所做的只是：
每1秒将消息流推送到PubSub主题(使用python脚本)
创建该主题的订阅
创建一个简单的web应用程序，它侦听订阅，解析每条传入的消息，并以活动条形图的形式显示给浏览器(使用节点js、socket.io和聚结图)
我遵循了本教程：，唯一的区别是我使用了PubSub而不是PubNub，还遵循了以下文档：“接收消息”部分的。
实际上，当我每1秒发布10条消息时，图表将每1秒准确地显示10条消息。当我运行我的应用程序时，这个图表就是这样的：
问题是它只在我第一次运行应用程序并打开页面时
浏览 1提问于2018-08-28得票数 0
我想知道确认PubSub消息(来自推送用户)的正确方式是什么，这是一个Firebase云函数。这是通过返回一个承诺来完成的吗？ import * as functions from 'firebase-functions'
import * as admin from 'firebase-admin'
export const listener = functions.pubsub.topic('new_members').onPublish(async (message:any) => {
let data = {
name:
浏览 20提问于2020-01-18得票数 0
回答已采纳
我正在开发的一个Android应用程序中使用了基于GCM主题的消息传递。它工作得很好，但我想给用户一个停止接收推送消息的选项。当然，从应用程序设置中禁用通知是可行的，但我想让用户禁用/启用来自应用程序的推送消息。
因此，我使用以下方法来尝试取消订阅该主题(单击一个按钮)：
GcmPubSub pubSub = GcmPubSub.getInstance(this);
try{pubSub.unsubscribe(MyRegistrationToken,"MyTopic");}
catch(Exception e){e.printStac
浏览 2提问于2015-11-06得票数 1
我们尝试对云PubSub推送订阅者进行一定的速率限制，将推送订阅者吞吐量kB配额设置为1，有效意味着PubSub对推送订阅者的处理不超过1kbps。 但是，实际吞吐量可能会更高，大约为6-8kbps。 为什么没有像预期的那样限制吞吐量呢？ 更多详细信息： 其目标是将速率限制为每秒50条消息。 我们可以假设平均消息大小，为了测试的目的，我们使用50字节的消息，即50字节* 60秒= 3000字节/秒，或每秒3kbps的消息。通过将配额设置为1，我们预计PubSub每秒推送的消息将少于50条。在测试过程中，我们得到的远不止这些。
浏览 10提问于2019-03-13得票数 0
我正试图从一个next.js应用程序中将消息发布到pubsub。
我正在通过来设置节点客户端并在pubsub仿真器上运行它，但是对于我尝试的所有方法，我都得到了以下错误：
Error: 12 UNIMPLEMENTED: Method not found: google.pubsub.v1.Publisher/GetTopic
at Object.callErrorFromStatus (/Users/ethan/Documents/code/refold-library/node_modules/@grpc/grpc-js/build/src/call.js:31:19)
a
浏览 25提问于2022-09-16得票数 0
我使用Google控制台设置Pub/Sub，并实现异步拉以从订阅获取消息。这是带有错误消息的命令行，上面写着错误解析订阅。使用错误消息，如何找到项目信息并正确设置属性属性？
C:\Program Files (x86)\Google\Cloud SDK>gcloud beta pubsub subscriptions pull GmailSub
错误：(gcloud.beta.pubsub.subscriptions.pull)错误解析订阅。未正确指定订阅资源。
找不到属性项目。属性可以通过以下方式设置：-设置属性[core/project]或在命令行中提供标志[--project]
浏览 3提问于2018-01-01得票数 1
我在Django中使用google- Cloud -pubsub和Google Cloud Pub/Sub模拟器。我试着这样创建一个主题：
publisher = pubsub.PublisherClient ()
topic_path = publisher.topic_path ('my-project', 'my-new-topic')
topic = publisher.create_topic (topic_path)
topic.publish (topic, request.data ['url']. encode ('ut
浏览 0提问于2017-09-27得票数 5
1回答
我试图在gcp上使用terraform来实现以下目标。
云函数侦听添加到发布/副主题中的消息，一旦添加消息，云函数将被触发，如果在处理该消息时出错，则将消息放入相应的死信队列。
我不知道如何创建云功能的订阅，它也包含死信策略。目前，我正在为云函数执行以下操作，
resource "google_cloudfunctions_function" "brw-user-function-item-registered" {
// details
event_trigger {
event_type = "google.pubsub.topic.
浏览 3提问于2021-08-12得票数 0
我一直在使用创建顶点AI监控作业的例子。在@Jose Gutierrez Paliza的帮助下，它发送了一封电子邮件，并对其进行了修改，发送了Pubsub消息。
我已经开始工作了，算是吧。但是看起来正在发生的是Pubsub将日志推送到一个错误函数上。
我的日志水槽包括：
当我查看日志时，我看到了一个信息条目：
my-fn an_id Event data: {"insertId":"another_id...
后面是一个单独的错误条目：
...
ValueError: The pipeline parameter insertId is not found
浏览 7提问于2022-08-23得票数 1
我有一个从PubSub读取数据的Java数据流作业。数据流读取一条消息大约需要5秒。
我怎么才能加快速度呢？我假设数据流是从PubSub中提取的，而不是PubSub将消息推送到数据流中。
浏览 0提问于2019-08-10得票数 0
我希望能够将Google平台( GCP ) Pubsub订阅的消息转发到另一个GCP主题，这可能是在另一个GCP项目中。
是否可以通过推送端点URL (目标主题的url是什么？)
通过API进行其他一些简单的配置？
(解决办法)或者，您将如何提供此功能？
浏览 3提问于2016-11-17得票数 4
我正在使用spring boot与pubsub主题进行交互。
此连接的配置类如下所示：
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.gcp.pubsub.core.PubSubTemplate;
import org.springframework.cloud.gcp.pubsub.core.publisher.PubSubPublisherTemplate;
import org.springframework.cloud.gcp.pubsub.suppor
浏览 2提问于2020-01-08得票数 0
2回答
我在Google中有以下设置：
将消息发布到Google主题的应用程序“生成器”。
使用唯一消息的应用程序'worker‘。
任何无效的PubSub消息都应该以“死信”主题结束。
这个主题应该有一个“死信”主题，其中无效的消息结束。然而，每当我通过Terraform配置它时，google云控制台就会提到，我没有将“订户”和“publisher”角色附加到我的项目公共服务帐户：
我有以下地形结构，似乎是正确的AFAIK：
resource "google_project_service_identity" "pubsub_sa"
浏览 1提问于2021-04-15得票数 1
我正在使用pubsub将消息推送到灵活环境中以node编写的App Engine应用程序中。有没有办法将我的端点限制为仅来自pubsub的流量？
在标准环境中，App Engine具有可定义仅管理请求和安全端点的处理程序。但是，此功能在灵活的环境中不可用。是否可以仅为Google请求设置防火墙规则(防火墙似乎是应用程序范围的，而不是端点？)，是否有标准方法来保护端点，或者我是否需要自定义部署解决方案？
浏览 15提问于2017-08-31得票数 3
回答已采纳
1回答
我想做一个设置:我的Dockerized -> Pub/Sub Dockerized仿真器<- Cloud函数Dockerized仿真器
分步骤：
我的应用程序向Pub/Sub Docker模拟器发布消息
Pub/Sub Docker模拟器在主题下注册消息
云功能/订阅主题和过程
我希望在本地运行每个服务，并在开发模式中首先测试整个设置。我成功地建立了前两部分。我能够向Dockerized仿真器发布一条消息，并通过订阅它获得数据。
在此之后，我想添加云函数(步骤3)并让函数/s订阅该主题。我还对函数进行了文档化，并将所有内容放到了docker-组合文件中，这样我
浏览 6提问于2021-05-11得票数 0
我要求在PubSub中跟踪未送达的邮件。但是，当PubSub请求订阅的订阅者在保留期过后不可用时，该消息将永远从订阅中丢失。它不会被为订阅创建的死信主题捕获。 似乎PubSub仅在重试次数超过且用户未接收到确认时才向死信主题发送消息。 有没有办法在消息永远消失之前将消息推送到死信主题？
浏览 24提问于2020-08-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
