发布/订阅推送消息没有messageId属性
发布/订阅推送消息是一种在云计算中常用的消息传递模式。在该模式中，发布者发布消息，而订阅者通过订阅特定的主题或频道来接收相应的消息。
在发布/订阅推送消息中，消息通常是一个包含特定信息的数据包。这些消息可以是文本、JSON、XML等格式，用于传递各种类型的数据。
该模式的优势包括：
- 异步通信：发布/订阅模式允许消息的异步传递，发布者和订阅者可以在不同的时间和速率下进行通信。
- 松耦合：发布者和订阅者之间的通信是通过消息中间件进行的，彼此之间不直接依赖。这使得系统的不同部分能够独立地进行开发和扩展。
- 消息过滤：订阅者可以选择订阅特定的主题或频道，只接收与其相关的消息。这种灵活性使得系统能够更好地适应不同的应用场景。
发布/订阅推送消息在许多应用场景中得到了广泛的应用，包括：
- 实时通知：通过发布/订阅模式，可以实现实时的消息推送，例如社交媒体应用中的新消息通知、实时聊天等。
- 数据同步：在分布式系统中，发布/订阅模式可以用于数据的实时同步，保持不同节点之间的数据一致性。
- 日志记录：发布/订阅模式可以用于将应用程序的日志消息发送到集中的日志管理系统，便于统一的日志分析和处理。
腾讯云提供了适用于发布/订阅推送消息的产品，例如腾讯云消息队列 CMQ（Cloud Message Queue），它是一种高可靠、高可用、分布式的消息队列服务。CMQ提供了发布/订阅模式，并具备消息过滤、定时消息等功能，适用于各种实时通知、数据同步、日志记录等场景。
产品介绍链接：腾讯云消息队列 CMQ
相关·内容
通过消息id从主题中选择消息时遇到问题。以下是精简后的代码：
//publish message
connectionFactory = new ActiveMQConnectionFactory("vm://localhost");
//or external broker: tcp://localhost:61616
con = connectionFactory.createConnection();
con.setClientID("foo");
con.start();
session = connection.createSession(true
浏览 2提问于2012-01-05得票数 1
回答已采纳
我有一个Ingres DB with History表，它记录数据库事件，如插入、更新和删除。我有一个生产者，这将是多线程。这个生产者将读取History表，以找到要选择的表和行，然后将该行添加到Kafka主题中。现在生产者需要确保将事件添加到Kafka主题中，其方式与History表登录的方式相同。因此，使用者读取它们的顺序与它在History表中记录的顺序相同，并在Postgrace上执行它。
我可以将这些数据生成多个生产者。示例
Producer1 has message 1 to 5
producer2 has message 6 to 10
producer3 has message
浏览 1提问于2019-01-16得票数 0
2回答
我使用.net sdk将消息推送到SNS，然后SNS将消息发布到订阅的SQS队列，但是SNS添加了元数据(如消息类型等)，最后得到了我不想要的更大的JSON有效负载，特别是当每条消息被限制在256 k时。
是否有可能向SNS发送命令并告诉它不要发送元数据？
下面是代码：
var credentials = new StoredProfileAWSCredentials("dev");
using (var client = new AmazonSimpleNotificationServiceClient(credentials, Amazon.RegionEndpoint.
浏览 6提问于2016-09-27得票数 4
回答已采纳
我有一个云发布/订阅推送订阅，它将相同消息的多个实例推送到一个处理端点I GAE。我可以跟踪消息ID，这是同一消息，被多次推送。 我已经将ack-timeout设置为600秒，但它仍然会推送某些消息的多个实例。消息的外部没有“确认”，是什么触发了这种行为？有没有人有同样的问题？ 我运行的实例越多，这个问题似乎就越大，但即使使用basic_scaling和max_instances: 1，问题仍然存在。 我可以在GAE中看到一堆503个错误，但如果我理解正确的话，这不是问题，因为这些消息会自动“重试”，而是发布/订阅。
浏览 65提问于2019-10-18得票数 3
我试图一次向几个设备发送推送通知。为此，我要做以下几点：
列表项目
创建一个主题
订阅我想要的所有这个主题的设备
向主题发布消息
我正在尝试向我的应用程序发送一个定制的JSON。内容如下：
{"APNS_SANDBOX":"{\"aps\":\"{\\\"u\\\":\\\"1\\\"}\"}"}
不过，我在发送JSON时遇到了InvalidParameter错误。错误的细节是
“消息结构- JSON消息体中没有默认条目”
奇怪的是，发送到单个设备(发布到endpoi
浏览 0提问于2015-02-19得票数 4
回答已采纳
这是一个不属于的简单问题--如果重新传递了一个pubsub消息，那么messageId是否与最初的尝试相同，还是随着后续的传递尝试而改变？
浏览 7提问于2022-01-14得票数 1
回答已采纳
1回答
我正在处理多个日志文件，在出了问题时我已经放置了一段代码，同时，我将一条包含错误细节的消息推送到AWS中。现在，当消息被推入SQS时，我想给自己发送一封电子邮件。早些时候我试着用SES。我把SES电子邮件发送代码，但SQS没有发挥作用。我能做什么来实现我的用例？
except:
#this part runs for any corrupted file
sqs_msg_response = queue_client.send_message(MessageBody='Data Processing num_failed')
浏览 0提问于2020-10-27得票数 1
回答已采纳
根据
默认情况下，订阅在不活动31天后到期(例如，如果没有活动连接、请求或推送成功)。如果Pub/Sub检测到订阅者活动，则订阅删除时钟重新启动。使用订阅过期策略，您可以配置非活动持续时间或使订阅保持不变，而不考虑活动。还可以手动删除订阅。
订阅是否被认为是不活动的，即使上面有未加加的消息？
浏览 1提问于2021-05-25得票数 0
回答已采纳
是否可以将消息推送到安装了SNS的应用程序的子集。
当发布到一个主题时，默认情况下，所有订阅者都会收到通知。
浏览 0提问于2014-08-18得票数 0
从医生那里：
没有活动的订阅(推送成功或拉请求) 31天可以自动删除。
我需要设置一个推送消息订阅，它的使用率可能很低(每年几条消息)，但对应用程序至关重要。
上面这句话是官方文件上说的，让我跳了起来！我应该依赖谷歌的公共服务，还是远离它？有更多关于这个自动机构的信息吗？
需要建议。
浏览 1提问于2017-07-04得票数 3
回答已采纳
假设我的数据库中有一个messages节点，其结构如下：
"messages": {
"$messageId": {
"text": "Hello there!",
"created_by": "$userId",
"created_at": 1501749790029
}
}
这条规则是：
"messages": {
".read": "auth != null",
"$messageI
浏览 33提问于2017-08-03得票数 0
回答已采纳
1回答
我试图让一些基于泛美卫生组织的客户端与Vert.xMQTT服务器一起工作。我正在尝试发布到我的接收客户端订阅的测试主题。我很难从我的客户发布者那里得到一条信息给我的客户订阅者。
使用我在互联网上看到的非常多的例子，我把一个MQTT代理组合在一起。Vert.x MQTT代理代码的代码如下：
public class MQTTBroker
{
public MQTTBroker()
{
MqttServerOptions opts = new MqttServerOptions();
opts.setHost("localhost")
浏览 0提问于2017-11-12得票数 1
回答已采纳
我正在尝试使用以下代码将一些会话消息推送到一个数组中：
myConversations: IConversation[] = [];
myConversationMessage: IConversationMessages = {
conversationId: 0,
messageId: 0,
messageText: ''
};
myConversationMessages: IConversationMessages[] = [];
this.conversationService.getConversations().subscribe(conversations =
浏览 46提问于2019-03-20得票数 0
回答已采纳
我通过外部脚本发送推送通知，并捕获从MobileFirst返回的响应。响应始终为200，messageId位于响应JSON对象中。
如何模拟错误情况？
我使用MFP API删除订阅，从MFP控制台的设备选项卡中删除设备。但是，我仍然可以发送和接收该deviceID的推送通知。
浏览 3提问于2017-07-26得票数 0
回答已采纳
3回答
数据丢失
、、
我遇到了GCP的问题，在几秒钟内发布数千条消息时，有一小部分数据丢失了。
我记录了发布端和接收端上每个消息的唯一message_id和session_id，结果是接收端上的某些消息具有相同的session_id，但message_id不同。还有一些信息丢失了。
例如，在一次测试中，我向pubsub发送了5,000条消息，总共收到了5,000条消息，丢失了8条消息。日志丢失的消息如下所示：
MISSING sessionId:sessionId: 731 (missing in log from pull request, but present in log from Flask API)
浏览 5提问于2017-05-29得票数 6
回答已采纳
在发布/订阅“推送”模型中，文档是这样说的：
如果推流端点返回错误码，则使用指数退避策略重试消息，最长7天(最大10秒)。
有没有办法决定在重试时间过后如何处理消息？例如，将其发送到某个错误队列等？
浏览 0提问于2017-02-25得票数 1
我使用Amazon和发送短信。据我所知，Aws::SNS::Client#publish方法只是排队发送消息。
当返回一个messageId时，消息已经保存，Amazon不久将尝试将其传递给主题的订阅者。
我想知道publish方法是否只是对发送进行排队，如果是的话，是否有任何方法可以向SDK确认消息已成功发送？
浏览 4提问于2017-08-17得票数 1
回答已采纳
当从私有存储库()推送/拉取任何映像时，docker存储库向端点提供通知。Google Cloud镜像存储库是否提供了类似的通知机制？这篇文档谈到了发布者应用程序，它将发布消息到pub-sub，但我不清楚-1) GCR是否会直接将消息发布到pub-sub 2)如果不是，如果我必须编写一个发布者应用程序，它如何知道我的存储库上的任何更改。我可能在这里遗漏了一些非常基本的东西，请帮助我理解流程。
浏览 1提问于2018-02-20得票数 0
我们正在评估"Azure服务总线“，以便在web服务器和应用服务器之间用于请求响应模式。我们计划有两个队列：
请求队列
响应队列
Webserver会将消息推送到请求队列，并订阅响应队列。通过比较MessageID和CorrelationId，它可以接收返回的响应，并将响应发送回浏览器。
但是在云上，使用弹性伸缩，我们可以增加/减少web服务器(和应用服务器)实例。我们想知道这种模式在这里是否会以最佳方式工作。
要做到这一点，我们必须有一个请求队列和多个主题(每个web服务器实例一个)。
这有两个缺点：
随着web服务器实例的增加/减少，我们还必须创建/删除主题。
所有消息将被推送到所
浏览 4提问于2017-08-30得票数 1
我收到了一个酒吧/分推订阅的消息。
下面是以原始字节为单位的这样一条消息的有效负载：
REQUEST_BODY b'{"message":{"attributes":{"one":"two"},"data":"InN0dWZmIg==","messageId":"5481363137518973","message_id":"5481363137518973","publishTime":"2022-08
浏览 10提问于2022-08-24得票数 0
回答已采纳
我们碰到过几次这个问题，希望能找到一个解决办法。与图片中的一样，PubSub主题上有一个推送订阅。当单击“查看消息”时，侧面板似乎允许用户选择订阅。但是当用户点击它时，它并没有显示订阅。因此，用户无法“查看消息”。
订阅类型是否与此问题相关，还是此功能不可用？如果是相关的，是否有一种方法可以查看仅具有推送订阅的主题的消息？
浏览 2提问于2019-09-25得票数 1
我有一个客户端应用程序，它将消息发布到单个位置/目标，然后我需要该消息在3个单独的其他队列中结束(并随后处理)基本上是这样的用例:网站以lead形式收集客户信息。该销售线索信息被推送到restful web api。restfull web api随后将消息发布到单个位置，然后将成功结果返回给客户端。在后台，消息最终在4个队列中结束，并最终发送到4个不同的其他web服务(一些是外部的，一些是内部的)
系统需要在处理来自4个队列的所有4个队列的速度方面具有良好的性能。但引线的数量并不一定非常高。(每天可能有几百条线索)
这是我所想的图像
浏览 0提问于2019-01-13得票数 0
1回答
我试图通过MQTT协议在使用WebSphere MQ队列的应用程序和使用Websphere主题的nodeJS应用程序之间发送消息。
我知道我们可以创建一个别名队列：
指向主题(在这种情况下，应用程序通过别名队列侦听新发布)，
指向另一个队列。
现在，我想要相反的程序：
如何创建指向队列的别名主题?在这种情况下，nodeJS应用程序将能够通过来自推送原始队列消息的另一个应用程序的别名主题侦听传入的消息。
配置：
WebSphere v7.5
节点v5.5.0
协议MQTT v3
浏览 0提问于2016-06-21得票数 2
1回答
sns推送通知发布到单个设备
、、、、
--这是我在SNS官方站点上找到的发布到主题的代码
String msg = "My text published to SNS topic with email endpoint";
PublishRequest publishRequest = new PublishRequest(topicArn, msg);
PublishResult publishResult = snsClient.publish(publishRequest);
System.out.println("MessageId - " + publishResult.getMessag
浏览 0提问于2017-05-05得票数 0
我们有mqtt生产者和消费者。MQTT生成器位于客户端级。当我们向producer推送消息时，如果设备打开了，那么它就会收到消息。如果设备被关闭，那么它在打开之前不会收到消息。
我们需要知道，当消息发送到服务器中的MQTT时，如果服务器关闭了，那么我们需要知道它的状态是，它是否正在排队或未被服务器接收。
在此基础上，我们将向用户as发送消息，请打开设备进行具体操作。
有没有更好的方法来了解MQTT中的状态，以查找消息是否已发送、失败或排队以了解服务器是否处于活动状态。
浏览 0提问于2020-06-04得票数 0
有什么方法可以让AWS SQS调用我的REST呢？基本上，只要消息被推送到AWS SQS，我就想听到它并执行所需的操作。我可以安排一个监听器，它可以每秒钟提取消息，但这不是一个优化的解决方案，队列也可能是空的(有时)。
提前谢谢！！
浏览 3提问于2017-02-27得票数 2
回答已采纳
1回答
所以我设置了推送通知。当多个客户端连接并推送消息时，每个其他客户端都会收到该消息。这很好，但我需要的是让Pubnub也推送给发送消息的人。我该怎么做呢？
我正在使用这个函数来监听。是否有某种我可以指定的选项，以便我也能收到通知？
PUBNUB.subscribe({
channel: "notify",
callback: function(data) {
alert(data.message);
}
});
浏览 3提问于2012-09-25得票数 1
1回答
实时推送消息
、、、
我正在尝试将每秒100条左右的XML消息推送到第三方web客户端。
推送目前与HTTP POST一起工作。
我想知道做这件事的好方法是什么？
有没有针对C#的实时推送？
浏览 1提问于2014-02-25得票数 1
我曾经使用RabbitMQ作为消息传递平台，但我从来没有遇到过任何问题--不幸的是，我们最近将基础设施转移到Azure，他们不提供RabbitMQ服务器，所以我考虑尝试服务总线扩展。
我有一个作家和多个读者，。目前，每个读者都将读取不同的消息(消息竞争模式--例如，有利于负载平衡)。
我想要的是，所有的读者都会得到相同的消息并自己处理它。
读者：
string connectionKey = "....";
this.client = QueueClient.CreateFromConnectionString(connectionKey, "dev&#
浏览 2提问于2016-05-21得票数 6
回答已采纳
我有一个主题topicA与主题topicA的订阅subscriptionA相关联的deadLetterTopicA。下面是订阅subscriptionA的配置
dead_letter_policy { dead_letter_topic："deadLetterTopicA“max_delivery_attempts: 5}
因此，如果我能够处理我正在调用的message.ack()的消息，如果由于我所依赖的其他服务的中断而出现任何错误，我将调用message.nack()，以便重新传递该消息。但是，从日志中我可以看到，传递尝试大于5，这是出乎意料的。
..... message_id
浏览 6提问于2022-05-21得票数 0
回答已采纳
1回答
我想知道是否可以让发布服务器在jedis中将消息推送到一个频道，并且在一个完全独立的类中，让订阅者在同一个频道上监听消息。
例如，对于一个类，有
jedis.publish(CHANNEL_NAME, entry.toString());
在另一堂课上，听
jedis.subscribe(subscriber, CHANNEL_NAME);
其中，订阅者是扩展JedisPubSub的内部类。
谢谢你的帮忙!
浏览 2提问于2015-06-24得票数 1
回答已采纳
2回答
我正在尝试使用Firebase向iOS发送推送消息。已经为开发和生产设置了APNS证书，确认可以接收远程消息。我认为没有办法只在Firebase控制台中为开发发送消息。
浏览 0提问于2016-07-26得票数 4
一次在Pub Sub推送订阅中可以有多少未确认的消息。 如果订阅有超过100条消息，它将如何影响新的消息传递。
浏览 24提问于2021-04-23得票数 0
回答已采纳
在推送到Azure Queue之前，我正在尝试自定义JMSMessageID，由于某些原因，此id没有进入队列，相反，我看到针对MessageID生成了一个随机ID。当我调试代码时，在调用MessageProducer.send( messageID )之前，我可以看到消息已被正确设置。我们使用的是spring框架JMSTemplate。有人能帮帮忙吗？
jmsTemplate.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException
浏览 7提问于2017-12-16得票数 1
2回答
我想在发布时为redis pub/sub消息设置过期时间。如何在nodeJS中实现？
var redis = require('redis');
redis.createClient().publish('some channel', 'some message', function(err) {
if (err) {
console.error('error publishing:', err);
}
});
上面是推送消息的代码。要设置已发布消息的过期时间，我必须做哪些更改。
浏览 4提问于2017-05-23得票数 1
1回答
我正在使用此链接中的MQTT客户端库。
我的示例代码如下：
public partial class Form1 : Form
{
MqttClient client = null;
public Form1()
{
InitializeComponent();
client = new MqttClient("broker.hivemq.com");
byte code = client.Connect("lenovofullondude");
}
private
浏览 2提问于2019-03-24得票数 0
回答已采纳
我正在实现一个队列，用于使用PubSub主题摄取数据。我的计划是使用推送订阅使数据在发布时立即处理。
在使用Pull时，我看到了许多代码模式试图在每次运行中重新创建一个请求订阅，以保证在下一个拉周期中我们有一个活动订阅。
我应该使用推送订阅进行同样的操作吗？IMHO没有，但我担心在某种程度上，推送订阅不是永恒的，应该被监控，以保证下一次消息发布时主动推送订阅。
什么是推送订阅创建的好设计模式？我应该使用PubSub管理接口创建一次推送订阅，还是以编程方式创建(甚至重新创建)？
浏览 2提问于2016-10-25得票数 1
回答已采纳
1回答
基于官方
我尝试使用"PubSub拉订阅“触发器创建一个云函数。
import base64
def hello_pubsub(event, context):
"""Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
context (google.cloud.functions.Context): Metadata for the event.
"""
浏览 4提问于2020-07-22得票数 4
回答已采纳
1回答
使用实时照片更新()，可以在创建媒体时或在发布具有特定标签的媒体时进行推送更新。
当有人喜欢媒体时，有没有办法获得最新消息？我没有找到任何东西，我试着订阅不同的对象，但当我执行like操作时，回调永远不会被调用。
浏览 4提问于2015-03-20得票数 0
我们尝试对云PubSub推送订阅者进行一定的速率限制，将推送订阅者吞吐量kB配额设置为1，有效意味着PubSub对推送订阅者的处理不超过1kbps。 但是，实际吞吐量可能会更高，大约为6-8kbps。 为什么没有像预期的那样限制吞吐量呢？ 更多详细信息： 其目标是将速率限制为每秒50条消息。 我们可以假设平均消息大小，为了测试的目的，我们使用50字节的消息，即50字节* 60秒= 3000字节/秒，或每秒3kbps的消息。通过将配额设置为1，我们预计PubSub每秒推送的消息将少于50条。在测试过程中，我们得到的远不止这些。
浏览 10提问于2019-03-13得票数 0
我正在从推送订阅转到拉订阅订阅。假设我的服务有几个实例在运行，在部署推出期间，推送和拉入都将发挥作用，直到所有实例都更新。我不想让消息事件松散，也不想让事件同时被推和拉。简单地将主题和订阅的单独版本用于pull，然后在第二个部署中删除旧的push版本，然后在主题被排出后删除，这是否是最佳实践？或者有更好的方法来做这件事？
浏览 3提问于2021-10-18得票数 0
1回答
我计划重新设计一个现有的系统，使用Akka，Play和Websockets。
我目前的系统是基于Jetty和Websockets的。
我有一个快速的消息流被发布到一个Redis频道。在我的web应用程序层中，我使用Jedis订阅服务器订阅这些消息，然后将这些消息推送到Websocket，然后显示在浏览器上。
我想让这个转变有两个主要原因：( a)由于使用了Actors ( b)能够使用不同的参与者连接到多个流，所以更好和更简单的容错。
在我目前的设计中，我有一个主管，为每一个新频道创建一个新的儿童演员。然后，子演员订阅一个Redis频道。我的问题是，将消息(从Redis频道接收)推送到播放We
浏览 2提问于2014-03-21得票数 0
回答已采纳
1回答
我是Azure的新手，在过去的几周里一直在学习可能和服务总线。
我正在尝试从Azure服务总线队列中读取消息。QueueClient接收方法将把消息从队列中拉出，这是我最初不想做的。因此，我使用Peek()方法在while循环中一次浏览队列中的所有消息。然后将消息的correlationId与在本地DB表中内部维护的相关Id进行比较。
只有当关联ID匹配时，我才会继续并接收消息。但是，为了使用messageSequencenumber接收消息，我了解到必须首先延迟消息，获取存储在列表或其他内容中的messageid，然后使用QueueClient Receive()方法接收消息，最后将消息标记
浏览 2提问于2015-04-10得票数 1
我有以下场景:我在Azure服务总线中订阅了2个微服务，一个微服务用于发送推送通知，另一个用于发送电子邮件，这些微服务将永远不会一起工作，因此消息将只由一个微服务执行。
我正在搜索，看起来是一个好主意，把消息发送到一个主题，并有一个过滤器，以选择什么微服务应该执行的操作。
所以我有两个问题：
我应该使用主题和过滤器吗？不确定是否有更好的做法。
如果是，是否存在将消息发送到正确订阅的方法？例如，我将消息发布到订阅X，而不是发布所有订阅。
谢谢
浏览 1提问于2020-04-23得票数 0
回答已采纳
我有多个需要通知某些事件的微服务。所有这些微服务都运行在Cloud Run上。鉴于Cloud Run可以缩减到0个实例，我假设推送模型更适合我们的情况。 问题出现在需要将通知发送到多个端点的情况下。例如，我们有一个OrderService、一个InventoryService和PaymentService。后两者都需要监听“OrderPlaced”事件。问题是，我们如何才能在不显式调用它(例如，使用任务队列)或在OrderService中创建依赖项的情况下，将此消息推送到这两个服务？有没有一个“Google Cloud”的方法来解决这个问题？ 我已经考虑过创建“拉”监听器，但问题是Cloud
浏览 38提问于2020-04-26得票数 0
回答已采纳
我正在使用以下GCP发布/订阅REST API来拉取和确认消息。拉取消息：-
POST https://pubsub.googleapis.com/v1/projects/myproject/subscriptions/mysubscription:pull
{
"returnImmediately": "false",
"maxMessages": "10"
}
确认消息：-
POST https://pubsub.googleapis.com/v1/projects/myproject/subscriptions/my
浏览 5提问于2021-11-25得票数 0
我正在构建一个客户端浏览器应用程序，它通过AJAX使用Ruby Rails 3编写的服务器端json API。这一切都运行得很好，没有问题。但是，当其他用户通过API执行操作时，我希望将数据推送到用户客户端，而不必让客户端不断轮询服务器以获取新数据。
因此，我设置了一个Node.js和Socket.IO应用程序作为推送服务器。客户端连接到Socket.IO服务器并订阅所需的频道。但问题是，我如何让Rails应用程序将消息发送到Node服务器，以便在这些通道上发出？
我想我可以向Node服务器上特殊路由器生成一个post请求，但是有没有更好的方法呢？我如何确保post请求来自我的rails应用程
浏览 2提问于2012-12-25得票数 2
在Angular4中，我们可以直接将消息推送/拉到，而无需调用后端的任何服务/代码吗？如果有可能的话，我们该怎么办呢？
提前谢谢。
浏览 4提问于2017-08-07得票数 3
我一直在尝试在Airflow中使用PubSubPullSensor来拉取JSON消息并将其摄取到bigquery中，当消息大小超过阈值时，传感器无法通过XCOM拉取消息并推送。我知道XCOM有一个最大大小限制，但是我们如何克服这种情况，对于这种情况有什么变通办法吗？
浏览 3提问于2020-05-12得票数 0
1回答
我对这个问题不太确定，我想得到一些澄清。
您正在使用Cloud /Sub将来自许多销售点(POS)终端的库存更新流到BigQuery中。每个更新事件都有以下信息:产品标识符“prodSku”、更改增量“quantityDelta”、POS标识“termId”和“messageId”，这些信息是为终端的每次推送尝试创建的。在网络中断期间，您发现发送了重复的消息，导致库存系统对更改进行了过多的计数。您确定终端应用程序存在设计问题，并可能在推送重试期间发送同一事件多次。您希望确保库存更新是准确的。你应该怎么做？
检查每条信息的“publishTime”。确保其“publishTime”值与BigQu
浏览 2提问于2022-09-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
