规则说明

流程说明

云消息队列 MQTT 版通过Kafka规则将发送消息和事件消息流转至云消息队列 Kafka 版，流程如下所示：

• 发送消息

  

• 事件消息

  

注意事项

• 仅支持云消息队列 MQTT 版铂金版和专业版实例。如需使用Kafka规则功能，请提交工单进行申请。

• 不支持跨地域创建规则，云消息队列 MQTT 版和云消息队列 Kafka 版的实例必须处于同一地域。

• 暂不支持云消息队列 Confluent 版Kafka实例。

• 单个云消息队列 MQTT 版实例最多创建10条规则。

• 路由到云消息队列 Kafka 版的实例不超过3个。

• 首次使用时，系统将自动创建目标服务的关联角色AliyunServiceRoleForMqttCoreRuleEngine，以实现数据流转功能。详情请参见服务关联角色。

计费说明

云消息队列 MQTT 版Kafka规则功能目前处于公测阶段，暂不收取费用，但会对TPS进行统计，并根据规格限制TPS的上限。

创建规则

1. 登录云消息队列 MQTT 版控制台，并在左侧导航栏单击实例列表。

2. 在顶部菜单栏选择目标地域，然后在实例列表中单击实例名称进入实例详情页面。

3. 在左侧导航栏单击规则管理。

4. 在规则管理页面，单击Kafka 规则页签，然后单击创建规则。

5. 在创建规则页面完成以下操作。

   1. 在规则配置向导页面，填写规则的基本信息，然后单击下一步。

      • 规则名称：输入规则名称。

      • SQL配置：配置SQL规则。

        • SQL编辑器：在SQL编辑器输入对应的SQL。详情请参见SQL语法和示例。

        • 测试验证：开启后可以模拟客户端发送消息，验证SQL规则执行的结果。

          说明

          仅支持消息的测试验证，事件的测试验证暂不支持。

          参数	取值示例	说明
          客户端ID	test	自定义客户端ID。
          主题	myTopic	云消息队列 MQTT 版Topic，需要和SQL配置中保持一致。
          Payload	{ "msg": "myMsg" }	测试消息。

   2. 在目标配置向导页面，配置数据的流转目标，然后单击创建。

      参数	取值示例	说明
      目标类型	云消息队列 Kafka 版	指定将源数据转发至的目标云产品。
      Kafka实例ID	alikafka_post-cn-test	选择云消息队列 Kafka 版的实例ID。
      Topic	topic_test	选择云消息队列 Kafka 版实例的Topic。
      投递策略	按Clientid的hash投递到Topic中的不同partition	消息投递策略： 按Clientid的hash 投递到Topic中的不同partition 无策略
      可用区	vsw-test	选择可用区的交换机ID。 重要 在所选的云消息队列 Kafka 版实例所属的安全组规则配置中，添加此处选择交换机对应的IP网段。

查看规则详情

1. 在规则管理页面，单击Kafka 规则页签。

2. 在规则列表中找到目标规则，在其操作列中，单击详情。

3. 在规则详情页面，查看基础信息、规则源和规则目标等信息。

启用/停用规则

1. 在规则管理页面，单击Kafka 规则页签。

2. 在规则列表中找到目标规则，在其操作列中，单击启用/停用。

3. 在弹出的提示对话框，单击确认。

编辑规则

1. 在规则管理页面，单击Kafka 规则页签。

2. 在规则列表中找到目标规则，在其操作列中，单击编辑。

3. 在编辑规则页面，完成以下操作。

   1. 在规则配置向导页面，修改SQL配置，然后单击下一步。

   2. 在目标配置向导页面，修改Topic或者投递策略，然后单击保存。

      参数	取值示例	说明
      Topic	topic_test	选择云消息队列 Kafka 版实例的Topic。
      投递策略	按Clientid的hash投递到Topic中的不同partition	消息投递策略： 按Clientid的hash 投递到Topic中的不同partition 无策略

删除规则

1. 在规则管理页面，单击Kafka 规则页签。

2. 在规则列表中找到目标规则，然后在其操作列选择 > 删除

3. 在弹出的提示对话框，单击确认。

相关文档

SQL语法和示例