Disparador de fila

Uma fila de mensagens é um componente de software usado para lidar com mensagens entre processos, threads ou aplicativos. Uma fila pode armazenar uma mensagem e os trabalhadores podem buscá-la quando é um bom momento.

Na nuvem, as filas de mensagens podem gerar eventos com uma carga útil. Um serviço como o Azure Functions pode ouvir essa mensagem e executar seu código quando uma mensagem é publicada.

Trabalhar com filas de mensagens

Para que uma função do Azure possa consumir uma mensagem de uma fila de mensagens, ela precisa de um gatilho e, possivelmente, de uma ligação.

Uma função do Azure precisa ouvir uma fila específica para que seu código seja acionado quando uma nova mensagem for publicada nessa fila. Para configurar um gatilho, você precisa fornecer as credenciais adequadas para que o código de gatilho saiba como se conectar à fila de mensagens. Você cria uma entrada no ficheiro function.json para a função que está a escutar a fila. bindings No elemento , especifique estas propriedades em uma entrada:

Uma entrada de exemplo pode ser definida assim:

{
    "name": "myQueueItem",
    "type": "queueTrigger",
    "direction": "in",
    "queueName": "messages-incoming",
    "connection": "AzureWebJobsStorage"
  }

Se essa fila estiver em uma conta de armazenamento, o AzureWebJobsStorage valor será o valor da cadeia de conexão.

Você não precisa estritamente de uma associação ao consumir uma mensagem de uma fila. No entanto, se quiseres gravar numa fila, precisas de uma vinculação de saída. Com essa vinculação, obtém-se uma referência à fila pretendida.

Programar localmente

Como desenvolvedor, você quer ciclos de feedback curtos. Você também deseja garantir que sua experiência de desenvolvedor seja o mais próxima possível de um ambiente de produção. Uma maneira de atingir esses dois objetivos é usando um emulador de fila.

Um emulador de fila permite simular mensagens de fila reais às quais sua função do Azure responderá. Para usar o emulador:

1. Instale o emulador. Procure Azurite no Visual Studio Code ou baixe a extensão Azurite.

2. Para usar a funcionalidade do emulador, inicie-a selecionando Azure: Start Queue Service na paleta de comandos.

   A execução deste comando inicia uma escuta chamada Azure Storage Explorer que outra aplicação pode detetar. O Storage Explorer é um aplicativo cliente que permite navegar pelos recursos da nuvem e usar a funcionalidade do emulador.

3. Baixe o Gerenciador de Armazenamento do Azure. Em seguida, abra o aplicativo e você verá a seguinte indicação de que o emulador está funcionando:

   

4. Crie uma fila no emulador. Você usará essa fila como parte da configuração do ponto de extremidade da função. Ao clicar com o botão direito do mouse no elemento queue, você pode criar uma nova fila.

5. Para garantir que seu aplicativo Functions use o emulador, você precisa definir a cadeia de conexão corretamente. Abra local.settings.json, localize o AzureWebJobsStorage elemento e dê-lhe o valor "UseDevelopmentStorage=true".

   Nota

   Lembre-se de definir essa propriedade de forma diferente à medida que você se move para a nuvem. Ele deve apontar para um recurso real no Azure quando em produção.

Construa a função

Agora você tem um emulador local configurado e ele tem uma fila nele. Você também configurou seu projeto para apontar para o emulador local. Agora você precisa criar uma função para lidar com um gatilho de fila.

Criar um ponto de extremidade de função

Você está pronto para criar uma função que possa lidar com mensagens de fila de entrada. Crie uma pasta para sua função e nomeie-a, por exemplo, queueTrigger. Em seguida, crie um arquivo function.json e forneça a ele o seguinte conteúdo:

{
  "bindings": [{
    "name" "queueItem",
    "type": "queueTrigger",
    "direction": "in",
    "queueName" : "items",
    "connection": "AzureWebJobsStorage"
  }]
}

O valor do name elemento é importante, porque você se referirá a ele posteriormente em seu código para analisar os dados de entrada da fila. Ele precisa ser do tipo queueTrigger para que a fila o acione quando houver uma nova mensagem.

O queueName elemento identifica exclusivamente com qual fila você está interagindo. Tudo o que você inserir aqui precisa corresponder ao que você chama de fila no emulador ou ao que você mais tarde chama de fila real no Azure.

O connection elemento aponta para o valor do AzureWebJobsStorage elemento em local.settings.json.

Manipular uma mensagem de fila

Para lidar com uma mensagem de fila de entrada, você precisa escrever código que possa analisar a mensagem que você precisa. Nesse ponto, você pode decidir o que fazer a seguir. Por exemplo, você pode iniciar uma solicitação da Web, colocar essa mensagem em outra fila ou enviar a mensagem para um banco de dados.

Configurar uma rota

Você precisa de uma rota para lidar com solicitações de entrada. O Azure Functions irá processar pedidos para uma fila no nível raiz. Quando você configura uma rota da seguinte maneira, sua solicitação será invocada como http://localhost:<port>/queueTrigger:

http.HandleFunc("/queueTrigger", handleQueueTrigger)

Descodificar um pedido

Quando a mensagem da fila é enviada para você, ela tem esta forma:

{
  "Data": {
    "queueItem": "your message"
  },
  "Metadata": {
    "DequeueCount": 1,
    "ExpirationTime": "2019-10-16T17:58:31+00:00",
    "Id": "800ae4b3-bdd2-4c08-badd-f08e5a34b865",
    "InsertionTime": "2019-10-09T17:58:31+00:00",
    "NextVisibleTime": "2019-10-09T18:08:32+00:00",
    "PopReceipt": "AgAAAAMAAAAAAAAAAgtnj8x+1QE=",
    "sys": {
      "MethodName": "QueueTrigger",
      "UtcNow": "2019-10-09T17:58:32.2205399Z",
      "RandGuid": "24ad4c06-24ad-4e5b-8294-3da9714877e9"
    }
  }
}

Como parte da decodificação dessa solicitação de entrada, você precisa de uma estrutura auxiliar que modele a mensagem anterior. Deverá ter o seguinte aspeto:

type InvokeRequest {
   Data map[string]json.RawMessage
   Metadata map[string]interface{}
}

Comece a escrever código para receber essa solicitação de entrada e decodificá-la:

func handleQueueTrigger(w http.ResponseWrite, r *http.Request) {
   var invokeRequest InvokeRequest
   d := json.NewDecoder(r.Body)
   d.Decode(&invokeRequest)
}

Agora estás num ponto em que o pedido foi decodificado, mas precisas de analisar a mensagem da fila propriamente dita.

Analisar uma mensagem de fila

Depois de a solicitação ser decodificada, a sua mensagem de fila pode ser recuperada da solicitação através da propriedade Data. Você também precisa fazer referência à mensagem pelo valor da propriedade name que você configurou no arquivo function.json. O código para recuperar a mensagem é uma linha única como esta:

invokeRequest.Data["queueItem"]

Como você precisa ser capaz de ler essa mensagem em texto não criptografado, você usará uma biblioteca JSON e a analisará. A biblioteca JSON usará um Unmarshal() método que usa dois parâmetros: a mensagem a ser analisada e a variável na qual colocar a mensagem analisada. Portanto, seu código precisa ter esta aparência:

var parsedMessage string
json.Unmarshal(invokeRequest.Data["queueItem"], &parsedMessage)

Neste ponto, parsedMessage contém a sua mensagem. Se você quiser imprimi-lo no console, use o seguinte código:

fmt.Println(parsedMessage) // your message

Enviar uma mensagem

Para testar seu aplicativo, você pode usar o Gerenciador de Armazenamento do Azure. No painel direito da ferramenta, selecione o botão Adicionar mensagem para criar uma mensagem na fila.

Se você tiver seu aplicativo Functions e ele estiver em execução neste momento, ele acionará a associação e seu código será invocado.