Exemplo de fila de tarefas do Go

Neste exemplo, criamos um aplicativo que exibe um formulário HTML. Você insere uma string na caixa de diálogo e clica em Add. O aplicativo conta o número de vezes que você insere qualquer string dessa maneira.

O aplicativo faz o seguinte:

• Quando você clica em Add, o formulário usa uma solicitação HTTP POST para enviar a string para o aplicativo em execução no App Engine. Lá, o aplicativo agrupa a string em uma tarefa e a envia para a fila padrão.
• A fila encaminha a tarefa para um gerenciador de tarefas incluído, associado ao URL /worker, que grava de maneira assíncrona a string em um armazenamento de dados.
• O envio de uma solicitação HTTP GET exibe uma lista das strings que você digitou e o número de vezes que vocêAdd cada string, seja digitando ou clicando na lista suspensa.

Para implantar esse aplicativo no App Engine:

1. Copie o seguinte para um arquivo chamado queue.yaml. Isso altera a taxa em que as tarefas serão processadas do padrão 5 por segundo para 3 por segundo.

   queue:
   - name: default
     rate: 3/s
   

2. No mesmo diretório, copie o seguinte em um arquivo que terá o nome que você escolheu (terminando em .go). Esse é o código do aplicativo, incluindo o gerenciador 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 em um arquivo chamado app.yaml. Isso configura seu aplicativo para o App Engine:

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

4. Verifique se você tem um projeto do Google Cloud Platform com um aplicativo do App Engine preparado. Confira também se você inicializou e configurou o comando gcloud para esse projeto.

5. Use o comando gcloud app deploy para implantar o aplicativo no App Engine.

6. Veja o app em ação usando o comando gcloud app browse.