消息发布与订阅
云数据库Redis版也提供了与Redis相同的消息发布（publish）与订阅（subscribe）功能。即一个客户端发布消息，其他多个客户端订阅消息。场景介绍 云数据库Redis版发布的消息是“非持久”的，即消息发布者只负责发送消息，而不管消息是否有...
混合云解决方案
场景说明 ApsaraDB for SQL Server混合云解决方案用于实现本地SQL Server服务与RDS SQL Server服务之间的数据传输或者同步。利用SQL Server复制技术实现数据的同步，其典型应用场景就是写数据在本地，读数据在RDS...RDS的订阅数据库版本不限。
账号权限详情
订阅允许将来自发布（publication）的更改应用到订阅数据库。SQL示例 创建订阅。仅为示例，详细使用方法，请参见 CREATE SUBSCRIPTION。CREATE SUBSCRIPTION test_subscription CONNECTION 'host=<发布端连接地址>port=<发布端端口>dbname=...
使用Canal和RocketMQ实现数据库变更订阅处理
方案介绍 基于Binlog日志实现增量订阅和消费的典型业务场景如下：数据库镜像、数据库实时备份 索引构建和实时维护（拆分异构索引、倒排索引等）业务Cache更新 和业务逻辑相关的增量数据处理 基于Canal和 云消息队列 RocketMQ 版 的CDC方案...
Serverless实例计费说明
阶梯单价 Serverless实例的消息收发单价在不同地域有所差异，具体价格如下：公共云地域单价 标准版实例消息收发单价 地域 计费阶梯 月度消息收发累计次数（亿次）普通消息发送（元/百万次）普通消息订阅（元/百万次）高级消息发送（元/百万...
主题模型基本概念
订阅者（Subscriber）消息订阅者，从主题接收消息的客户端，主题所有者默认拥有该主题的订阅权限。订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以接收发布者发布到该主题的消息。消息过滤标签（FilterTag）...
查看应用性能详情
消息订阅 页签显示了指标趋势和数据源明细，包括所选应用调用的消息订阅的消息主题（Topic）、请求次数等信息。参数说明可参考下表。参数名 说明 单位 Topic 所选应用调用的消息订阅的消息主题（Topic）。请求次数 所选应用调用消息订阅的...
中间件监控指标
ant cloud agent Msg Sub Detail 消息订阅详情-ant cloud agent DB 监控 指标名称 说明 单位 数据源 DB Request 数据库请求数（主要是针对 zdal 接入的数据库）个 ant cloud agent DB Request Avg Cost 数据库请求平均耗时 ms ant cloud ...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更多信息，请参见 基本概念。MessageModel 设置Consumer实例的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。...
概述
支持String（字符串）、List（链表）、Set（集合）、Sorted Set（有序集合）、Hash（哈希表）、Stream（流数据）等多种数据结构，同时支持Transaction（事务）、Pub/Sub（消息订阅与发布）等高级功能。在社区版的基础上推出企业级内存数据...
普通消息
TCP SDK收发普通消息的示例代码 Java 发送普通消息（三种方式）发送消息（多线程）订阅消息 C或C++ 收发普通消息 订阅消息.NET 收发普通消息 订阅消息 HTTP SDK收发普通消息的示例代码 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议...
接口和参数说明
消息订阅接口 消息订阅参数 参数名 参数说明 GROUP_ID 您在消息队列控制台上创建的 Group ID，详情参见 基础术语。MESSAGE_MODEL 设置 Consumer 的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。BROADCASTING：表示广播...
应用总览
调用 DB 服务-dal 数据库访问。用来监控应用访问数据库的相关指标，配置要求如下：SOFA 框架中默认使用/home/admin/logs/tracelog/zdal-db-stat.log。自定义配置中可以使用自己设定的日志文件，要求日志文件中必须有：数据源、库、表、结果...
开发部署扩展程序：自建服务方式
因此，开发并使用扩展程序前，需先开启消息订阅，获取消息订阅的EventBridge信息、订阅事件的消息体格式，用于后续扩展程序的代码开发。开启消息订阅，详情请参见 开启消息订阅。订阅事件的消息体格式，详情请参见 附录：消息格式。步骤二...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控，专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏，单击 应用管理>应用列表，在顶部菜单栏选择地域并在页面上方选择微...
参数说明
由于云端SDK订阅消息一般用于云上应用进行消息汇总和分析等场景，因此，云端SDK订阅消息不支持设置子级Topic。设备上下线事件 表 3.设备上下线事件参数 参数 说明 gid 您在 云消息队列 MQTT 版 控制台创建的Group的ID。更多信息，请参见 ...
接口和参数说明
由于云端SDK订阅消息一般用于云上应用进行消息汇总和分析等场景，因此，云端SDK订阅消息不支持设置子级Topic。messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：...
配置变更
在迭代详情页面，用户可以对当前研发迭代进行配置变更。技术栈配置 技术栈配置是从 SOFAStack 的应用服务同步获取，由于目前仅技术栈 2.0 提供查询...所有的配置会保存到数据库中，如果需要生效到对应环境，可进行 同步和生效 DRM 配置 操作。
旧版订阅迁移至新版订阅
订阅消息的格式 旧版订阅的格式。新版的订阅SDK：DefaultUserRecord。Flink客户端：DataStream API、Table API和SQL。Kafka客户端：Avro。问题排查 无 根据新版SDK的报错排查新版订阅任务问题：问题排查 使用DTS定制工具包排查新版订阅任务...
开启消息订阅
DataWorks的OpenEvent通过EventBridge为您提供事件消息订阅与发送服务。在EventBridge中创建自定义总线后，您需要在DataWorks中配置消息事件分发通道，以便在EventBridge中创建规则并完成事件的发布。本文为您介绍如何开启消息订阅服务与...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
设备模拟器
具体功能如下：功能项 说明 上行指令调试 设备上报消息到物联网平台，包含：自定义Topic的消息上报和消息订阅 属性上报 事件上报 下行指令调试 物联网平台下发指令到设备，包含：自定义Topic的消息下发 属性调试（含获取、设置）服务调用 ...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
基础版/铂金版实例计费
对于QoS=1且cleanSession=false的消息，服务端如果没有推送成功，则存储为离线消息等待重试，并计算为一次订阅消息。消息TPS计算时，需要根据传输质量乘以对应倍率。具体倍率，请参见 计价倍率。例如，若客户端设置为QoS=2且cleanSession=...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
使用Flink SQL消费实时变更数据示例
云原生多模数据库 Lindorm 支持实时数据订阅功能，对实时变更数据进行计算，可以为实时监控，实时报表和流数据分析功能提供有效数据。通过Flink Kafka Connector可以从底层存储消费订阅数据，同时Flink Kafka Connector对订阅数据进行解析...
API概览
消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。UpdateConsumerGroup 更新消费者分组 更新消费者分组的基础信息和消费重试策略。DeleteConsumerGroup 删除消费者分组 删除指定的消费者分组。ListConsumerGroups 查询消费者...
开放平台概览
开放事件（OpenEvent）DataWorks开放平台的开放事件功能为您提供消息订阅服务，通过订阅DataWorks事件状态，应用系统对接DataWorks，实时获取相关内容的状态变化，帮助您及时响应，满足您的个性化决策需求。关于开放事件功能，具体请参见 ...
基于MQTT Topic通信
取消消息订阅 重要 Python Link SDK的1.0.0至1.2.11版本中，设备与物联网平台连接断开后，继续调用以下接口取消消息订阅会抛出异常，需要您做好异常处理。在1.2.12版本后，该API执行失败后，会返回非零错误值，不再抛出异常。通过调用 ...
应用场景
通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据（例如注册、登录、充值、支付、购买），根据业务数据类型将消息发布到不同的Topic，然后利用订阅消息的实时投递，将消息流用于实时处理、实时监控或者加载到Hadoop...
园区空间数据变更订阅
1、消息订阅 1、获取项目appkey和appSecret 使用阿里云账号登录数字园区引擎，登录后如下图所示 点击对应的园区，则会进入该园区的管理页面，在园区概览菜单下，可以查看园区项目的appKey和appSecret 2、获取实例ID 3、获取数据模型id 在...
使用Topic通信
将指定设备数据流转到消息服务（MNS）、云数据库RDS、表格存储、函数计算、时间序列数据库TSDB、云原生多模数据库Lindorm、DataHub、消息队列RocketMQ等云产品中。云产品流转的概念、流程请参见 云产品流转概述。可选步骤 查看云端日志 ...
什么是服务端订阅
服务端接收产品下全部设备的订阅数据。说明 如果您有多个服务器消费同一个产品的订阅消息，消息会随机转发至某个服务器。服务端订阅与规则引擎数据流转的使用场景和能力对比，请参见 数据流转方案对比。使用AMQP服务端订阅消息 AMQP...
OpenEvent概述
DataWorks的OpenEvent旨在将DataWorks的各类状态变更情况以消息的方式触达到用户，便于用户订阅消息并做出个性化的响应。例如，您可以通过OpenEvent订阅表变更，从而实现核心表的实时监控；通过OpenEvent订阅任务变更，实现定制化开发实时...
参数说明
消息订阅参数 参数名 参数说明 consumerGroup Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组，即您在阿里云RocketMQ控制台上创建的Group ID，详情请参见 基本概念。...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
设备数据订阅
完成身份认证和对接进行设备的消息订阅。Demo示例 a.配置参数/System.getenv("iot.hosting.appKey")方法可以从环境变量中获取appkey和appsecret String appKey=System.getenv("iot.hosting.appKey");String appSecret=System.getenv("iot....
订阅方案概览
数据订阅功能可以帮助您获取数据库的实时增量数据，您可以根据自身业务需求自由消费增量数据，并写入目标端，实现各类业务场景，例如缓存更新、业务异步解耦、异构数据源数据实时同步及含复杂ETL的多种业务场景。数据订阅方案 说明 是否...
- 产品推荐
- 这些文档可能帮助您