云消息队列 RocketMQ 版
RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。内容分割：根据正则表达式对消息内容进行分割，将分割后的消息逐条发送至目标。...
云消息队列 RocketMQ 版
RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。内容分割：根据正则表达式对消息内容进行分割，将分割后的消息逐条发送至目标。...
云消息队列 RocketMQ 版服务等级协议
如需查看 云消息队列 RocketMQ 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 RocketMQ 版服务等级协议。
云消息队列 RocketMQ 版自定义权限策略
["rocketmq:GetAnalyticsQuery","rocketmq:SubmitAnalyticsQuery","rocketmq:ListAnalyticsQuery"],"Resource":["acs:rocketmq:*:{#accountId}:*/*"]}]} 授权信息参考 使用自定义权限策略，您需要了解业务的权限管控需求，并了解 云消息...
RocketMQ全链路追踪解决方案
链路追踪功能可在多个服务进行交互时记录请求在系统的传输过程，并提供详细的日志和性能数据，云消息队列 RocketMQ 版 支持将符合OpenTelemetry标准的Trace数据集成至阿里云的链路追踪服务中，帮助您快速诊断异常问题。Trace定义 云消息...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
云消息队列 RocketMQ 版自定义权限策略
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
使用Canal和RocketMQ实现数据库变更订阅处理
8 \-e canal.instance.tsdb.enable=true \-e canal.instance.gtidon=false \-e canal.serverMode=rocketMQ \-e canal.aliyun.accessKey=xxx \-e canal.aliyun.secretKey=xxx \-e canal.mq.accessChannel=cloud \-e rocketmq.namesrv.addr='...
使用Canal和RocketMQ实现数据库变更订阅处理
8 \-e canal.instance.tsdb.enable=true \-e canal.instance.gtidon=false \-e canal.serverMode=rocketMQ \-e canal.aliyun.accessKey=xxx \-e canal.aliyun.secretKey=xxx \-e canal.mq.accessChannel=cloud \-e rocketmq.namesrv.addr='...
云消息队列 RocketMQ 版5.x系统权限策略参考
本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
云消息队列 RocketMQ 版4.x系统权限策略参考
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
RocketMQ
名称 类型 描述 示例值 object RocketMQ 消息通知参数。TopicName string RocketMQ Topic 名称。如果需使用 RocketMQ 做消息通知，该参数必填。topic1 InstanceId string RocketMQ 实例 Id。如果需使用 RocketMQ 做消息通知，该参数必填。...
RocketMQ触发器
消息队列 RocketMQ 版 作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过 消息队列 RocketMQ 版 触发器（以下简称RocketMQ触发器）能够触发关联函数执行，通过函数可以对发布到 消息队列 RocketMQ 版 中的消息进行自定义处理。...
RocketMQ触发器
消息队列RocketMQ版 作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过 消息队列RocketMQ版 触发器（以下简称RocketMQ触发器）能够触发关联函数执行，通过函数可以对发布到 消息队列RocketMQ版 中的消息进行自定义处理。...
RocketMQ(Ons)
RocketMQ(Ons)
新建 RocketMQ 数据源
VPC 内自建 RocketMQ 实例对于网络的处理：安装 RocketMQ 实例的 ECS 的安全组需要添加对应 VPC 的网段，放开 RocketMQ 实例的 namesvr 和 broker 的所有端口。操作步骤 登录 OceanBase 管理控制台。在左侧导航栏，单击 数据传输>数据源...
Spark对接RocketMQ
本文介绍如何通过Spark Streaming消费消息队列RocketMQ（简称MQ）中的数据并计算每个Batch中的单词。通过Spark访问MQ 代码示例如下。val Array(cId,topic,subExpression,parallelism,interval)=args val accessKeyId=System.getenv(...
云消息队列 RocketMQ 版
本文为您介绍 云消息队列 RocketMQ 版 连接器。重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件...
创建RocketMQ数据源
背景信息 RocketMQ即阿里云消息队列RocketMQ版，如果您使用的是阿里云消息队列RocketMQ版，在对接Dataphin进行数据开发时，您需要先完成RocketMQ数据源的创建。更多信息，请参见 什么是消息队列RocketMQ版。权限说明 仅支持 超级管理员、...
alicloud_rocketmq_topic
rocketmq_topic" "default" { remark = "example" instance_id = alicloud_rocketmq_instance.createInstance.id message_type = "NORMAL" topic_name = var.name } Argument Reference The following arguments are supported: instance_id -(Required,ForceNew)...
添加RocketMQ数据源
本文介绍如何添加RocketMQ数据源。数据源添加 首先进入LTS操作页面，数据源管理->RocketMQ数据源 录入MQ的相关信息，点击创建，创建对应的MQ数据源。参数说明 获取NameSrvAddr NameSrvAddr表示MQ的接入点，对于自建客户，请自行查询MQ的...
创建RocketMQ Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已...
自建Apache RocketMQ触发器
Apache RocketMQ作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过Apache RocketMQ触发器能够触发关联函数执行，通过函数可以对发布到Apache RocketMQ的消息进行自定义处理。本文介绍如何在 函数计算 控制台创建Apache ...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
云消息队列 RocketMQ 版
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
创建RocketMQ Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
alicloud_rocketmq_instance
Provides a RocketMQ Instance resource.RocketMQ instance resources.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"{ ...
自建Apache RocketMQ触发器
Apache RocketMQ作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过Apache RocketMQ触发器能够触发关联函数执行，通过函数可以对发布到Apache RocketMQ的消息进行自定义处理。本文介绍如何在 函数计算 控制台创建Apache ...
使用铂金版RocketMQ实例
使用铂金版RocketMQ实例，视为“合规”。应用场景 铂金版RocketMQ提供更高的性能、稳定性、功能特性和服务支持，可以为企业提供更好的消息服务支持。风险等级 默认风险等级：低风险。当您使用该规则时，可以按照实际需求变更风险等级。检测...
DATASOURCE:ROCKETMQ:Instances
DATASOURCE:ROCKETMQ:Instances类型用于查询所有RocketMQ实例的信息。属性 无。返回数据 Fn:GetAtt Instances：RocketMQ实例详情列表。InstanceIds：RocketMQ实例ID列表。属性名称 类型 描述 约束 InstanceIds List RocketMQ实例ID列表。无...
查看RocketMQ压测报告
在RocketMQ压测过程中，您可以查看实时性能数据。完成压测后，系统将自动获取压测过程中的数据，形成压测报告。本文介绍RocketMQ压测报告中各部分详情。压测报告入口 登录 PTS控制台。在左侧导航栏选择 性能测试>报告列表。单击目标报告 ...
- 产品推荐
- 这些文档可能帮助您