Function Compute:Configure a concorrência de instâncias

Billing

A duração da execução e o custo de uma instância de função variam conforme a concorrência de instâncias. Para mais informações, consulte Billing overview.

• Concorrência de Instâncias = 1

  A instância processa apenas uma requisição por vez. O período de faturamento inicia quando a primeira requisição começa a ser processada e termina quando a última requisição é concluída.

  

• Concorrência de Instâncias > 1

  A instância processa múltiplas requisições simultaneamente. A duração real de execução da instância serve como base para medir o tempo de execução da função. O período de faturamento começa no início do processamento da primeira requisição e encerra após a conclusão da última requisição.

  

Concurrency throttling

Por padrão, o Function Compute suporta até 100 instâncias sob demanda em uma região. O cálculo do número máximo de requisições que podem ser processadas simultaneamente em uma região segue a fórmula: 100 × Concorrência de Instâncias. Por exemplo, ao defina a concorrência de instâncias como 10, a região poderá processar no máximo 1.000 requisições simultâneas. Se o volume de requisições concorrentes exceder a capacidade máxima de processamento do Function Compute, o sistema retornará o erro de limitação ResourceExhausted.

Logging

• Com a concorrência de instâncias defina como 1, o Function Compute retorna os logs da função no header de resposta X-Fc-Log-Result caso você especifique X-Fc-Log-Type: Tail no header da requisição HTTP ao invocar a função. Quando a concorrência de instâncias é maior que 1, o header de resposta não inclui os logs da função, pois não é possível isolar os logs de uma requisição específica dentre as requisições concorrentes.

• No runtime Node.js, a função console.info() era utilizada para retornar logs contendo os IDs das requisições. Entretanto, se a Concorrência de Instâncias for maior que 1, a console.info() não exibirá os IDs das requisições corretamente. Todos os IDs aparecerão como req 2. O exemplo abaixo mostra um log nesse formato:

  2019-11-06T14:23:37.587Z req1 [info] logger begin
  2019-11-06T14:23:37.587Z req1 [info] ctxlogger begin
  2019-11-06T14:23:37.587Z req2 [info] logger begin
  2019-11-06T14:23:37.587Z req2 [info] ctxlogger begin
  2019-11-06T14:23:40.587Z req1 [info] ctxlogger end
  2019-11-06T14:23:40.587Z req2 [info] ctxlogger end
  2019-11-06T14:23:37.587Z req2 [info] logger end
  2019-11-06T14:23:37.587Z req2 [info] logger end                    

  Nessa situação, recomenda-se o uso de context.logger.info() para imprimir os logs. Esse método garante a exibição correta dos IDs das requisições. Veja o código de exemplo a seguir:

  exports.handler = (event, context, callback) => {
      console.info('logger begin');
      context.logger.info('ctxlogger begin');
  
      setTimeout(function() {
          context.logger.info('ctxlogger end');
          console.info('logger end');
          callback(null, 'hello world');
      }, 3000);
  };                   

Error handling

Quando uma instância processa múltiplas requisições simultaneamente, o encerramento inesperado do processo causado por uma falha em uma requisição pode afetar as demais requisições concorrentes. Por isso, é essencial implementar lógica de captura de exceções no nível da requisição dentro do código da função, evitando impactos negativos nas outras requisições. O exemplo a seguir apresenta um código em Node.js:

exports.handler = (event, context, callback) => {
    try {
        JSON.parse(event);
    } catch (ex) {
        callback(ex);
    }

    callback(null, 'hello world');
};                    

Shared variables

Erros podem ocorrer se múltiplas requisições tentarem modifique a mesma variável simultaneamente enquanto uma instância processa requisições concorrentes. Utilize mecanismos de exclusão mútua no código para impedir modificações de variáveis que não sejam seguras para threads. O exemplo abaixo demonstra um código em Java:

public class App implements StreamRequestHandler
{
    private static int counter = 0;

    @Override
    public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException {
        synchronized (this) {
            counter = counter + 1;
        }
        outputStream.write(new String("hello world").getBytes());
    }
}