Um exemplo de fila de tarefas do Go

Este exemplo cria uma app que apresenta um formulário HTML. Introduz uma string na caixa de diálogo e clica em Add. A app conta o número de vezes que introduz qualquer string desta forma.

A app faz o seguinte:

• Quando clica em Add, o formulário usa um pedido HTTP POSTpara enviar a string para a app que está a ser executada no App Engine. Aí, o app bundle agrupa a string numa tarefa e envia-a para a fila predefinida.
• A fila encaminha a tarefa para um controlador de tarefas incluído, mapeado para o URL /worker, que grava a string de forma assíncrona num armazenamento de dados.
• O envio de um pedido HTTP GET apresenta uma lista das strings que introduziu e o número de vezes que Add cada string, quer digitando-a, quer clicando nela na caixa de menu pendente.

Para implementar esta app no App Engine:

1. Copie o seguinte para um ficheiro com o nome queue.yaml. Isto altera a taxa à qual as tarefas são processadas de 5 por segundo (predefinição) para 3 por segundo.

   queue:
   - name: default
     rate: 3/s
   

2. No mesmo diretório, copie o seguinte para um ficheiro com o nome que quiser (terminado em .go). Este é o código da aplicação, incluindo o controlador de tarefas.

   
   package counter
   
   import (
   	"html/template"
   	"net/http"
   
   	"google.golang.org/appengine"
   	"google.golang.org/appengine/datastore"
   	"google.golang.org/appengine/log"
   	"google.golang.org/appengine/taskqueue"
   )
   
   func init() {
   	http.HandleFunc("/", handler)
   	http.HandleFunc("/worker", worker)
   }
   
   type Counter struct {
   	Name  string
   	Count int
   }
   
   func handler(w http.ResponseWriter, r *http.Request) {
   	ctx := appengine.NewContext(r)
   	if name := r.FormValue("name"); name != "" {
   		t := taskqueue.NewPOSTTask("/worker", map[string][]string{"name": {name}})
   		if _, err := taskqueue.Add(ctx, t, ""); err != nil {
   			http.Error(w, err.Error(), http.StatusInternalServerError)
   			return
   		}
   	}
   	q := datastore.NewQuery("Counter")
   	var counters []Counter
   	if _, err := q.GetAll(ctx, &counters); err != nil {
   		http.Error(w, err.Error(), http.StatusInternalServerError)
   		return
   	}
   	if err := handlerTemplate.Execute(w, counters); err != nil {
   		http.Error(w, err.Error(), http.StatusInternalServerError)
   		return
   	}
   	// OK
   }
   
   func worker(w http.ResponseWriter, r *http.Request) {
   	ctx := appengine.NewContext(r)
   	name := r.FormValue("name")
   	key := datastore.NewKey(ctx, "Counter", name, 0, nil)
   	var counter Counter
   	if err := datastore.Get(ctx, key, &counter); err == datastore.ErrNoSuchEntity {
   		counter.Name = name
   	} else if err != nil {
   		log.Errorf(ctx, "%v", err)
   		return
   	}
   	counter.Count++
   	if _, err := datastore.Put(ctx, key, &counter); err != nil {
   		log.Errorf(ctx, "%v", err)
   	}
   }
   
   var handlerTemplate = template.Must(template.New("handler").Parse(handlerHTML))
   
   const handlerHTML = `
   {{range .}}
   <p>{{.Name}}: {{.Count}}</p>
   {{end}}
   <p>Start a new counter:</p>
   <form action="/" method="POST">
   <input type="text" name="name">
   <input type="submit" value="Add">
   </form>
   `
   

3. No mesmo diretório, copie o seguinte para um ficheiro denominado app.yaml. Esta ação configura a sua aplicação para o App Engine:

   runtime: go
   api_version: go1
   
   handlers:
   - url: /worker/.*
     script: _go_app
     login: admin
   - url: /.*
     script: _go_app

4. Certifique-se de que tem um projeto da Google Cloud Platform com uma app do App Engine preparado e que inicializou e configurou o comando gcloud para esse projeto.

5. Use o comando gcloud app deploy para implementar a app no App Engine.

6. Veja a app em ação através do comando gcloud app browse.