1回答
我试着用下面的代码从pub/sub阅读 return new String(input.getMessage());}); c.output(c.element()); }));
浏览 3提问于2017-05-16得票数 5
回答已采纳
我正在使用以下GCP发布/订阅REST API来拉取和确认消息。拉取消息：-{"returnImmediately": "false",
"maxMessages": "1
浏览 5提问于2021-11-25得票数 0
我们可以通过在堆栈驱动程序中验证未确认的消息计数，或者通过重新部署函数和查看消息得到服务来验证订阅S2中的消息排队。
是谷歌的node.js发布客户端不兼容谷歌云功能吗？谷歌 。在云函数中运行客户端是否“其他需求”，要求我们<
浏览 0提问于2018-02-05得票数 5
回答已采纳
我正在构建一个测试库，抽象出一些第三方资源，如谷歌PubSub。 问题是，当我创建一个主题和一个订阅时，消息会不断地到达。输出示例： 确认 _ id："projects/test-project-123/subscriptions/my-subscription:2“消息{数据：”我的消息！-1“消息 _ id："2“发布 _ 时间{秒: 1614597484 }} 确认 _ id：&
浏览 48提问于2021-03-01得票数 0
回答已采纳
我们正在以一种“尖峰”的方式使用谷歌PubSub，在短时间内(~ 10分钟)发布数百万条小消息(< 10k)，用10个工作线程旋转2k GKE吊舱，每个线程使用同步拉和确认PubSub服务调用来完成相关的订阅来自GAE任务拉队列世界，我们假设工作人员将通过从PubSub订阅中提取一条消息来“租赁”一条消息，其中，从提取时开始，员工将有10分钟的时间来确认消息。然而，在添加日志
浏览 1提问于2020-06-27得票数 2
回答已采纳
3回答
我的应用程序从google cloud pubsub获取排队的消息并处理任务。worker应用程序也与谷歌应用程序引擎(Node.js)一起托管。
浏览 22提问于2016-08-22得票数 3
2回答
我正在尝试从监视器获取数据到Android应用程序，并以IHE-PCD-01事务为模型。但我不明白的是，在每次留言之后，我是否需要一个ACK。有人能帮我吗？
浏览 1提问于2014-11-06得票数 1
回答已采纳
最好我能够使用Cloud来实现这一点，因为它能够很好地适应需求，如果发布了一千条消息，我希望云运行实例的100多个可以旋转起来。这些运行实例是通过推送订阅启动的。问题是PubSub有600秒的确认超时时间。这意味着，为了让云运行这些消息，它们必须在600秒内完成。如果没有，PubSub将其超时，并再次发送，导致任务重新启动，直到第一个任务最终确认它为止(这将导致同一任务多次运行)。云运行通过返回2** HTTP状态代码来确认消息。我看
浏览 0提问于2019-08-05得票数 11
我正在升级以前使用RabbitMQ的队列处理系统。
我目前正在导入RabbitMQ中的死信和指数回退功能，但是我似乎遇到了一些问题。主要的问题是，当我使用死信策略创建一个新的订阅时，它似乎没有必要的相关权限，以便Google将消息转发到我的死信订阅。如下所示，在检查订阅详细信息时，google强调了项目的pubsub服务帐户需要发布者角色和订阅者角色，以便发布和转发到死信主题。在UI中给出了添加这些的选项，但是我需要完全通过我正在运行的消费者来处理，因为这需要是一个自动化的过程，因为这些
浏览 1提问于2020-09-28得票数 2
我有一个来自第三方的API (对于我和gcp)，我想知道是否有可能从API获得数据到PUBSUB，或者从我可以在我的环境中设置的包装API中。基本模式：
(第三方API) -> PUBSUB -Cloud函数-> BigQuery
浏览 5提问于2022-09-01得票数 0
我在kafka上的工作并不多，但我想在GCE中构建数据管道。所以我们想知道Kafka vs PUB/Sub。基本上，我想知道在Kafka和Pub/sub中是如何维护消息一致性、消息可用性和消息可靠性的
谢谢
浏览 0提问于2016-07-25得票数 101
我发现这两种方法都在Google的不同文档中使用：载于：
from google.cloud import pubsub_v1
浏览 1提问于2018-01-10得票数 14
回答已采纳
使用python google-cloud-pubsub库，通过subscriber.acknowledge()确认消息不会确认我的消息。我的确认截止时间设置为30秒。下面是我的代码： from google.cloud import pubsub_v1
subscription_name = "$$$$"
subscriber= pubsub
浏览 18提问于2019-12-05得票数 1
我试图使用一个拉队列来创建一个图像处理任务队列，这些任务可能需要超过10分钟的超时时间。我正在使用node.js api，我想知道如何让一个工作人员从拉队列中抓取一条消息，并将其标记为正在进行的消息，这样就不会有其他工作人员尝试抓取它、做它的工作并在处理完成后确认消息。如果出现异常，我希望删除“进行中”状态，并允许其他工作人员获取此消息并尝试处理它。
我希望在公共场合有什么东西能让我这么做。我的替代方法是，在处理之前，将带有消
浏览 5提问于2016-05-10得票数 1
回答已采纳
我正在通过订阅提取pubsub消息，并且需要在处理之前确认这些消息，就像我正在进行多处理一样，这会因为grpc模块而引发SSL损坏的错误。我想预先对所有消息进行解码，以防出现错误，我知道我们可以在异步拉中这样做，但是我们是否也可以在同步拉中实现unack呢？
我正在使用官方python模块从订阅中提取。
浏览 3提问于2021-07-21得票数 0
回答已采纳
2回答
我正在尝试使用google的云功能，我所有的东西都工作得很好，但是我的消息并没有被公开。我的云功能正在被调用，但我的消息没有被确认。
因此，函数应该自动确认它不工作。
浏览 0提问于2019-04-10得票数 5
回答已采纳
我试图从实时公共projects/pubsub-public-data/topics/taxirides-realtime流中读取消息，而且似乎我处理数据的速度不够快，或者确认存在问题。消息正在到达我的程序，但要么处理缓慢，要么处理不当。每小时产生约8-1000万条记录的流，其中不到0.5%与我的回调中的IF条件相匹配。无论如何，我还尝试了一个完全空的回调，其中只包含
浏览 4提问于2020-01-17得票数 2
回答已采纳
我正在AWS Lambda函数上导入Stackdriver logging python库，如下所示： from google.cloud.logging.handlers') stackdriver.addHandler(handler)
我看到了这个错误，但它似乎不是来自我的代码中的任何特定行gapic_google_cloud_logging_v2-0.91.3-py3.6-nspkg
浏览 7提问于2017-07-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
