默认情况下，云消息队列 Kafka 版 为了提升可用性，并不保证单个分区内绝对有序，在升级或者宕机时，会发生少量消息乱序（某个分区挂掉后把消息Failover到其它分区）。如果业务要求分区保证严格有序，请在创建Topic时选择使用Local存储。
如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。核心概念 Topic：消息...
这允许系统根据消息本身的特性、现有的业务需求或其他动态因素实时调整路由决策，从而提高了消息传递的灵活性和效率。元数据导入 安全合规 功能集 功能 功能描述 参考文档 数据加密 支持SASL、SSL接入点 SASL和SSL提供了两个关键的安全特性...
混合分布式事务 有些系统在使用数据库保证系统内数据一致的同时，也会使用消息队列作为和其他系统间的消息传递，完成不同系统间的数据一致。例如会员注册服务和邮件发送服务，当用户注册会员成功，需要给用户发送一封邮件，告诉用户注册...
新消息写入能自动分配递增的顺序ID，保证永远插入队尾：Timeline中是根据同步位点也就是顺序ID来同步消息，所以需要保证新写入的消息数据的顺序ID绝对不能比已同步的消息的顺序ID还小，否则会导致数据漏同步，所以需要支持对新写入的数据...
消息类型：指在特定渠道上支持的不同类型的消息传递方式。根据渠道的特性和技术能力，可以选择支持发送图片、发送文件、发送语音等不同的消息类型。选择接待技能组：指为特定渠道配置可接待的技能组。每个渠道当前只支持转接到一个特定技能...
降低了消息传递的延时、少了一次远程访问、避免了函数计算的冷启动。去除了一个服务依赖、提高了容错性。Serverless 工作流 未来会推出更多的云服务集成，让不同类型任务组成的工作流编排变得更加容易。服务集成功能 下图中3个串行的任务由...
功能介绍 随着企业业务的不断发展，消息传递的需求也日益增加。RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积...
消息类型：指在特定渠道上支持的不同类型的消息传递方式。根据渠道的特性和技术能力，可以选择支持发送图片、发送文件、发送语音等不同的消息类型。选择接待技能组：指为特定渠道配置可接待的技能组。每个渠道当前只支持转接到一个特定技能...
如何传递文本消息 Linux-SDK 提供了两种文本消息的传递模式：P2P 场景：推荐 DataChannel 传递，调用 Session->SendData 方法（高频消息，能保证按顺序收发）。其他场景：使用 Room 中转的模式，调用 Session->SendText 方法（低频消息可能...
CMNS介绍 Cloud Message Notification Service（CMNS）云消息通知服务，实时跨平台数据通道，您可以使用CMNS进行通知和消息的传递。CMNS使用场景 CMNS主要有以下三种使用场景：服务端下发通知：服务端可以根据设备对象进行通知分发。对象...
使用建议 合理划分主题和Tag标签 从消息的过滤机制和主题的原理机制可以看出，业务消息的拆分可以基于主题进行筛选，也可以基于主题内消息的Tag标签及属性进行筛选。关于拆分方式的选择，应遵循以下原则：消息类型是否一致：不同类型的消息...
支持Meta、消息的基本管理（数据的CRUD）。支持Meta、消息的多维组合查询、全文检索。支持SequenceId的两种设置：自增列、手动设置。支持多列的Timeline Identifier。兼容Timeline 1.X模型，提供的TimelineMessageForV1样例可直接读写V1...
这时服务实例升级不仅需要将新版本的软件包部署到ECS实例中，还需要更新弹性伸缩组生命周期挂钩中的软件包地址，从而保证新扩容的ECS实例商部署的是新版本软件包。流程介绍 此处介绍了该最佳实践的整体流程。创建部署物 使用软件包部署物...
7）Nats变量 NATS是一个开源的消息传递系统，用于在云中或者在数据中心内部传递数据。1.点击创建变量后，出现创建变量弹窗，在变量类型下拉框中选择nats，选择nats后会展示nats变量的面板。2.填写nats表单中的必填项，非必填项可不填写。3....
Message：队列中承载消息的实体，包含了消息的完整内容。Timeline Data Timeline的数据部分就是Message，Message主要包含以下两部分。Message：消息实体，其内部也可以包含任意数量任意类型字段。Message Index：消息数据索引，可对消息...
集成流引擎自身定义了一些核心数据类型，主要包括：类名 简介 相关文档 StepMessage 集成流节点之间传递的消息格式。StepMessage Entity 承载数据的实体，是对二进制数据的封装。Entity HTTP类 对HTTP Request、Response的封装，使用HTTP...
在分布式事务服务挂掉的情况下，事务是否能正常回滚？分布式事务的服务端会记录下事务的状态并持久化，即使服务挂掉，在服务重新启动后，事务仍然能够正常回滚。建表时，是否可以使用 SQL 的关键字作为列的名称？不可以，建表时列名不能...
Sharding Key 是顺序消息中用来区分不同分区的关键字段，和普通消息的 Message Key 是完全不同的概念。详情请参见 消息类型>顺序消息。分布式事务 distributed transaction，事务的发起者、资源及资源管理器和事务协调者分别位于不同的分布...
您理解许可软件仅在当前使用或包含该等服务，短趣无法保证许可软件将会永久地使用或包含该等服务，也无法保证将来不会使用或包含该第三方的同类型或不同类型的软件或服务或其他第三方的软件或服务，一旦短趣在许可软件中使用或包含前述软件...
这一功能保证了进程可用性，避免进程因异常挂掉或机器重启等原因，需要手动拉起的情况。所以，您在服务器进程中结束 AHAS Agent 无法永久结束该进程，AHAS 会在定时检查后或机器重启时，自动拉起该进程。如果您某段时间不需要使用 AHAS ...
物联网平台根据MQTT协议，仅定制了RRPC消息的请求和响应机制。设备端若要获取物联网平台下发的RRPC消息数据，并做应对处理，需要在设备端先订阅Topic，然后开发数据处理逻辑。设备可通过发送 SUB 指令订阅指定Topic，实现从物联网平台获取...
音视频管控服务还需要根据用户A邀请的信息找到用户B信息，同样封装一条邀请入会的消息，传递流程同 步骤2。会议参与者用户B收到参数后加入会议，本次通信初始化完成。基于上述设计思路，可以使用 云消息队列 MQTT 版 消息实现其他自定义...
延长一个生命周期挂钩触发后被挂起的ECS实例的等待时间。接口说明 ECS 实例的等待时间不能超过 6 小时，每次等待状态最多能被延时 20 次。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI ...
本文档以数字大屏1上的 Tab列表 组件控制数字大屏2上的 通用标题 组件为例，实现跨屏联动功能。效果展示 使用场景 当您有多个可视化应用，并希望多个可视化应用内的组件能展示相互联动的...连接成功后，根据文档中的消息格式传递参数即可。
本文档以数据看板1上的 Tab列表 组件控制数据看板2上的 通用标题 组件为例，实现跨屏联动功能。效果展示 使用场景 当您有多个数据看板，并希望多个数据看板内的组件能展示相互联动的效果。...连接成功后，根据文档中的消息格式传递参数即可。
在挂起弹性收缩活动的 CONTINUE 类型生命周期挂钩时，或者对于弹性扩张活动，后续生命周期挂钩会继续挂起伸缩活动，直到最后一个生命周期挂钩触发的等待状态结束。最终的下一步动作以最后一个结束等待状态的生命周期挂钩类型为准。...
调用RecordLifecycleActionHeartbeat延长一个生命周期挂钩触发后被挂起的ECS实例的等待时间。接口说明 ECS实例的等待时间不能超过6小时，每次等待状态最多能被延时20次。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的...
单击 或 图标配置多个接收消息的排列样式。单击 图标，即可复制当前选中接收消息配置内容并新增一个同样配置的接收消息。发送消息 该 WebSocket 节点发送到其他端的消息名称。单击右侧的 或 图标，添加或删除一个发送消息。单击 或 图标...
公司总部位于中国上海，专注于为企业和开发者提供高性能、可靠和安全的物联网消息传递平台。业务挑战 作为一家创新驱动的公司，EMQ致力于解决物联网领域面临的挑战，包括大规模设备连接、消息传递效率和数据安全等方面。EMQ的核心产品是EMQ...
不同数据类型分片策略 Shard表示对DataHub的一个topic进行数据传输的并发通道，单个Shard写入速率有上限，多个Shard可以提高写入性能，但DataHub仅能保证单个Shard在消费时的有序性，不保证多个Shard之间消息的顺序。因此，为了既能通过...
当应用服务器B创建完成后，如果您直接访问服务器B的公网IP，将会出现如下图所示的报错信息：造成该问题的原因是因为在宝塔面板中，网站对应的域名设置仍然为应用服务器A的公网IP，因此，您需要登录宝塔面板将应用服务器B的公网IP添加至域名...
若报错与上图一致，则原因一般是：未能在Windows上启动本地消息传递主机，“未设置环境变量COMSPEC”导致。a.在环境变量的系统变量中新建或修改变量ComSpec即可，变量值%SystemRoot%\system32\cmd.exe，如下图所示。重装edge浏览器并重新...
现象一：若报错与上图一致，则原因一般是：未能在Windows上启动本地消息传递主机，“未设置环境变量COMSPEC”导致。在环境变量的系统变量中新建变量ComSpec即可，如下图所示。重装chrome浏览器并重新安装chrome插件即可。现象二：若报错与...
当累计用户数≥50000时，按累计用户数*2计算 单用户推送限制（条/日）不限量 新闻类（三级分类为新闻类）：5 条 其他应用类型：2 条 应用类别以创建应用时应用基本信息所提交的“软件分类”为准；若需修改应用类别，可在移动应用列表-应用...
生命周期挂钩可以暂停由弹性伸缩自动触发的伸缩活动，使ECS实例或ECI实例处于挂起中的状态（即等待的状态），为您保留一段自定义操作的时间以满足特定的部署需求和业务场景，例如预装软件等。直至生命周期挂钩超时结束后，弹性伸缩的伸缩...
此场景中，MQTT客户端产生上下线等状态变更，云消息队列 MQTT 版 会根据您配置的客户端状态通知规则，将状态变更封装后转发到 云消息队列 RocketMQ 版 消息的方式来实现客户端状态数据的聚合和统计。说明 针对其他场景，推荐您使用同步查询...
迁移与同步 为什么OSS外表导入ORC、PARQUET等格式的数据，出现内存报错或OOM挂掉？如何处理导入数据报错：too many parts？为什么DataX导入速度慢？为什么Hive导入后其数据行数跟ClickHouse对不上？为什么Kafka导入后其数据行数跟...
message_id String 本次消息的ID，由SDK自动生成。task_id String 任务全局唯一ID，请记录该值，便于排查问题。status_text String 状态消息。payload对象参数说明：参数 类型 说明 index Integer 句子编号，从1开始递增。time Integer ...