MQ配置

MQ配置提供了一套通过阿里云RocketMQ产品订阅云价签产品消息的机制。前提条件 使用MQ订阅云价签产品消息,您需要先开通 RocketMQ产品 并创建实例。开通权限 云价签需要获取用户发送MQ消息的权限,需在 RAM控制台 创建一个新角色,角色名为...

MQ监控

MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控,专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏,单击 应用管理>应用列表,在顶部菜单栏选择地域并在页面上方选择微...

配置MQ

多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版,在异地双活容灾场景下,完成消息层配置后,保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...

配置MQ

多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版,在异地应用双活容灾场景下,完成消息层配置后,保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...

MQ监控

ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台,在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域,然后单击目标应用名称。说明 语言 列显示 图标的...

MQ推送

MQ推送用于监控物联网卡的状态变化以及流量使用情况,并可以直接将消息推送到用户自己的系统中,帮助用户实时接收物联网卡的状态变化、套餐用量等信息。使用说明 MQ推送与自动化规则都是用于监控物联网卡的状态变化以及流量使用情况,主要...

MQ订阅消息

通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类,取值范围:"DEVICE":设备事件"BIZ":业务事件 Event String 事件说明:"DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY":设备属性变更"BIZ_...

MQ消息回执通知

mq_model: queuemq_topic: dla_hangzhou_topicmq_queue: NULLmq_producer_id: GID_dla_hangzhoumq_endpoint: http://MQ_INST_*_BagJ6yLU.cn-hangzhou.mqinternal.aliyuncs.com:8080 mq_status: SUCCESSmq_error_msg: NULLmq_message_id: AC13140925E468C4039C6FFCFD50001B...

消费托管MQ接口

消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息 获取托管MQ中的消息,方法名称:consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求...

sample-txc-mq 样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前,请先完成以下工作:开通 GTS(创建事务分组)。开通 MQ。具体操作,请参见 快速入门概述。准备两个 RDS 实例,用户创建数据库。准备...

消息队列MQ的审计事件

消息队列MQ(AMQP)已与操作审计服务集成,您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。操作审计记录了...

数据出口至消息队列MQ

物联网络管理平台支持数据出口至阿里云中间件消息队列MQ,本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组,单击一条节点分组对应 操作 栏下的...

MQ 事务消息纳入全局事务管理样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务,请先完成以下工作:准备一个可用的 MySQL 环境(可以是阿里云的 RDS)。准备一个可用的 Maven 环境。样例说明 样例...

MQTT触发器

[{"props":{"firstTopic":"testTopic","secondTopic":"/testMq4*","clientId":"consumerGroupID@xxx"},"body":"hello mq4Iot pub sub msg"}]event 字段包含的参数解释如下表所示。参数 类型 示例值 描述 props Map 消息属性。firstTopic ...

添加RocketMQ数据源

本文介绍如何添加RocketMQ数据源。数据源添加 首先进入LTS操作页面,数据源管理->...参数说明 获取NameSrvAddr NameSrvAddr表示MQ的接入点,对于自建客户,请自行查询MQ的配置。对于云上的客户可以在MQ控制台获取。获取 AccessId、AccessKey

RocketMQ触发器

{"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"RocketMQ-Function-rocketmq-trigger","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:...

RocketMQ触发器

[{"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"RocketMQ-Function-rocketmq-trigger","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:...

MQTT触发器

[{"props":{"firstTopic":"testTopic","secondTopic":"/testMq4*","clientId":"consumerGroupID@xxx"},"body":"hello mq4Iot pub sub msg"}]event 字段包含的参数解释如下表所示。参数 类型 示例值 描述 props Map 消息属性。firstTopic ...

云消息队列 MQTT 版

事件示例 {"specversion":"1.0","id":"AC1EC0C950650816F27D46F7D7CA*","source":"acs:mqtt","type":"mqtt:Topic:SendMessage","subject":"acs:mq:cn-hangzhou:143998900779*:topic/mqtt-cn-2r42qam*/housekee*","datacontenttype":...

云消息队列 MQTT 版

MQ_INST_115964845466*_BYEiGXc4 Topic 选择目标实例的Topic。test 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。自定义配置:使用事件模式匹配特定事件。详细规则,请参见 消息转换。消息...

自定义事件源消息队列RocketMQ版

事件示例 {"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"acs:mq","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:cn-hangzhou:123456789098*:MQ_INST_...

Spark对接RocketMQ

本文介绍如何通过Spark Streaming消费消息队列RocketMQ(简称MQ)中的数据并计算每个Batch中的单词。通过Spark访问MQ 代码示例如下。val Array(cId,topic,subExpression,parallelism,interval)=args val accessKeyId=System.getenv(...

微消息队列MQTT版推送事件到函数计算

public class MQ4IoTProducerDemo { public static void main(String[]args)throws Exception {/*MQ4IOT实例ID,购买后控制台获取。String instanceId="XXXXX;接入点地址,购买MQ4IOT实例,且配置完成后即可获取,接入点地址必须填写分配的...

路由到消息队列RocketMQ版

接收到的示例消息内容如下所示:{"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"acs:mq","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:...

使用Canal和RocketMQ实现数据库变更订阅处理

mq.topic=canal_topic \ -e rocketmq.producer.group=test \ -e rocketmq.tag=tag \ -e rocketmq.enable.message.trace=false \ -e rocketmq.customized.trace.topic=表 1.源端MySQL参数说明 参数 说明 取值示例 canal.auto.scan 是否开启Canal本身的...

消息队列RocketMQ版

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息的Topic。topic Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。GID_http_1 消费位点 选择开始消费消息的...

微消息队列MQTT版

MQ_INST_115964845466*_BYEiGXc4 Topic 选择目标实例的Topic。test 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。自定义配置:使用事件模式匹配特定事件。详细规则,请参见 消息过滤。消息...

创建RocketMQ Source Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 消息队列RocketMQ版 消息的Topic。topic Tag 配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,...

使用Canal和RocketMQ实现数据库变更订阅处理

mq.topic=canal_topic \ -e rocketmq.producer.group=test \ -e rocketmq.tag=tag \ -e rocketmq.enable.message.trace=false \ -e rocketmq.customized.trace.topic=表 1.源端MySQL参数说明 参数 说明 取值示例 canal.auto.scan 是否开启Canal本身的...

消息队列RabbitMQ版

MQ_INST_115964845466*_ByBeUp3p Vhost 选择源实例中的Vhost。vhost Queue 选择源实例中的队列。queue 表 2.目标端消息队列RocketMQ版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1(杭州)...

创建RabbitMQ Sink Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 云消息队列 Kafka 版 消息的Topic。topic Group ID 选择源实例的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。GID_http_1 并发配额...

创建RocketMQ Sink Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 云消息队列 Kafka 版 消息的Topic。topic Group ID 选择源实例的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。GID_http_1 并发配额...

消息队列RocketMQ版

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息的源Topic。topic Tag 云消息队列 RocketMQ 版 中用于过滤消息的标签。test_tag Group ID 快速创建:自动创建以GID_EVENTBRIDGE_xxx 命名的Group ID。使用已有:选择源实例中的消费组...

消息队列RabbitMQ版

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息的Topic。topic Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。GID_http_1 消费位点 选择开始消费消息的...

通过RocketMQ客户端消费设备消息

本示例中,产品名称为 MQ_test,所属品类为 自定义品类,节点类型为 直连设备,其他参数使用默认值。单击 查看产品详情,在产品详情页面,单击 Topic类列表>自定义Topic,然后单击 自定义Topic类,定义一个具有 发布 权限的Topic类,用于...

MQTT和RocketMQ进行数据互通(跨产品数据流出)

MQ4IoTSendMessageToRocketMQ.java 类中,按代码注释说明填写相应参数,主要涉及 步骤一 至 步骤三 所创建的MQTT资源以及您在 云消息队列 RocketMQ 版 创建的相应资源,然后执行Main函数运行代码实现消息收发。示例代码如下。说明 在...

通过RocketMQ客户端消费设备消息

本示例中,产品名称为 MQ_test,所属品类为 自定义品类,节点类型为 直连设备,其他参数使用默认值。单击 查看产品详情,在产品详情页面,单击 Topic类列表>自定义Topic,然后单击 自定义Topic类,定义一个具有 发布 权限的Topic类,用于...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

public class MQ4IoTSendMessageToMQ4IoTUseSignatureMode { public static void main(String[]args)throws Exception {/*您在控制台创建的云消息队列 MQTT 版的实例ID。String instanceId="XXXXX;设置接入点,进入云消息队列 MQTT 版控制...

GetMqConsumerTag-获取工单RocketMQ消息监听的TAG

mq 消费的 tag 46434030 RequestId string 请求唯一识别码 CA6204AC-6AA9-4CFA-9310-7DFD20C19EBC Success boolean 调用是否成功。true:表示成功;false:表示失败。true 示例 正常返回示例 JSON 格式 {"Code":200,"Message":"success",...

MQTT和RocketMQ进行数据互通(跨产品数据流入)

RocketMQ 实例 MQ_INST_13801563067*_BbyOD2jQ 指定源云产品的实例ID,即 云消息队列 RocketMQ 版 的实例ID。说明 仅支持选择和 云消息队列 MQTT 版 实例为同一地域的云产品实例。Topic TopicA 指定源云产品的资源键值,即 云消息队列 ...
共有23条 < 1 2 3 4 ... 23 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 全局事务服务 (文档停止维护) 云消息队列 Kafka 版 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用