As regras de saída de dados encaminham mensagens publicadas em tópicos do ApsaraMQ for MQTT para outros serviços da Alibaba Cloud. Quando uma regra está ativa, as mensagens são entregues automaticamente ao serviço de destino e podem ser consumidas por meio de sua API. Atualmente, apenas o ApsaraMQ for RocketMQ 4.0 é compatível como destino.

Como funciona
Ao criar uma regra de saída de dados, você especifica um tópico MQTT de origem e um tópico RocketMQ de destino. O ApsaraMQ for MQTT encaminha continuamente todas as mensagens publicadas no tópico de origem para o tópico de destino. Em seguida, é possível consumir essas mensagens pela API do ApsaraMQ for RocketMQ.
O ApsaraMQ for MQTT oferece suporte a tópicos multinível, enquanto o ApsaraMQ for RocketMQ aceita apenas tópicos de nível único. Durante o encaminhamento, um tópico MQTT de nível 1 é mapeado para um tópico RocketMQ, e os subníveis do tópico MQTT correspondem às propriedades da mensagem no RocketMQ. Para mais detalhes, consulte Mapeamentos de estrutura de mensagens entre ApsaraMQ for MQTT e ApsaraMQ for RocketMQ.
Criar uma regra de saída de dados
Antes de começar, verifique se você possui:
Uma instância do ApsaraMQ for MQTT com versão de kernel V3.x.x
Uma instância do ApsaraMQ for RocketMQ 4.0 na mesma região da instância MQTT
Tópicos criados em ambas as instâncias
Visualize a versão do kernel da sua instância MQTT na lista de instâncias ou na página Instance Details no console do ApsaraMQ for MQTT .
Para criar uma regra de saída de dados:
Faça login no console do ApsaraMQ for MQTT. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior, selecione a região onde a instância está localizada. Na página Instances, clique no nome da instância para acessar a página Instance Details.
No painel de navegação à esquerda, clique em Rules. No canto superior esquerdo da página Rules, clique em Create Rule.
-
Na etapa Configure Basic Information, defina os parâmetros a seguir e clique em Next.
Parâmetro
Obrigatório
Exemplo
Descrição
Rule ID
Sim
111111
Identificador globalmente único. Caracteres permitidos: letras, dígitos, hifens (-) e underscores (_). Deve incluir pelo menos uma letra ou dígito. Comprimento: 3 a 64 caracteres (truncado automaticamente se exceder). Não pode ser alterado após a criação.
Description
Não
migrate from rocketmq
Descrição da regra.
Status
Sim
Enable
Define se a regra deve ser ativada na criação. Valores válidos: Enable, Disable.
Rule Type
Sim
Data Outbound
Tipo da regra. Valores válidos: Data Outbound: Encaminha mensagens MQTT para outro serviço da Alibaba Cloud. Para mais informações, consulte Exportar dados do ApsaraMQ for MQTT para outros serviços da Alibaba Cloud. Data Inbound: Importa dados de outros serviços da Alibaba Cloud para o ApsaraMQ for MQTT. Para mais informações, consulte Importar dados de outros serviços de nuvem para o ApsaraMQ for MQTT. Client Status Notification: Exporta eventos de status dos clientes do ApsaraMQ for MQTT para outros serviços da Alibaba Cloud. Para mais informações, consulte Exportar eventos de status de clientes do ApsaraMQ for MQTT.
-
Na etapa Configure Rule Source, especifique o tópico de origem e clique em Next.
ImportanteO ApsaraMQ for MQTT oferece suporte a tópicos multinível, mas o ApsaraMQ for RocketMQ aceita apenas tópicos de nível único. Um tópico MQTT de nível 1 é mapeado para um tópico RocketMQ, enquanto os subníveis do tópico MQTT correspondem às propriedades da mensagem no RocketMQ. Para mais detalhes, consulte Mapeamentos de estrutura de mensagens entre ApsaraMQ for MQTT e ApsaraMQ for RocketMQ.
Parâmetro
Obrigatório
Exemplo
Descrição
Topic
Sim
Topic A
Tópico MQTT de onde os dados serão exportados.
-
Na etapa Configure Rule Destination, especifique o destino e clique em Create.
Parâmetro
Obrigatório
Exemplo
Descrição
Destination Service Type
Sim
Message Queue for Apache RocketMQ
Apenas o ApsaraMQ for RocketMQ é compatível.
Message Queue for Apache RocketMQ Instance
Sim
MQ_INST_13801563067\\\\\*\_BbyOD2jQ
ID da instância RocketMQ. Deve estar na mesma região da instância MQTT.
Topic
Sim
Topic B
Tópico de destino na instância RocketMQ. As mensagens do tópico MQTT de origem são encaminhadas para este local.
Após a criação, a regra aparece na página Rules.
Para informações sobre como as mensagens MQTT são mapeadas para mensagens RocketMQ, consulte Mapeamentos de estrutura de mensagens entre ApsaraMQ for MQTT e ApsaraMQ for RocketMQ .
Editar uma regra de saída de dados
Na página Rules, localize a regra desejada. Na coluna Actions, escolha More > Edit.
Na página Edit Rule, modifique qualquer parâmetro, exceto o ID da regra.
Clique em Save na etapa Configure Rule Destination.
Excluir uma regra de saída de dados
Na página Rules, localize a regra desejada. Na coluna Actions, escolha More > Delete.
Na caixa de diálogo de confirmação, clique em OK.
Ativar uma regra de saída de dados
Na página Rules, localize a regra desejada. Na coluna Actions, escolha More > Enable.
Na caixa de diálogo de confirmação, clique em OK.
Desativar uma regra de saída de dados
Na página Rules, localize a regra desejada. Na coluna Actions, escolha More > Disable.
Na caixa de diálogo de confirmação, clique em OK.