As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Configure a entrada e a saída do fluxo de trabalho em Step Functions

No tópico anteriorExecutar o fluxo de trabalho , você aprendeu a executar seu fluxo de trabalho. Neste tópico, você aprenderá como selecionar, filtrar e manipular dados à medida que eles passam entre estados.

Uma execução do Step Functions recebe JSON texto como entrada e passa essa entrada para o primeiro estado no fluxo de trabalho. Estados individuais em um fluxo de trabalho recebem JSON dados como entrada e geralmente passam JSON dados como saída para o próximo estado. Por padrão, os dados passam de um estado para o próximo estado no fluxo de trabalho, a menos que você tenha configurado a entrada e/ou a saída. Ter noções básicas sobre como as informações fluem de um estado para outro e aprender a filtrar e manipular esses dados é a chave para efetivamente projetar e implementar fluxos de trabalho no Step Functions.

O Step Functions fornece os seguintes filtros para controlar o fluxo de dados de entrada e saída entre os estados:

Selecione partes específicas da entrada bruta usando o InputPath filtro

Use o filtro InputPath para selecionar uma parte específica da carga de entrada.

Se você não especificar InputPath, o valor padrão será $, o que fará a tarefa do estado se referir à entrada bruta inteira, em vez de a uma parte específica.

Etapa 1: Criar uma máquina de estado

Etapa 2: Executar a máquina de estado

Etapa 3: Usar o filtro InputPath para selecionar partes específicas de uma entrada de execução

Manipule a entrada selecionada usando o filtro Parâmetros

Embora o InputPath filtro ajude a limitar a JSON entrada bruta fornecida, usando o Parameters filtro, você pode passar uma coleção de pares de valores-chave como entrada. Esses pares de chave-valor podem ser valores estáticos que você define na definição de máquina de estado, ou valores selecionados na entrada bruta usando InputPath.

Em seus fluxos de trabalho, Parameters são aplicados depois de InputPath. O Parameters ajuda você a especificar como a tarefa subjacente aceita sua carga de entrada. Por exemplo, se a função check-address Lambda aceitar um parâmetro de string como entrada em vez dos JSON dados, você poderá usar o Parameters filtro para transformar a entrada.

No exemplo a seguir, o filtro Parameters recebe a entrada que você selecionou usando InputPath em Etapa 3: Usar o filtro InputPath para selecionar partes específicas de uma entrada de execução e aplica a função intrínseca States.Format nos itens de entrada para criar uma string chamada addressString. As funções intrínsecas ajudam você a realizar operações básicas de processamento de dados em uma determinada entrada. Para obter mais informações, consulte Funções intrínsecas na Amazon States Language para fluxos de trabalho de Step Functions.

"Parameters": {
    "addressString.$": "States.Format('{}. {}, {} - {}', $.street, $.city, $.state, $.zip)"
  }

Assim, a sequência de caracteres a seguir é criada e fornecida à função do Lambda check-address como entrada.

{
    "addressString": "123 Main St. Columbus, OH - 43219"
}

Configurar a saída usando os OutputPath filtros ResultSelector ResultPath, e

Quando a função check-address Lambda é invocada na máquina de WorkflowInputOutputestado, a função retorna uma carga de saída após realizar a verificação do endereço. Na página Detalhes da execução, escolha a etapa Verificar endereço e visualize a carga de saída dentro do Resultado da tarefa no painel Detalhes da etapa.

{
    "ExecutedVersion": "$LATEST",
    "Payload": {
      "statusCode": 200,
      "body": "{\"approved\":true,\"message\":\"identity validation passed\"}"
    },
    "SdkHttpMetadata": {
      "AllHttpHeaders": {
        "X-Amz-Executed-Version": [
          "$LATEST"
        ],
        ...
        ...
    "StatusCode": 200
  }

Usando ResultSelector

Se precisar fornecer o resultado das verificações de identidade e endereço para os seguintes estados em seu fluxo de trabalho, você pode selecionar o nó Payload.body na saída JSON e usar a função StringToJson intrínseca no ResultSelector filtro para formatar os dados conforme necessário.

ResultSelector seleciona o que é necessário na saída da tarefa. No exemplo a seguir, ResultSelector pega a string em $.payload.BODY e aplica a função States.StringToJson intrínseca para converter a string JSON e colocar o resultado dentro do nó de identidade. JSON

"ResultSelector": {
    "identity.$": "States.StringToJson($.Payload.body)"
  }

Consequentemente, os seguintes JSON dados são criados.

{
    "identity": {
      "approved": true,
      "message": "Identity validation passed"
    }
  }

Ao trabalhar com esses filtros de entrada e saída, você pode ver erros de tempo de execução de JSONpath expressões inválidas.

Usando ResultPath

Você pode especificar um local na carga inicial de entrada para salvar o resultado do processamento da tarefa de um estado usando o campo ResultPath. Se você não especificar ResultPath, o valor padrão será $, o que fará a carga inicial de entrada ser substituída pelo resultado bruto da tarefa. Se você especificar ResultPath como null, o resultado bruto será descartado e a carga inicial de entrada passará a ser a saída efetiva.

Se você aplicar o ResultPath campo aos JSON dados criados usando o ResultSelector campo, o resultado da tarefa será adicionado dentro do nó de resultados na carga de entrada, conforme mostrado no exemplo a seguir:

{
  "data": {
    "firstname": "Jane",
    "lastname": "Doe",
    "identity": {
      "email": "jdoe@example.com",
      "ssn": "123-45-6789"
    },
    "address": {
      "street": "123 Main St",
      "city": "Columbus",
      "state": "OH",
      "zip": "43219"
    },
  "results": {
    "identity": {
      "approved": true
    }
  }
}

Usando OutputPath

Você pode selecionar uma parte da saída do estado após a aplicação de ResultPath para passar ao estado seguinte. Com essa abordagem, você pode filtrar informações indesejadas e repassar apenas JSON a parte necessária.

No exemplo a seguir, o campo OutputPath salva a saída do estado dentro do nó de resultados: "OutputPath": "$.results". Dessa forma, a saída final do estado, que você pode passar para o próximo estado, é a seguinte:

{
    "addressResult": {
      "approved": true,
      "message": "address validation passed"
    },
    "identityResult": {
      "approved": true,
      "message": "identity validation passed"
    }
}

Como usar os recursos do console para visualizar os fluxos de dados de entrada e saída

Você pode visualizar o fluxo de dados de entrada e saída entre os estados em seus fluxos de trabalho usando o Simulador de fluxo de dados do console Step Functions ou a opção de visualização avançada na página Detalhes da execução.

Manipule a entrada selecionada usando o campo Parâmetros

Embora o InputPath campo ajude a limitar a JSON entrada bruta fornecida, usando o Parameters campo, você pode passar uma coleção de pares de valores-chave como entrada. Esses pares de chave-valor podem ser valores estáticos que você define na definição de máquina de estado, ou valores selecionados na entrada bruta usando InputPath.

Em seus fluxos de trabalho, Parameters são aplicados depoisInputPath. Parametersajudam você a especificar como a tarefa subjacente aceita sua carga de entrada. Por exemplo, imagine que se a função check-address Lambda aceitar um parâmetro de string como entrada em vez dos JSON dados, você pode usar o Parameters campo para transformar a entrada.

No exemplo a seguir, o Parameters campo recebe a entrada que você selecionou usando InputPath na Selecione partes específicas da entrada bruta usando o InputPath filtro seção e aplica a função intrínseca States.Format nos itens de entrada para criar uma string chamada. addressString As funções intrínsecas ajudam você a realizar operações básicas de processamento de dados em uma determinada entrada. Para obter mais informações, consulte Funções intrínsecas.

"Parameters": {
    "addressString.$": "States.Format('{}. {}, {} - {}', $.street, $.city, $.state, $.zip)"
  }

Consequentemente, a sequência de caracteres a seguir é criada e fornecida à função Lambda de endereço de verificação como entrada.

{
    "addressString.$": "123 Main St. Columbus, OH - 43219"
}

Próximas etapas

No tópico finalErros de depuração, você aprenderá como depurar erros em seus fluxos de trabalho do Step Functions.