ListDIProjectConfig
当前DataWorks仅支持为同步解决方案任务中的实时同步DDL消息处理策略设置默认的全局配置。如果您的同步解决方案任务包含实时同步任务，则配置 DDL消息处理规则时会读取此处的全局配置为默认配置。您也可以根据实际业务需求修改目标同步任务...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
配置并管理实时同步任务
DDL消息处理规则设置。来源数据源会包含许多DDL操作，数据集成体提供默认处理策略，您也可以根据业务需求，对不同的DDL消息设置同步至目标端的处理策略。不同DDL消息处理策略请参见：DDL消息处理规则。运行资源设置。在 运行资源设置 页面...
DataStudio侧实时同步任务配置
说明 您可以在 数据集成>配置选项>实时同步DDL消息处理策略 页面，针对每个写入的目标数据库类型，设置DDL处理策略。不同DDL消息处理策略如下表所示。DDL消息类型 处理策略 新建表 DataWorks收到对应类型的DDL消息时，处理策略如下：正常...
通过可观测性能力进行故障处理最佳实践
消息处理成功率=消息处理成功次数/消息处理失败次数+成功次数。查询方式，请查看 仪表盘 中，消费者指标下的统计面板。根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
延时消息
若延时时间超过延时消息最大延时时间，则当作普通消息处理，即消息发送后被立即投递给消费者消费。最大延时时间根据实例类型不同有所差异，具体数值，请参见 集群限制。若您为延时消息设置了消息存活时间，则 延时消息的实际存活时间＝min{...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
消息服务MNS
是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射关系...
消息服务MNS
是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射关系...
消息服务MNS
是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射关系...
设置消息通知
本文介绍在媒体处理中为任务设置消息通知的操作步骤。您可以根据以下流程为您的任务设置消息通知。开通消息服务MNS。根据实际业务需要，创建主题或队列。说明 队列模型提供高可靠、高并发的一对一消费模型；主题模型提供一对多的发布订阅...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
消息服务MNS
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
消息服务MNS
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
消息服务MNS
queue_test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
全局配置
在左侧导航栏，单击 系统设置>国际消息设置。在 全局配置 页面，设置发送量阈值。请填写每日和每月的短信预警阈值、暂停阈值。单击 确定，完成设置。说明 控制短信发送量还可以通过 国家/地域维度 来配置上限阈值，请参见 路由管理。
消息队列RabbitMQ版
vhost 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
消息队列RocketMQ版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
微消息队列MQTT版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
云消息队列 RocketMQ 版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
云消息队列 MQTT 版
queue_test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
收发事务消息
go ConsumeHalfMsg(&mqTransProducer)/发送4条事务消息，1条发送完就提交，其余3条通过检查半事务消息处理。for i:=0;i;i+{ msg:=mq_http_sdk.PublishMessageRequest{ MessageBody:"I am transaction msg!Properties:map[string]string{...
消息队列Kafka版
LeaderOnly 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
云消息队列 RocketMQ 版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
消息队列Kafka版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
消息队列RocketMQ版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
云消息队列 RocketMQ 版
queue_test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
云消息队列 Kafka 版
queue_test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
云消息队列RabbitMQ版
queue_test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
配置渠道设置
使用说明 消息发送渠道可在全局（实例级）进行设置，也可以在每个租户级别进行设置，您可以根据您所在的组织的要求进行不同的配置。消息渠道关闭后，相关消息将无法发送到对应的渠道，请按需选择开启的消息渠道。权限说明 元仓租户超级管理...
云消息队列 RocketMQ 版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
云消息队列 RabbitMQ 版
vhost 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息转换。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
云消息队列 Kafka 版
LeaderOnly 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。...
- 产品推荐
- 这些文档可能帮助您