Neste tutorial, você aprenderá a usar o AWS Step Functions para resolver erros de tempo de execução do fluxo de trabalho. AWS Step Functions é um serviço de orquestração sem servidor que permite coordenar com facilidade várias funções do Lambda em fluxos de trabalho flexíveis, fáceis de depurar e alterar. AWS Lambda é um serviço de computação que permite que você execute o código sem provisionar ou gerenciar servidores. 

As funções do Lambda podem ocasionalmente falhar, como quando ocorre uma exceção não processada ou sua execução ultrapassa o tempo limite configurado ou não há memória suficiente. Desenvolver e manter a lógica de processamento de erros em cada função do Lambda, para lidar com situações como controle de utilização de API ou tempo limite de soquete, pode ser uma tarefa demorada e especialmente complexa para aplicativos distribuídos. Incorporar esse código em cada função do Lambda cria dependências entre elas. Além disso, pode ser difícil manter essas conexões em caso de mudanças.

Para evitar que isso aconteça e também reduzir o volume de código necessário para resolver erros, você pode usar o AWS Step Functions para criar um fluxo de trabalho sem servidor que lide com o processamento de erros de função. Independentemente de o erro ser uma exceção de função criada pelo desenvolvedor (por exemplo, arquivo não encontrado) ou ser imprevisível (por exemplo, memória insuficiente), você pode configurar o Step Functions permite responder com lógica condicional de acordo com o tipo de erro ocorrido. Com essa separação da lógica do fluxo de trabalho da lógica de negócios, é possível modificar a maneira como o fluxo de trabalho responde aos erros sem alterar a lógica de negócios das funções do Lambda.

Neste tutorial, você projetará e executará um fluxo de trabalho sem servidor usando o AWS Step Functions, que solucionará esses erros. Você criará uma função do AWS Lambda, que simulará chamadas para uma API RESTful e retornará vários códigos de resposta e exceções. Em seguida, você usará o AWS Step Functions para criar uma máquina de estado com recursos de Retry (Tentar novamente) e Catch (Detectar) que responde com lógica diferente dependendo da exceção gerada.

a.  Abra o Console de Gerenciamento da AWS para poder manter este guia detalhado aberto. Quando a tela carregar, digite seu nome de usuário e senha para começar. Em seguida, digite Lambda na barra de pesquisa e selecione Lambda para abrir o console do serviço.

b. Selecione Create a function (Criar função).

c. Deixe a opção Author from scratch (Criar do zero) marcada. Em seguida, configure a função do Lambda da seguinte maneira:

Para Name (Nome), digite MockAPIFunction.
Para Runtime (Tempo de execução), selecione Python 3.6.
Para Role (Função) selecione Create custom role (Criar função personalizada).

Uma nova janela do IAM será exibida. Mantenha a opção Role name (Nome da função) como lambda_basic_execution e clique em Allow (Permitir). Você retornará automaticamente ao console do Lambda.

Clique em Create function (Criar função).

d. Na tela MockAPIFunction, role para baixo até a seção Function code (Código da função). Neste tutorial, você criará uma função que usa o modelo de programação para criação de funções do Lambda no Python. Na janela do código, substitua todo o código pelas informações abaixo e selecione Save (Salvar).

class TooManyRequestsException(Exception): pass
class ServerUnavailableException(Exception): pass
class UnknownException(Exception): pass

def lambda_handler(event, context):
    statuscode = event["statuscode"]    
    if statuscode == "429":
        raise TooManyRequestsException('429 Too Many Requests')
    elif statuscode == "503":
        raise ServerUnavailableException('503 Server Unavailable')
    elif statuscode == "200":
        return '200 OK'
    else:
        raise UnknownException('Unknown error')

e. Depois que a função do Lambda for criada, role a tela até a parte superior da janela e veja o nome de recurso da Amazon (ARN) no canto superior direito da página. Os nomes de recurso da Amazon (ARNs) identificam com exclusividade os recursos da AWS e ajudam você a monitorar e usar itens e políticas da AWS nos serviços da AWS e nas chamadas de API. Um ARN é necessário quando precisamos fazer referência a um recurso específico do Step Functions.

a. Em outra janela do navegador, acesse o Console de Gerenciamento da AWS e digite IAM na barra de pesquisa. Clique no IAM para abrir o console do serviço.

b. Clique em Roles (Funções) e escolha Create Role (Criar função).

c. Na página Select type of trusted entity (Selecionar tipo de entidade de confiança), em AWS service (Serviço da AWS), selecione Step Functions na lista e, em seguida, Next: Permissions (Próximo: Permissões).

d. Na página Attach permissions policy (Anexar política de permissões), escolha Next: Review (Próximo: Revisar).

 

e. Na página Review (Revisar), digite step_functions_basic_execution para Role name (Nome da função) e clique em Create role (Criar função).

f. Sua nova função do IAM foi criada e aparece na lista abaixo da função do IAM da sua função do Lambda.

a. Abra o console do AWS Step Functions. Na página Create a state machine (Criar uma máquina de estado), selecione Author from scratch (Criar do zero). Na seção Details (Detalhes), nomeie sua máquina de estado como MyAPIStateMachine e selecione I will use an existing role (Usarei uma função existente).

b. Em seguida, você projetará uma máquina de estado que executará diversas ações de acordo com a resposta da API simulada. Se a API não for acessada, o fluxo de trabalho tentará novamente. Novas tentativas são um meio útil de lidar com erros momentâneos. O fluxo de trabalho também detecta diversas exceções lançadas pela API simulada.

Substitua o conteúdo da seção State machine definition (Definição de máquina de estado) pelo seguinte código:

{
  "Comment": "An example of using retry and catch to handle API responses",
  "StartAt": "Call API",
  "States": {
    "Call API": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:FUNCTION_NAME",
      "Next" : "OK",
      "Comment": "Catch a 429 (Too many requests) API exception, and resubmit the failed request in a rate-limiting fashion.",
      "Retry" : [ {
        "ErrorEquals": [ "TooManyRequestsException" ],
        "IntervalSeconds": 1,
        "MaxAttempts": 2
      } ],
      "Catch": [ 
        {
          "ErrorEquals": ["TooManyRequestsException"],
          "Next": "Wait and Try Later"
        }, {
          "ErrorEquals": ["ServerUnavailableException"],
          "Next": "Server Unavailable"
        }, {
          "ErrorEquals": ["States.ALL"],
          "Next": "Catch All"
        }
      ]
    },
    "Wait and Try Later": {
      "Type": "Wait",
      "Seconds" : 1,
      "Next" : "Change to 200"
    },
    "Server Unavailable": {
      "Type": "Fail",
      "Error":"ServerUnavailable",
      "Cause": "The server is currently unable to handle the request."
    },
    "Catch All": {
      "Type": "Fail",
      "Cause": "Unknown error!",
      "Error": "An error of unknown type occurred"
    },
    "Change to 200": {
      "Type": "Pass",
      "Result": {"statuscode" :"200"} ,
      "Next": "Call API"
    },
    "OK": {
      "Type": "Pass",
      "Result": "The request has succeeded.",
      "End": true
    }
  }
}

c. Localize a linha “Resource” (Recurso) no estado de tarefa “Call API” (Chamar API) (linha 7). Para atualizar esse ARN com o ARN da função do Lambda da API simulada recém-criada, clique no texto do ARN e selecione o ARN na lista.

d. Clique no botão de atualização ao lado do painel de fluxo de trabalho visual para que o Step Functions crie um diagrama da máquina de estado que corresponda ao fluxo de trabalho recém-projetado. Depois de revisar o fluxo de trabalho visual, clique em Create state machine (Criar máquina de estado).

a. Clique em Start execution (Iniciar execução).

b. Uma nova caixa de diálogo de execução é exibida, onde é possível inserir informações para a máquina de estado. Você executará a parte da API e informará o código de erro que desejamos que a API simulada retorne. Substitua o texto existente pelo código abaixo e escolha Start execution (Iniciar execução):

{
    "statuscode": "200"
}

c. Na telaExecution details (Detalhes de execução), clique em Input (Entrada) para ver as informações fornecidas à máquina de estado. Em seguida, clique em Output (Saída) para visualizar o resultado da execução da máquina de estado. Você pode ver que o fluxo de trabalho interpretou o código de status 200 como uma chamada de API bem-sucedida.

d. Em Visual workflow (Fluxo de trabalho visual), você pode ver o caminho de execução, exibido em verde no fluxo de trabalho. Clique no estado de tarefa "Call API" (Chamar API) e expanda os campos Input (Entrada) e Output (Saída) na tela Step details (Detalhes da etapa).

Você pode ver que esse estado de tarefa invocou com êxito a função do Lambda da API simulada com as informações fornecidas e capturou a saída da função do Lambda, “200 OK”.

e. Clique no estado de tarefa "OK" no fluxo de trabalho visual. Em Step details (Detalhes da etapa), você pode ver que a saída da etapa anterior (o estado de tarefa Chamar API) foi passada como entrada para esta etapa. O estado OK é um estado de passagem, ou seja, a entrada passou para a saída, sem executar qualquer trabalho. Os estados de passagem são úteis na construção e depuração de máquinas de estado.

a. Role até a parte superior da tela Execution details (Detalhes de execução) e clique em MyAPIStateMachine.

b. Clique novamente em Start execution (Iniciar execução) e, desta vez, forneça as seguintes informações e clique em Start execution (Iniciar execução).

{
    "statuscode": "503"
}

c. Na seção Execution event history (Histórico de eventos de execução), expanda cada etapa de execução para confirmar se o fluxo de trabalho se comportou como esperado. Esperávamos que esta execução falhasse, não se preocupe! Você perceberá o seguinte:

1. O Step Functions capturou sua entrada de informações
2. Essas informações passaram para o estado de tarefa Chamar API
3. O estado de tarefa Chamar API chamou MockAPIFunction usando essas informações
   
4. MockAPIFunction foi executada
5. MockAPIFunction falhou com ServerUnavailableException
6. A instrução de detecção do estado de tarefa Chamar API detectou essa exceção
7. A instrução de detecção falhou no fluxo de trabalho
   
8. A máquina de estado concluiu sua execução
   

d. Em seguida, você simulará uma exceção 429. Role até a parte superior da tela Execution details (Detalhes de execução) e clique em MyAPIStateMachine. Clique em Start execution (Iniciar execução) e forneça as seguintes informações e clique em Start execution (Iniciar execução):

{
    "statuscode": "429"
}

e. Agora você inspecionará o comportamento de novas tentativas do fluxo de trabalho. Na seção Execution event history (Histórico de eventos de execução), expanda cada etapa de execução mais uma vez para confirmar que o Step Functions tentou chamar a função MockAPILambda mais duas vezes, e ambas falharam. Nesse momento, o fluxo de trabalho passou para o estado Aguardar e tentar mais tarde (indicado na imagem à direita), na esperança de que a indiferença da API fosse apenas temporária.

Em seguida, o estado Aguardar usou a força bruta para mudar o código de resposta para 200, e o fluxo de trabalho concluiu a execução com êxito. Provavelmente você não agiria dessa forma com uma exceção 429 em um aplicativo real, mas estamos tentando simplificar neste tutorial.

f. Execute uma ou mais instâncias do fluxo de trabalho e, desta vez, forneça uma resposta da API aleatória que não seja processada por sua máquina de estado:

{
    "statuscode": "999"
}

Inspecione novamente a execução usando o Histórico de eventos de execução. Ao terminar, clique em MyAPIStateMachine mais uma vez. No painel Executions (Execuções), você pode ver o histórico de todas as execuções do fluxo de trabalho e acessar cada uma individualmente se quiser.

a. Na parte superior da janela do console do AWS Step Functions, clique em State machines (Máquinas de estado).

b. Na janela State machines (Máquinas de estado), clique em MyAPIStateMachine e selecione Delete (Excluir). Confirme a ação selecionando Delete state machine (Excluir máquina de estado) na caixa de diálogo. Sua máquina de estado será excluída em um ou dois minutos assim que o Step Functions confirmar as execuções em andamento estão concluídas.

c. Em seguida, você excluirá as funções do Lambda. Clique em Services (Serviços) no menu do Console de Gerenciamento da AWS e selecione Lambda.

d. Na tela Functions (Funções), clique em MockAPIFunction, selecione Actions (Ações) e Delete (Excluir). Confirme a exclusão clicando novamente em Delete (Excluir).

e. Por último, você excluirá todas as funções do IAM. Clique em Services (Serviços) no menu do Console de Gerenciamento da AWS e selecione IAM.

f. Selecione as duas funções do IAM que você criou para este tutorial e clique em Delete role (Excluir função). Confirme a exclusão clicando em Yes, Delete (Sim, excluir) na caixa de diálogo.

Agora você pode fazer logout no Console de Gerenciamento da AWS.