MQ消息回执通知
本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时，...MQ成功接收DLA消息后，您就可以通过MQ实时了解DLA异步执行SQL的任务详情。关于MQ，请参见 什么是消息队列RocketMQ版？
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
MQ 事务消息纳入全局事务管理样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明 样例...
基于事件流实现RocketMQ消息路由
MQ_INST_115964845466*_ByBehioo Topic 选择生产 消息队列RocketMQ版 消息的Topic。topic Tag 配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，...
云消息队列 RocketMQ 版
说明 如果您的MQ消息为二进制格式，则DDL中只能定义一个字段，且字段类型必须为VARBINARY。创建将 keys 和 tags 字段指定为RocketMQ消息的key和tag的结果表 RocketMQ 5.x CREATE TABLE mq_sink(id INTEGER,len BIGINT,content VARCHAR,keys...
基于事件流实现RabbitMQ消息路由
本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RabbitMQ 版 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
GetMqConsumerTag-获取工单RocketMQ消息监听的TAG
获取工单RocketMQ消息监听的TAG。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 ...
消费托管MQ接口
确认消息 消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数 参数 必选 说明 streamId 是 队列ID，即数据导出服务中的任务ID。...
微消息队列MQTT版推送事件到函数计算
MQ4IoT支持点对点消息，即如果发送方明确知道该消息只需要给特定的一个设备接收，且知道对端的Client Id，则可以直接发送点对点消息。点对点消息不需要经过订阅关系匹配，可以简化订阅方的逻辑。点对点消息的Topic格式规范是{{parentTopic}...
QueryMqttTraceMessagePublish-查询消息发送轨迹
mqtt.trace.action.msg.pub.mq：消息动作取值为 pub_mq时返回该参数值。mqtt.trace.action.msg.pub.mqtt ActionInfo string 消息动作的说明信息。取值说明如下：Pub From Mqtt Client：消息动作取值为 pub_mqtt时返回该参数值。Pub From MQ...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
微消息队列MQTT版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 MQTT 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 云消息队列 MQTT 版 实例...
云消息队列 MQTT 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，以实现将 云消息队列 MQTT 版 的数据流入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
MQ配置
开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入授权的目标账号ID。具体的账号ID请向对口技术同学二次确认。创建成功后，在RAM...
设备报警事件
IoT云端订阅设备alarmEvent事件和上下线的MQ消息，将其转换为DOP数据模型，由上层应用订阅获取设备消息。模型ID：DeviceAlarmEventBasic 模型版本：1.0 属性名称 属性标识符 数据类型 数据描述 租户id tenantId String 租户id 事件时间 ...
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。...可以消费掉刚刚 sample-txc-mq 工程生产出来的 MQ 消息。
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
授权信息
消息队列 MQ（Ons）的RAM代码（RamCode）为 mq，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式，其通用结构如下：{"Version":"1","Statement":[{"Effect":"<Effect>","Action":"<Action>","Resource":"<Resource>",...
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
服务关联角色
应用场景 物联网无线连接服务的MQ消息推送功能，需要访问消息队列RocketMQ版云服务的资源，通过服务关联角色功能获取访问权限。关联角色介绍 角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":...
API 概览
本节给出BaaS REST的所需的SDK列表，具体接口信息请参阅相关文档。...针对两种模式，有对应的配套的API，分别介绍如下。...消费托管MQ接口 接口 描述 consumeMQMessage 获取托管MQ中的消息 ackMQMessage 消费托管MQ消息成功后，进行确认
旧版样例简介
sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...
sample-txc-edas 样例
该样例综合了 GTS、EDAS 及 MQ 的使用，...在 sample-mq-consumer 目录下执行 build.sh 编译该工程，编译完成后在 sample-mq-consumer/client/bin 目录下执行 run.sh 可以消费掉刚刚 sample-txc-edas/txc-client-mq 工程生产出来的 MQ 消息。
消息队列RocketMQ版
MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息的Topic。topic Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。GID_http_1 消费位点 选择开始消费消息的...
产品功能发布记录
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。2020.02.27 相关文档 Hyperledger Fabric【云服务集成】数据库 如果您希望区块链上的数据能导出到关系型数据库，您可以将...
模块开通
单地域 双地域 企业版RocketMQ 阿里云企业版MQ服务容灾模块，保证MQ消息收发的容灾调度与消息数据RPO。单地域 双地域 DRDS服务 DRDS容灾模块，保障数据的RPO。双地域 OceanBase服务 OceanBase服务容灾模块，保障数据的RPO。双地域 PolarDB ...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
消息队列RabbitMQ版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务，实现将其他数据源中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买...
消息队列RocketMQ版
MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息的源Topic。topic Tag 云消息队列 RocketMQ 版 中用于过滤消息的标签。test_tag Group ID 快速创建：自动创建以GID_EVENTBRIDGE_xxx 命名的Group ID。使用已有：选择源实例中的消费组...
支持STS的云服务
控制台 API 企业级分布式应用服务-edas√消息队列MQ 消息队列Rocket MQ版 mq√消息队列MQ 微消息队列MQTT版 mq√消息队列MQ 消息队列RabbitMQ版 amqp√云服务总线CSB-csb√性能测试-pts√消息服务-mns√应用配置管理-acms√消息队列Kafka版...
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
如何快速使用微消息队列MQTT版的Java SDK收发消息？
本文提供使用 微消息队列MQTT版 的Java SDK收发消息的快速入门视频。
云消息队列 RocketMQ 版
MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 消息队列RocketMQ版 消息的Topic。topic Tag 配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，...
- 产品推荐
- 这些文档可能帮助您