Entender o Cloud Tasks

Nesta página, você verá o que são as tarefas e filas do Cloud Tasks, além de quando e como usá-las. O Cloud Tasks permite separar os trabalhos que podem ser executados de maneira independente, fora do fluxo principal do aplicativo e enviá-los para processamento assíncrono, usando os gerenciadores criados por você. Esses trabalhos independentes são chamados de tarefas. Por exemplo, você precisa atualizar um banco de dados como parte do processamento de uma solicitação do usuário, mas as atualizações podem ser demoradas. O descarregamento desse detalhe como uma tarefa permite que você retorne da solicitação mais rapidamente.

Importante: o serviço Cloud Tasks foi projetado para trabalho assíncrono. Ele não oferece garantias fortes em relação ao tempo de entrega da tarefa e, portanto, é inadequado para aplicativos interativos em que um usuário está esperando o resultado.

A tarefa descarregada é adicionada a uma fila, que a mantém até que seja executada com sucesso. Com base na sua configuração inicial, a fila também pode atuar como um controle de fluxo de despacho. Você cria e configura a fila, que é gerenciada pelo serviço Cloud Tasks. Depois que as tarefas são adicionadas, a fila as despacha e garante que elas sejam processadas de forma confiável pelos workers. As complexidades associadas a esse processo, como custos de latência do usuário, falhas do servidor, limitações de consumo de recursos e gerenciamento de novas tentativas, são gerenciadas pelo serviço.

O Cloud Tasks foi projetado para fornecer entrega "pelo menos uma vez", ou seja, se uma tarefa for adicionada com sucesso, a fila a entregará pelo menos uma vez. Em algumas circunstâncias raras, a execução de várias tarefas é possível. Portanto, o código precisa garantir que não haja efeitos colaterais prejudiciais pela execução repetida. Os gerenciadores precisam ser idempotentes.

As tarefas em si são compostas por um nome exclusivo e informações de configuração e, opcionalmente, qualquer dado da solicitação inicial, chamado de payload, necessário para processar a solicitação. À medida que o payload é enviado no corpo da solicitação, as tarefas que incluem payloads precisam usar POST ou PUT como método HTTP.

Para acessar o serviço Cloud Tasks usando a API Cloud Tasks , você precisa ter um projeto do Google Cloud.

Casos de uso

Os casos de uso típicos incluem:

• acelerar os tempos de resposta dos usuários delegando operações em segundo plano potencialmente lentas, como atualizações de banco de dados para um worker;
• preservar solicitações no contexto de incidentes de produção inesperados;
• ajudar a amenizar os picos de tráfego removendo tarefas que não são voltadas para o usuário do fluxo de usuários principal.
• Como gerenciar taxas de chamadas de API de terceiros

Filas do Cloud Tasks com destinos HTTP

No caso de destinos HTTP genéricos, o serviço Cloud Tasks encaminha a solicitação de tarefa para o worker, localizado em qualquer endpoint HTTP genérico, com base em como a tarefa está configurada. Esse endpoint pode estar no Cloud Functions, Cloud Run, GKE, Compute Engine ou até mesmo em um servidor da Web no local, com base na configuração da tarefa. Essas filas enviam solicitações a uma taxa confiável e configurável, e Elas garantem uma execução de tarefas confiável. Após a conclusão, todos os workers precisam enviar um código de resposta HTTP (200-299) para o serviço Cloud Tasks antes do prazo padrão de 10 minutos, com um máximo de 30 minutos. Se nenhuma resposta ou uma resposta diferente for enviada, uma nova tentativa com a tarefa será realizada.

O destino precisa gerenciar o escalonamento de workers e a limpeza de tarefas quando elas forem concluídas.

Se o destino exigir autenticação, será necessário configurar duas contas de serviço, uma para o aplicativo, o cliente, e outra para a própria fila. As duas contas precisam ter recebido as permissões exigidas. Além disso, é necessário que um identificador para a conta de serviço do cliente seja incluído na solicitação de tarefa. Consulte Criar tarefas de destino HTTP para mais informações.

Filas do Cloud Tasks com destinos do App Engine

O Cloud Tasks é compatível com os seguintes ambientes do App Engine:

• Ambientes de execução de segunda geração do ambiente padrão do App Engine
• Ambiente flexível do App Engine

Os usuários dos ambientes de execução de primeira geração do App Engine que usam a API Task Queue podem migrar para o Cloud Tasks. Para saber como fazer isso, consulte Migrar do pacote de serviços legados. Os usuários dos ambientes de execução de primeira geração do App Engine que não usam o serviço de tarefas incluídas podem fazer upgrade para ambientes de execução de segunda geração para usar o Cloud Tasks.

No caso de destinos do App Engine, o serviço Cloud Tasks também encaminha a solicitação de tarefa para o gerenciador, mas esse worker está localizado no App Engine. Portanto, todas as filas direcionadas aos gerenciadores do App Engine precisam ter um aplicativo do App Engine. Os gerenciadores precisam ser executados na região em que o aplicativo do App Engine é executado. Essa região também serve como o parâmetro LOCATION_ID para suas solicitações do Cloud Tasks.

As tarefas são roteadas com base em como a tarefa (ou, menos comumente, a própria fila) está configurada. As filas enviam solicitações a uma taxa confiável e configurável. Elas garantem uma execução de tarefas confiável. Após o sucesso, todos os workers precisam enviar um código de resposta HTTP (200-299) para o serviço Cloud Tasks, nessa instância antes de um prazo com base no tipo de escalonamento de instâncias do serviço: 10 minutos para escalonamento automático ou até 24 horas para escalonamento manual. Se nenhuma resposta ou uma resposta diferente for enviada, uma nova tentativa com a tarefa será realizada.

Como os gerenciadores fazem parte do App Engine, o próprio serviço do Cloud Tasks pode fazer grande parte do gerenciamento de processos para a tarefa, aumentando e diminuindo os workers em relação ao tráfego e excluindo tarefas quando elas são concluídas.

Observação :dois locais do App Engine, chamados europe-west e us-central nos comandos do App Engine, são chamados, respectivamente, europe-west1 e us-central1 nos comandos do Cloud Tasks.

Regiões compatíveis por destino

Se o destino for um endpoint HTTP/S, o Cloud Tasks vai estar disponível em todas as regiões compatíveis do Google Cloud para o Cloud Tasks.

Se o destino for um aplicativo do App Engine localizado no projeto atual:

• Uma tarefa destinada ao App Engine só pode ser criada na região do App Engine do projeto.

• Um projeto do Google Cloud pode conter apenas um aplicativo do App Engine, e a região em que ele está localizado não poderá ser alterada após a criação.

• O App Engine é regional, ou seja, a infraestrutura que executa seu aplicativo está localizada em uma região específica. Se você quiser distribuir computação e filas entre várias regiões, escolha um endpoint HTTP/S.

• Se você não estiver usando o App Engine como destino, não precisará implantar um aplicativo do App Engine e poderá desativar qualquer aplicativo atual do App Engine.

Fluxos de trabalho

O fluxo de trabalho geral é o seguinte:

1. Você cria um worker para processar as tarefas.
2. Você cria uma fila.
3. Você cria tarefas de maneira programática e as adiciona à fila.
4. O serviço Cloud Tasks retorna um OK para o aplicativo de origem. Isso indica que a tarefa foi gravada com êxito no armazenamento do Cloud Task, o que torna a solicitação de criação de tarefa altamente disponível e durável.
5. As tarefas são transmitidas para o worker.
6. O worker processa a tarefa.
7. Para completar a sequência, o worker retorna um código de status de sucesso 2xx para o serviço Cloud Tasks.

Depois que a tarefa for entregue à fila, nenhum dado estará disponível para a solicitação inicial.

Observação: a API Cloud Tasks fornece uma interface independente do App Engine para o serviço de fila de tarefas do App Engine. As filas que estão acessíveis usando o SDK do App Engine também podem ser acessadas na API do Cloud Tasks, e vice-versa.

Recursos

Com o Cloud Tasks, é possível despachar itens de trabalho assíncronos com os seguintes controles:

• Agendar horários de entrega específicos
• Gerenciar taxas de envio
• Configurar o comportamento de repetição
• Acessar e gerenciar tarefas individuais em uma fila
• Ativar a eliminação de duplicação de tarefas

Termos

A tabela a seguir mostra os termos-chave que descrevem aspectos do comportamento do Cloud Tasks.

Termo	Definição
fila	Um conjunto de tarefas com o mesmo tipo de destino gerenciado por uma única configuração.
tipo de destino	Como e o local em que uma tarefa é processada.
worker	Um serviço que processa tarefas.
tentativa	Uma tentativa de executar uma tarefa.
tentativa de despacho	O momento em que o Cloud Tasks enviou a tarefa ao seu destino.
tentativa de resposta	Uma resposta de um worker que indica que o trabalho associado à tarefa foi concluído ou falhou.
tentar de novo	Várias tentativas para executar uma tarefa. O número de novas tentativas é definido por RetryConfig.
limites de taxas	Os limites de taxas para uma fila.

Métricas

As métricas predefinidas do Google Tarefas a seguir estão disponíveis no Cloud Monitoring.

Tipo de métrica Nome de exibição Tipo, Tipo, Unidade	Descrição Rótulos
api/request_count Solicitações de API DELTA, INT64, 1	Contagem de chamadas da Cloud Tasks API. api_method: o método de API chamado (por exemplo, CreateTask). response_code: código de resposta canônico como string (por exemplo, "ok").
queue/depth Profundidade da fila BETA GAUGE, INT64, 1	O número de tarefas na fila. Amostras coletadas a cada 60 segundos. Após a amostragem, os dados não são visíveis por até 120 segundos.
queue/task_attempt_count Contagem de tentativas de tarefas DELTA, INT64, 1	Contagem do número de tarefas que a fila tentou enviar, detalhadas por código de resposta da tarefa. response_code: código de resposta canônico como string (por exemplo, "ok").
queue/task_attempt_delays Atrasos das tentativas de tarefa DELTA, DISTRIBUTION, ms	Atraso entre cada horário de tentativa programado e o horário de tentativa real.