本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...
Apache RocketMQ作为事件源通过 事件总线EventBridge 与 函数计算 集成后,通过Apache RocketMQ触发器能够触发关联函数执行,通过函数可以对发布到Apache RocketMQ的消息进行自定义处理。本文介绍如何在 函数计算 控制台创建Apache ...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:...
Apache RocketMQ作为事件源通过 事件总线EventBridge 与 函数计算 集成后,通过Apache RocketMQ触发器能够触发关联函数执行,通过函数可以对发布到Apache RocketMQ的消息进行自定义处理。本文介绍如何在 函数计算 控制台创建Apache ...
使用铂金版RocketMQ实例,视为“合规”。应用场景 铂金版RocketMQ提供更高的性能、稳定性、功能特性和服务支持,可以为企业提供更好的消息服务支持。风险等级 默认风险等级:低风险。当您使用该规则时,可以按照实际需求变更风险等级。检测...
Provides a Rocket MQ Instance resource.For information about RocketMQ Instance and how to use it,see What is Instance.-NOTE:Available since v1.212.0.Example Usage Basic Usage variable"name"{ default="terraform-example"} ...
本文介绍如何在 云消息队列 MQTT 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 MQTT 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。开通事件总线EventBridge并授权。...
DATASOURCE:ROCKETMQ:Instances类型用于查询所有RocketMQ实例的信息。语法 {"Type":"DATASOURCE:ROCKETMQ:Instances","Properties":{"RefreshOptions":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 RefreshOptions String 否 是...
如果当前产品下设备与物联网平台之间的上下行消息量大于1,000 QPS,需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费(例如过滤、分析、存储等),可以使用云产品流转功能将物联网平台数据转发到消息队列(RocketMQ)...
在RocketMQ压测过程中,您可以查看实时性能数据。完成压测后,系统将自动获取压测过程中的数据,形成压测报告。本文介绍RocketMQ压测报告中各部分详情。压测报告入口 登录 PTS控制台。在左侧导航栏选择 性能测试 报告列表。单击目标报告 ...
如果当前产品下设备与物联网平台之间的上下行消息量大于1,000 QPS,需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费(例如过滤、分析、存储等),可以使用云产品流转功能将物联网平台数据转发到消息队列(RocketMQ)...
ALIYUN:ROCKETMQ:Instance类型用于创建标准版实例。语法 {"Type":"ALIYUN:ROCKETMQ:Instance","Properties":{"Remark":String,"InstanceName":String,"Tags":List,"DeletionForce":Boolean } } 属性 属性名称 类型 必须 允许更新 描述 约束...
使用RocketMQ时,消息堆积产生时容易导致系统负载过高。为避免服务崩溃,提高系统的可靠性和稳定性,您可以基于RocketMQ消息堆积指标,使用KEDA(Kubernetes Event-driven Autoscaling)为应用的弹性伸缩方案,实现自动化和高效的容器水平...
Provides a RocketMQ Consumer Group resource.For information about RocketMQ Consumer Group and how to use it,see What is Consumer Group.-NOTE:Available since v1.212.0.Example Usage Basic Usage variable"name"{ default=......
ALIYUN:ROCKETMQ:Topic类型用于创建Topic。语法 {"Type":"ALIYUN:ROCKETMQ:Topic","Properties":{"InstanceId":String,"Topic":String,"Remark":String,"MessageType":Integer } } 属性 属性名称 类型 必须 允许更新 描述 约束 InstanceId ...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的服务类型。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建...
ALIYUN:ROCKETMQ:Group类型用于创建客户端Group ID。创建的Group ID用于发布和订阅消息。语法 {"Type":"ALIYUN:ROCKETMQ:Group","Properties":{"InstanceId":String,"GroupType":String,"Remark":String,"GroupId":String } } 属性 属性...
DATASOURCE:ROCKETMQ:Instance类型用于查询单个RocketMQ实例的详情信息。语法 {"Type":"DATASOURCE:ROCKETMQ:Instance","Properties":{"InstanceId":String,"RefreshOptions":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 ...
DATASOURCE:ROCKETMQ:Topic类型用于查询单个Topic的详情信息。语法 {"Type":"DATASOURCE:ROCKETMQ:Topic","Properties":{"InstanceId":String,"TopicName":String,"RefreshOptions":String } } 属性 属性名称 类型 必须 允许更新 描述 约束...
RocketMQ SDK注册的消费者获取消息时会触发服务端的动态过滤计算,RocketMQ根据该消费者上报的过滤条件的表达式进行匹配,并将符合条件的消息投递给该消费者,实现消费者所属业务服务器接收设备上报至物联网平台的消息。前提条件 已注册...
本文使用Beats、Elasticsearch、Logstash和Kibana,在分布式环境下采集、汇聚、解析阿里云RocketMQ客户端SDK日志,帮助您在消息队列开发场景中快速定位并解决应用开发问题。背景信息 阿里云Elasticsearch(简称ES)已具备Elastic Stack全栈...
DATASOURCE:ROCKETMQ:Topics类型用于查询Topic的信息列表。语法 {"Type":"DATASOURCE:ROCKETMQ:Topics","Properties":{"InstanceId":String,"TopicName":String,"RefreshOptions":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 ...
RocketMQ SDK注册的消费者获取消息时会触发服务端的动态过滤计算,RocketMQ根据该消费者上报的过滤条件的表达式进行匹配,并将符合条件的消息投递给该消费者,实现消费者所属业务服务器接收设备上报至物联网平台的消息。前提条件 已注册...
DATASOURCE:ROCKETMQ:Groups类型用于展示Group资源的列表。语法 {"Type":"DATASOURCE:ROCKETMQ:Groups","Properties":{"GroupName":String,"GroupType":String,"InstanceId":String,"RefreshOptions":String } } 属性 属性名称 类型 必须 ...
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...
本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RocketMQ 版 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...
消息队列RocketMQ 5.0已与操作审计服务集成,您可以在操作审计中查询用户操作消息队列RocketMQ 5.0产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。操作...
您可以通过事件规则过滤事件,将事件路由到 消息队列RocketMQ版。本文以自定义事件为例介绍将事件路由到 消息队列RocketMQ版 的前提条件、操作步骤和结果验证。前提条件 事件总线EventBridge 开通事件总线EventBridge并授权 消息队列...
RocketMQ 实例)OB_MySQL(Serverless 实例)RocketMQ(VPC 内自建 RocketMQ 实例)OB_MySQL(Serverless 实例)RocketMQ(公网 RocketMQ 实例)OB_Oracle(OceanBase 集群实例)RocketMQ(阿里云 RocketMQ 实例)OB_Oracle(OceanBase ...
事件总线EventBridge 支持接入 云消息队列 RocketMQ 版 的消息,进行事件分析、查看事件轨迹、进行数据转发等操作。本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 类型的自定义事件源。前提条件 云消息队列 ...
消息队列RocketMQ版已与操作审计服务集成,您可以在操作审计中查询用户操作消息队列RocketMQ版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。操作审计...
本文介绍如何在 Serverless应用引擎SAE(Serverless App Engine)上基于阿里云 消息队列RocketMQ版 实现环境隔离,您可以在不修改任何业务代码的情况下,实现异步场景下的流量控制。背景信息 支持RocketMQ版本:4.2.0及以上版本。支持Pull...
本文介绍如何在 Serverless 应用引擎 SAE(Serverless App Engine)上基于阿里云 云消息队列 RocketMQ 版 实现环境隔离,您可以在不修改任何业务代码的情况下,实现异步场景下的流量控制。背景信息 支持RocketMQ版本:4.2.0及以上版本。...
通过消息队列这类异步场景下的流量控制,您可以在...rocketmq-name-server spec: containers: - command: - sh - mqnamesrv env: - name:ROCKETMQ_HOME value: /home/rocketmq/rocketmq-4.9.7 image: registry.cn-hangzhou.aliyuncs.com/mse-governance-demo/...
获取工单RocketMQ消息监听的TAG。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 ...
本文为您介绍本地IDC如何通过物理专线访问云上消息队列RocketMQ版,实现本地IDC使用消息队列RocketMQ版收发并处理消息。背景信息 本文以下图场景为例,某企业在阿里云华北2(北京)地域部署了专有网络VPC(Virtual Private Cloud)和交换机...
本文介绍如何通过 事件总线EventBridge 将消息队列RocketMQ版的数据推送到函数计算。前提条件 您已完成以下操作:事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 函数计算 创建函数 创建日志项目和日志仓库 SLS触发器 ...
通过创建和执行系统运维管理(OOS)自定义模板,您可以将RocketMQ实例的标签继承到实例中的Topic和Group上。使用限制 默认情况下,某地域的OOS负责管理本地域的资源。例如,华东1(杭州)的OOS默认管理华东1(杭州)的ECS实例。但是,作为...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...