As regras de entrada de dados permitem que o ApsaraMQ for MQTT receba mensagens de outros serviços da Alibaba Cloud e as envie para clientes MQTT por meio do protocolo Message Queuing Telemetry Transport (MQTT). É possível chamar as operações de API dos serviços da Alibaba Cloud para enviar dados aos clientes do ApsaraMQ for MQTT.
Como funciona
Uma regra de entrada de dados conecta um serviço da Alibaba Cloud ao ApsaraMQ for MQTT. O fluxo de dados passa por três etapas:
Um serviço de back-end envia uma mensagem ao ApsaraMQ for RocketMQ por meio de uma operação de API.
O ApsaraMQ for MQTT recupera a mensagem com base na regra de entrada de dados configurada e mapeia o tópico do RocketMQ para um tópico pai do MQTT.
O broker do ApsaraMQ for MQTT envia a mensagem para os clientes MQTT inscritos.
Casos de uso
Entrega de mensagens da nuvem para dispositivos
Um serviço de back-end implantado na nuvem envia uma mensagem ao ApsaraMQ for RocketMQ. A regra de entrada de dados mapeia o tópico do RocketMQ para um tópico do ApsaraMQ for MQTT, e o broker entrega a mensagem aos clientes MQTT de destino.
Limitações
|
Item |
Limite |
Descrição |
|
Regras por instância |
100 |
Para aumentar esse limite, entre em contato com o suporte técnico do ApsaraMQ for MQTT. |
|
Deduplicação de regras |
Uma regra de cada tipo por recurso interno |
Cada group ID aceita uma regra de notificação de status do cliente. Cada tópico aceita uma regra de entrada de dados e uma regra de saída de dados. |
|
Regras entre regiões |
Não suportado |
As instâncias de source e de destino devem estar na mesma região. Por exemplo, se a instância do ApsaraMQ for MQTT estiver na região China (Hangzhou), a instância do ApsaraMQ for RocketMQ também deverá estar em China (Hangzhou). |
|
Versão do ApsaraMQ for RocketMQ |
Apenas 4.0 |
Instâncias do ApsaraMQ for RocketMQ 5.0 não suportam regras de entrada ou saída de dados. |
Observações de uso
Os clientes MQTT podem apresentar latência na entrega de mensagens enquanto o broker do ApsaraMQ for RocketMQ passa por uma atualização de serviço. Para consultar o cronograma de atualizações, acesse a Lista de Avisos.
Mapeamento de recursos
As regras de entrada de dados mapeiam recursos no nível do tópico pai. Uma única regra importa dados de um recurso específico do ApsaraMQ for RocketMQ para um tópico pai do ApsaraMQ for MQTT. Os subtópicos no ApsaraMQ for MQTT são mapeados para propriedades de mensagem no ApsaraMQ for RocketMQ.
|
Recurso do ApsaraMQ for MQTT |
Serviço da Alibaba Cloud |
Recurso do serviço |
Definição do pacote |
|
Tópicos |
ApsaraMQ for RocketMQ |
Tópicos |
Mapeamentos de estrutura de mensagens entre o ApsaraMQ for MQTT e o ApsaraMQ for RocketMQ |
Próximos passos
Gerencie regras de entrada de dados -- Instruções passo a passo para criar e gerenciar regras de entrada de dados no console.
Mapeamentos de estrutura de mensagens entre o ApsaraMQ for MQTT e o ApsaraMQ for RocketMQ -- Detalhes sobre como os campos de mensagem são mapeados entre os dois serviços.