内容映射
数据处理 消息过滤：选择 无需过滤。消息转换：选择 自定义配置。消息体（body）选择 数据清洗，并选中 新建函数模版。函数模版 选择 内容映射 transform_projection，然后根据业务情况修改函数代码。创建完成后，您可以登录 函数计算控制...
自建Apache RocketMQ触发器
SQL：通过SQL语句进行消息过滤，可匹配消息的属性标识以及属性值。Tag Filter 选择 FilterType 后，需要配置对应的过滤类型下的过滤语句。TagA 认证模式 选择认证模式，支持 ACL 模式。ACL 用户名 当 认证模式 选择 ACL 后，需要配置Apache...
GetSubscriptionAttributes
FilterTag 描述了该订阅中消息过滤的标签（仅标签一致的消息才会被推送）。CreateTime Subscription的创建时间，从1970-1-1 00:00:00到现在的秒值。LastModifyTime 修改Subscription属性信息最近时间，从1970-1-1 00:00:00到现在的秒值。...
集成概述
消息过滤 支持多种消息过滤模式，过滤无用消息，提升处理效率。详细信息，请参见 事件模式。不支持。死信队列 支持 消息服务MNS 和 云消息队列 RocketMQ 版 等服务做死信队列。支持 云消息队列 Kafka 版 做死信队列。重试策略 统一支持。...
产品功能发布记录
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。2020.02.27 相关文档 Hyperledger Fabric【云服务集成】数据库 如果您希望区块链上的数据能导出到关系型数据库，您可以将...
模块开通
单地域 双地域 企业版RocketMQ 阿里云企业版MQ服务容灾模块，保证MQ消息收发的容灾调度与消息数据RPO。单地域 双地域 DRDS服务 DRDS容灾模块，保障数据的RPO。双地域 OceanBase服务 OceanBase服务容灾模块，保障数据的RPO。双地域 PolarDB ...
内容富化
数据处理 消息过滤：选择 无需过滤。消息转换：选择 自定义配置。消息体（body）选择 数据清洗，并选中 新建函数模版。函数模版 选择 内容富化 transform_enrichment，然后根据业务情况修改函数代码。创建完成后，您可以登录 函数计算控制...
Topic 与 Tag
您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下：Topic：消息主题，通过 Topic 对不同的业务消息进行分类。Tag：消息标签，用来进一步区分某个 Topic 下的消息分类，消息从生产者发出即带上...
动态路由
数据处理 消息过滤：选择 无需过滤。消息转换：选择 自定义配置。消息体（body）选择 数据清洗，并选中 新建函数模版。函数模版 选择 动态路由 dynamic_routing，然后根据业务情况修改函数代码。创建完成后，您可以登录 函数计算控制台 ...
功能与特性概述
消息过滤：云消息队列 RocketMQ 版 支持设置消息属性给消息进行分类，云消息队列 RocketMQ 版 服务端会根据您订阅消息时设置的过滤条件对消息进行过滤，您将只消费到需要关注的消息。消息功能 消息查询：云消息队列 RocketMQ 版 提供了三种...
使用函数计算实现消息数据清洗
算子 算子能力说明 消息过滤 按照正则表达式匹配消息内容，将匹配成功的消息发送至目标。更多信息，请参见 事件模式。消息转换 根据字符串匹配，进行消息内容替换，例如字符大小写转换。将转换后的消息发送至目标。更多信息，请参见 事件...
使用函数计算实现消息数据清洗
算子 算子能力说明 消息过滤 按照正则表达式匹配消息内容，将匹配成功的消息发送至目标。更多信息，请参见 事件模式。消息转换 根据字符串匹配，进行消息内容替换，例如字符大小写转换。将转换后的消息发送至目标。更多信息，请参见 事件...
设置消息通知
（可选）消息过滤标签 通过设置的标签对消息进行过滤。说明 用于消息过滤，不超过16个字符。重试策略 向接收端推送消息出现错误时的重试策略。退避重试：重试3次，间隔时间为10~20秒之间的一个随机值。指数衰减重试：重试176次，总计重试...
GetSubscriptionAttributes
FilterTag String important 描述了该订阅中消息过滤的标签（仅标签一致的消息才会被推送）。CreateTime Long 1449554806 Subscription的创建时间，从1970-01-01 00:00:00到现在的。LastModifyTime Long 1449554962 最近一次修改...
创建MQTT Source Connector
更多信息，请参见 消息过滤。在 Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见 数据清洗。在 Sink（目标）配置向导，选择 服务类型 为 消息队列 Kafka 版，配置以下参数...
创建RabbitMQ Source Connector
更多信息，请参见 消息过滤。在 Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见 数据清洗。在 Sink（目标）配置向导，选择 服务类型 为 消息队列 Kafka 版，配置以下参数...
创建MNS Source Connector
更多信息，请参见 消息过滤。在 Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见 数据清洗。在 Sink（目标）配置向导，选择 服务类型 为 消息队列 Kafka 版，配置以下参数...
订阅者最佳实践
消息过滤 云消息队列 Kafka 版 自身没有消息过滤的语义。实践中可以采取以下两个办法：如果过滤的种类不多，可以采取多个Topic的方式达到过滤的目的。如果过滤的种类多，则最好在客户端业务层面自行过滤。实践中请根据业务具体情况进行选择...
创建DTS Source Connector
更多信息，请参见 消息过滤。在 Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见 数据清洗。在 Sink（目标）配置向导，选择 服务类型 为 消息队列 Kafka 版，配置以下参数...
HttpEndpoint
参数名称 说明 TopicOwner 被订阅主题的拥有者 TopicName 被订阅主题的名称 Subscriber 订阅者 SubscriptionName 订阅名称 MessageId 消息编号 Message 消息正文 MessageMD5 消息的MD5值 MessageTag 消息标签（用于消息过滤）PublishTime ...
HTTP Endpoint
参数名称 说明 TopicOwner 被订阅主题的拥有者 TopicName 被订阅主题的名称 Subscriber 订阅者 SubscriptionName 订阅名称 MessageId 消息编号 Message 消息正文 MessageMD5 消息的MD5值 MessageTag 消息标签（用于消息过滤）PublishTime ...
数据流转方案对比
支持快速地获取设备消息，无消息过滤和转换能力，功能较为单一，但是简单易用且高效。服务端订阅概述 配置AMQP服务端订阅 AMQP客户端接入说明 使用MNS服务端订阅 流转方案对比说明 流转方式对比 流转方式 应用场景 优点 缺点 使用限制 云...
数据转发到消息队列RocketMQ
您可以在RocketMQ消息消费端，通过标签进行消息过滤。标签长度限制为128字节，可以输入常量或变量。变量格式为${key}，代表SQL处理后的JSON数据中key对应的value值。授权 授权物联网平台将数据写入RocketMQ。如您还未创建相关角色，单击 ...
云消息队列 RocketMQ 版
说明 如果您的MQ消息为二进制格式，则DDL中只能定义一个字段，且字段类型必须为VARBINARY。创建将 keys 和 tags 字段指定为RocketMQ消息的key和tag的结果表 RocketMQ 5.x CREATE TABLE mq_sink(id INTEGER,len BIGINT,content VARCHAR,keys...
MNS主题触发器
Mytopic 过滤标签 填写消息过滤标签。只有收到包含了此处设置的过滤标签字符串的消息时，才会触发函数执行。tag Event 格式 选择Event格式。取值：STREAM JSON JSON 重试策略 选择重试策略。取值：退避重试 指数衰减 如何选择重试策略，请...
MNS主题触发器
Mytopic 过滤标签 填写消息过滤标签。只有收到包含了此处设置的过滤标签字符串的消息时，才会触发函数执行。tag Event格式 选择Event格式。取值：STREAM JSON JSON 重试策略 选择重试策略。取值：退避重试 指数衰减 如何选择重试策略，请...
创建OSS Sink Connector（新版）
更多信息，请参见 消息过滤。在 Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见 数据清洗。在 Sink（目标）配置向导，选择 服务类型 为 对象存储 OSS，配置以下参数。参数...
直播互动解决方案
同时，服务端也会添加禁言名单用于业务校验和消息过滤。老师的客户端需将消息发送至roomSend/command Topic，其中：roomSend为直播间所有客户端发送消息使用的父级Topic，需要在 云消息队列 MQTT 版 控制台创建。command为自定义二级Topic...
步骤三：调用SDK收发消息
setKeys("messageKey")/设置消息Tag，用于消费端根据指定Tag过滤消息。setTag("messageTag")/消息体。setBody("messageBody".getBytes()).build();try {/发送消息，需要关注发送结果，并捕获失败等异常。SendReceipt sendReceipt=producer....
消息过滤
本文介绍消息集成中的消息过滤的特殊语法。注意事项 消息过滤的原则如下：事件必须包含事件模式中列出的所有字段名，且事件模式里的字段名必须和事件中的字段名具有相同嵌套结构。事件模式是逐个字符精确匹配的，需注意大小写，匹配过程中...
消息过滤
本文介绍消息集成中的消息过滤的特殊语法。注意事项 消息过滤的原则如下：事件必须包含事件模式中列出的所有字段名，且事件模式里的字段名必须和事件中的字段名具有相同嵌套结构。事件模式是逐个字符精确匹配的，需注意大小写，匹配过程中...
消息过滤
本文介绍消息集成中的消息过滤的特殊语法。注意事项 消息过滤的原则如下：事件必须包含事件模式中列出的所有字段名，且事件模式里的字段名必须和事件中的字段名具有相同嵌套结构。事件模式是逐个字符精确匹配的，需注意大小写，匹配过程中...
消息过滤
本文介绍消息集成中的消息过滤的特殊语法。注意事项 消息过滤的原则如下：事件必须包含事件模式中列出的所有字段名，且事件模式里的字段名必须和事件中的字段名具有相同嵌套结构。事件模式是逐个字符精确匹配的，需注意大小写，匹配过程中...
Subscription
FilterTag 过滤消息的标签。类型：字符串。指定了该属性后，MNS仅推送消息标签与该属性一致的消息到对应的Endpoint。NotifyStrategy 消息推送出现错误时的重试策略。取值范围：BACKOFF_RETRY或者EXPONENTIAL_DECAY_RETRY。当推送消息失败时...
Subscription
FilterTag 过滤消息的标签。类型：字符串。指定了该属性后，消息服务MNS 仅推送消息标签与该属性一致的消息到对应的Endpoint。NotifyStrategy 消息推送出现错误时的重试策略。取值范围：BACKOFF_RETRY或者EXPONENTIAL_DECAY_RETRY。当推送...
生产者负载均衡
setKeys("messageKey")/设置消息Tag，用于消费端根据指定Tag过滤消息。setTag("messageTag")/消息体。setBody("messageBody".getBytes()).build();try {/发送消息，需要关注发送结果，并捕获失败等异常。SendReceipt sendReceipt=producer....
定时/延时消息
setKeys("messageKey")/设置消息Tag，用于消费端根据指定Tag过滤消息。setTag("messageTag").setDeliveryTimestamp(deliverTimeStamp)/消息体.setBody("messageBody".getBytes()).build();try {/发送消息，需要关注发送结果，并捕获失败等...
顺序消息
setKeys("messageKey")/设置消息Tag，用于消费端根据指定Tag过滤消息。setTag("messageTag")/设置顺序消息的排序分组，该分组尽量保持离散，避免热点排序分组。setMessageGroup("fifoGroup001")/消息体。setBody("messageBody".getBytes())...
事务消息
setKeys("messageKey")/设置消息Tag，用于消费端根据指定Tag过滤消息。setTag("messageTag")/一般事务消息都会设置一个本地事务关联的唯一ID，用来做本地事务回查的校验。addProperty("OrderId","xxx")/消息体。setBody("messageBody"....
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
- 产品推荐
- 这些文档可能帮助您