数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
数据出口
数据出口至 自建云，使用的是消息队列MQ，透过MQTT订阅与消费数据。操作方法 根据用户的不同，我们推荐不同的操作方法。对入门组网开发的用户，我们推荐从阿里云物联网平台控制台来完成LoRaWAN设备接入。详细操作可参考 数据接入物联网平台...
节点分组
消息队列（MQ）：数据流转到MQ的Topic。调试转发 当 数据出口 为 阿里云物联网平台 时，出现此参数。用于控制调试开关。开：数据流转至基础Topic和物模型Topic。关：数据仅流转至物模型Topic。数据目的地 当 数据出口 为 阿里云物联网平台 ...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
重试和死信
死信队列 死信消息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前仅支持将死信发送至 云消息队列 RocketMQ 版 和 消息服务MNS。
重试和死信
死信队列 死信息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前仅支持将死信发送至 云消息队列 RocketMQ 版 和 消息服务MNS。
重试和死信
死信队列 死信息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前仅支持将死信发送至 云消息队列 RocketMQ 版 和 消息服务MNS。
重试和死信
死信队列 死信息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前仅支持将死信发送至 云消息队列 RocketMQ 版 和 消息服务MNS。
消息收发常见问题
问题现象：使用数据流入规格将 云消息队列 RocketMQ 版 的数据流入至 云消息队列 MQTT 版 时，通过mqttSecondTopic属性设置了 云消息队列 MQTT 版 的子级Topic，消息发送后，子级Topic后会多一个“/”。可能原因：服务端会对Topic名称进行...
云消息队列 Kafka 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您...
授权信息
本文为您介绍 消息队列 MQ（Ons）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。消息队列 MQ（Ons）的RAM代码（RamCode）为 mq，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式，其通用...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
跨云产品的数据流出
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...
集成概述
主要能力是将各类数据流入至 云消息队列 Kafka 版，并且可靠地管理来自不同源头的数据源，同时对来源数据进行筛选和过滤。概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态...
授权信息
本文为您介绍 消息队列 MQ（RocketMQ）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。消息队列 MQ（RocketMQ）的RAM代码（RamCode）为 rocketmq，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持...
云消息队列 MQTT 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
数据流入规则管理
如需将其他阿里云产品的数据导入 云消息队列 MQTT 版，您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...
创建RabbitMQ Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和...
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
创建MQTT Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买...
消息检索
开通消息检索相当于自动化创建了一个 云消息队列 Kafka 版 同步数据至表格存储的Connector任务，名称格式为：ots-ms-{Topic名称}-{6位随机字符}，该Connector任务在 消息检索 页面显示和管理，而不在 Connector 任务列表 页面显示和管理。...
数据传输服务DTS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。在...
消息服务MNS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 消息服务MNS 队列。具体步骤，请参见 开通消息服务MNS并授权。您已购买 云消息队列 ...
快速入门概述
消息服务MNS 支持使用队列模型和主题模型收发消息，实现...主题模型快速入门流程 主题模型投递消息至队列的流程如下：创建队列 创建主题 创建订阅 发布消息 接收消息 删除队列 删除主题 更多信息 使用多语言SDK实现消息收发，请参见 SDK参考。
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
云消息队列RabbitMQ版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将指定 云消息队列 RabbitMQ 版 实例中的数据导出至其他的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
消息服务MNS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 消息服务MNS。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 ...
函数计算
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至函数计算。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数...
MQTT客户端上下线事件数据流出
您可通过配置 云消息队列 MQTT 版 的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云...
直播互动解决方案
背景信息 在直播互动的场景下，您需创建相应的数据互通规则实现 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 的数据互通，包含 数据流入规则、数据流出规则 以及 客户端上下线通知规则。使用 云消息队列 MQTT 版 的客户端收发消息时，...
微消息队列MQTT版推送事件到函数计算
您可以通过 云消息队列 MQTT 版 的数据流出功能，将数据流转到 云消息队列 RocketMQ 版 的Topic中，并通过添加 事件总线EventBridge 的自定义事件源 云消息队列 RocketMQ 版，实现 云消息队列 MQTT 版 与 事件总线EventBridge 的集成。...
云消息队列 RabbitMQ 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
消息队列
配置消息队列 Rocket MQ触发器 说明 注意：配置消息队列Rocket MQ触发器，需要您先参考安装云服务集成章节完成云服务集成的安装，并参考集成消息队列Rocket MQ章节集成消息队列Rocket MQ。在消息队列 RocketMQ集成页面，单击 添加配置。在...
上下线通知规则管理
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
产品优势
云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用 云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
- 产品推荐
- 这些文档可能帮助您