• Guias
• Send Messages To A Queue

Send messages to a queue refere-se ao processo de adição de mensagens a uma fila. Esta fila é uma estrutura de dados que armazena mensagens na ordem “primeiro a entrar, primeiro a sair” (FIFO, em inglês). As mensagens são adicionadas na parte de trás da fila e removidas da parte da frente. As mensagens podem ser enviadas de forma assíncrona e processadas pelo componente receptor posteriormente, facilitando a comunicação entre diferentes partes de um sistema.

Para obter a integração Send messages to a queue fornecida pelo Marketplace, siga esses passos:

1. Acesse o Azion Console > Marketplace.
2. Na homepage do Marketplace, selecione o card da integração.
3. Quando estiver na página da integração, clique no botão Get It Now para iniciar a instalação.

Aparecerá uma mensagem indicando que a integração foi instalada com sucesso.

Sendo uma Edge Application function, a Send messages to a queue é executada no edge, empregando uma edge application existente.

Para configurar a integração Send messages to a queue, complete os seguintes passos:

1. No canto superior esquerdo da página, selecione Products Menu > Edge Application.
2. Na lista de aplicações, selecione a edge application na qual deseja configurar a integração Send messages to a queue.
3. Na página da aplicação, entra na aba Main Settings.
4. Habilite o swicth Edge Functions para permitir o uso do módulo na sua aplicação.
5. Clique no botão Save no canto inferior direito da página.

Aparecerá uma mensagem indicando que a edge application foi atualizada com sucesso.

Para instanciar a integração Send messages to a queue, ainda na página de Edge Application, siga os passos abaixo:

1. Selecione a aba Functions.
2. Clique no botão Add Function.
3. Escolha um nome fácil de lembrar para a sua função.
4. No menu suspenso de funções, selecione a função Send messages to a queue.

Isto irá carregar o código-fonte da função referente à integração Send messages to a queue. Logo acima, você terá duas abas: Code e Args. Se você clicar na aba Code, será possível navegar pelo código-fonte, mas sem alterá-lo.

A configuração de sua função estará na aba Args.

Clique na aba Args para editar o arquivo de configuração no formato JSON, no qual você passará os parâmetros para executar sua aplicação.

Você pode configurar três serviços de mensageria: RabbitMQ, Amazon SQS e Kafka-REST. Para cada uma destas integrações, você terá parâmetros diferentes e credenciais diferentes, como mostrado nos exemplos abaixo:

{
  "server_type": "amqp",
  "connection_url": "https://my-service.azion.com/queue",
  "connection_authorization": "Basic my_basic_auth",
  "connection_args: {
   "routing_key: "my_queue",
   "payload: "my_custom_payload"
  }
}

{
  "server_type": "sqs",
  "connection_url": "https://my-service.azion.com/sqs-queue",
  "connection_authorization": "Basic my_basic_auth",
  "connection_args: {
    "auth_params: "my_aditional_auth_params",
     "version": "2012-11-05",
    "expires": "Wed, 21 Oct 2015 07:28:00 GMT"
  }
}

{
  "server_type": "kafka-rest",
  "connection_url": "https://my-service.azion.com/topics/my-topic",
 "connection_args: {
    "payload": "my_custom_payload"
  }
}

Onde:

• server_type: define o tipo de conexão utilizada (amqp, sqs, kafka-rest são os três valores possíveis).
• connection_url: define a URL do servidor do serviço que você escolher.
• connection_authorization: define o tipo de autorização necessária para a conexão. Este é um campo opcional.

Você também pode definir parâmetros adicionais para sua fila, passando-os na seção connection_args. Cada serviço suportado tem parâmetros adicionais diferentes que podem ser utilizados. Estes não são obrigatórios para que a sua função rode no edge.

Para finalizar, clique no botão Save.

Agora, você deve configurar as regras que deseja (criteria e behavior) aplicar a fim de executar sua função.

Para fazer isso, ainda na página de Edge Application, siga estes passos:

1. Selecione a aba Rules Engine.
2. Clique em Default Rule.
   • Você não pode alterar o campo de criteria no Rules Engine para a Default Rule.
3. No campo behavior, selecione Run Function no menu suspenso.
4. Selecione a opção Send messages to a queue, de acordo com o nome que você deu na etapa de instanciação.
5. Clique no botão Save.

Pronto. Agora você tem a sua função funcionando no edge.

Contribuidores