当等待函数未完成时，运行循环以更新云发布/订阅acknolwedgement截止日期
当等待函数未完成时，运行循环以更新云发布/订阅acknowledgement截止日期是一种处理异步消息通信的机制。在云计算中，发布/订阅模式是一种常见的消息传递模式，用于实现解耦和灵活性。
具体而言，当一个应用程序需要等待某个函数的完成结果时，可以通过运行循环来实现等待。运行循环是一个持续运行的循环，它会不断地检查等待函数是否完成。一旦等待函数完成，运行循环会更新云发布/订阅的acknowledgement截止日期，表示消息已被接收和处理。
这种机制的优势在于可以实现异步通信，提高系统的响应速度和并发性能。同时，通过发布/订阅模式，可以实现解耦，使得不同组件之间的通信更加灵活和可扩展。
在云计算中，腾讯云提供了一系列相关产品来支持发布/订阅模式和异步消息通信。其中，消息队列CMQ（Cloud Message Queue）是一种高可靠、高可用的消息队列服务，可以实现消息的发布和订阅。通过CMQ，用户可以创建消息队列，并通过API进行消息的发送和接收。具体产品介绍和使用方法可以参考腾讯云的官方文档：腾讯云消息队列CMQ
总结起来，当等待函数未完成时，运行循环以更新云发布/订阅acknowledgement截止日期是一种处理异步消息通信的机制，通过发布/订阅模式和腾讯云的消息队列CMQ等相关产品，可以实现高效、可靠的消息传递和系统通信。
相关·内容
我的所有消息都将花费超过600秒的时间来确认/处理来自云PubSub的消息，所以当我处理消息时，我需要计数到590秒，并请求将确认截止时间延长600秒(这样其他订阅者就不会得到重新提交)。我的计划是编写一个等待进程运行的包装器 while awaited processing_function not finished: streaming_pu
浏览 6提问于2021-07-09得票数 0
回答已采纳
1回答
我正在尝试使用云函数作为由PubSub触发的异步后台工作程序，并进行更长时间的工作(以分钟为单位)。完整的代码在这里有人强调，PubSub可以多次传递相同的消息，但令我惊讶的是，100条消息中有10到40条是重复的。CF的响应时间分别为5、6、7分钟。在文档中提到“云发布/订阅可以发送重复的消息
浏览 0提问于2019-05-18得票数 2
我正在构建一个运行在Cloud Run上的服务，该服务由PubSub通过EventArc触发。“PubSub”保证交付至少一次，并将在每一个acknowledgement截止日期重新尝试。此截止日期设置在队列订阅详细信息中。
浏览 5提问于2021-06-24得票数 1
我有一个云函数订阅了Pub/Sub主题。我认为这个问题没有任何意义，我会解释原因。
由于您无法访问Pub/Sub函数中的Response对象，因此无法直接发送响应代码(我对此不太确定，因此如果我错了，请纠正我)。，正如所说，在默认情况下Pub/Sub甚至不会重试，所以关心确认截止</e
浏览 0提问于2019-07-08得票数 5
回答已采纳
1回答
我有一个Google函数订阅了一个主题。当需要向用户发送电子邮件时，我们的Go API会向主题发布一条消息。GCF创建电子邮件对象并将其发送到Sendgrid。问题是，90%的时候，云函数会被两次调用。据我所知，PubSub保证至少一次交付和GCF 至少一次执行后台函数。即使当我从GCP控制台手动发布要测试的消息<e
浏览 0提问于2019-06-20得票数 2
回答已采纳
一个托管在中，另一个托管在云运行中。以前有没有人遇到过类似的问题？GAE urlfetch有问题吗？再次检查，发现来自again的一些请求确实出现在云运行负载均衡器日志中，但时间很奇怪：GAE项目的日志
10:36:24.706
浏览 5提问于2021-12-31得票数 0
Topic T2充当由我们的服务发布的后台作业的队列。订阅S2由云函数在每次执行时读取，以服务排队的后台作业。
有时在第一次执行之后(在重新部署函数之后)，后续的执行永远不会收到新的消息。云函数文档清楚地声明了。但是，查看node.js<em
浏览 0提问于2018-02-05得票数 5
回答已采纳
以下是我的情况：那么，我的问题是:是否有一种标准的方法/最佳实践来批处理实时客户端请求：
当接收到请求时，请稍等其他requestsAfte
浏览 1提问于2021-05-31得票数 0
我创建了一个Java程序来以特定的频率发出事件。我使用的是System.nanoTime()而不是Thread.sleep()，因为根据和的许多参考文献，第一种方法在间隔上提供了更高的精度。但是，我想，当我试图将它设置为发出100万条记录/秒的数据速率时，它并没有达到这个目标。while ((System.nanoTime() - startTime) < this.delayInNanoSeconds) ;因此，当我在delayInNanoSeconds变量中等待10000纳秒时，我的工作负载为10
浏览 1提问于2020-05-28得票数 2
回答已采纳
我可以按以下方式确认订阅的所有消息：(尽管在确认所有消息之前，我经常要反复运行这个程序我想可能是：但是当我运行这个命令时，它每次都会显示不同的消息。
浏览 11提问于2022-06-09得票数 0
我最近已经开始使用Google PubSub，并在云运行实例之间使用相同的Push订阅来传输数据。
在测试过程中，我注意到在少数情况下，发布和订阅之间存在延迟。
浏览 2提问于2021-10-06得票数 0
回答已采纳
3回答
如果没有这样的服务，那么您会推荐哪些服务组合来实现分布式任务的有效编排(主要是云功能)。谢谢!
浏览 5提问于2019-11-25得票数 8
回答已采纳
我正在编写一个application应用程序，其中我使用了.NET PubSub模拟器，在那里我可以发布和订阅一个主题。但是，当我发布“大量”消息1000+时，我想拉出尽可能多的消息。
浏览 10提问于2018-03-02得票数 1
2回答
我有一个要求，在一个特定的截止日期前几天发送通知给用户。我目前的设计是使用Cloud定期调用一个作业，然后在一个很小的时间间隔内查找所有匹配的记录，然后通知它们。但是，调度作业需要发现所有的截止日期，而且不可能迭代每个分区，因为随着时间的推移，即将到来的截止日期的数量可能会比分区的数量小得多。
浏览 3提问于2019-09-28得票数 1
回答已采纳
当我使用meteor.logout()时，大约需要30-40秒的时间。Meteor.call()也是如此。约有200-250个客户端同时使用该系统。
浏览 38提问于2017-06-01得票数 0
回答已采纳
我正在使用pubsub来触发一个云函数，我已经定义它有最多10个实例。当大约300条左右的消息到达主题并开始触发该函数时，突然间，未加加的消息的数量就停止了，它只是没有改变，尽管我知道触发的云函数会自动添加这些消息.
send_message_operation_count (绿色)是发布到触发云<em
浏览 1提问于2021-06-07得票数 0
回答已采纳
当工作完成后，处理Redis队列的外部服务器将一个POST请求发送回GAE。
问题是，有时Redis队列失败，或者最后没有发出POST请求。这将导致GAE上的“等待”状态永不改变。选项1：当我向Redis队列提交任务时，我还会创建一个名为"Healthcheck“的新GAE任务，该任务将在5分钟内运行，如果当前任务未完成，则切换到”无效“并关闭它。选项2：当将任务提交到Redis队列时，我使用while True循环挂起进程，并刷新当前状态，
浏览 1提问于2016-12-20得票数 0
回答已采纳
4回答
假设我有Service A在云上运行时，由于负载较高，需要运行10个容器/实例。我想： 推送消息(来自云函数)到全部(广播)的容器Service A 推送消息(来自云函数)到单一任意容器Service A 背景：我的Cloud Run服务将使用服务器发送的事件将数据直接推送到客户端在某些情况下，我需要将消息推送到所有sse/ws连接 在所有容器上(想象一个带有公共聊天室的聊天应用程序，其中每个人都可以看到发布的消息)。
浏览 69提问于2021-02-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
