Executar consultas sequencialmente e paralelamente usando o Athena - AWS Step Functions

Executar consultas sequencialmente e paralelamente usando o Athena

Este exemplo de projeto demonstra como executar queries do Athena em sucessão e, em seguida, em paralelo, lidar com erros; depois, enviar uma notificação ao Amazon SNS com base no sucesso ou na falha das consultas.

Neste projeto, o Step Functions usa uma máquina de estado para executar queries do Athena de forma síncrona. Depois que os resultados da query forem retornados, entre no estado paralelo com duas queries do Athena em execução paralela. Em seguida, ele aguarda até o êxito ou a falha do trabalho e envia um tópico do Amazon SNS com uma mensagem sobre o êxito ou a falha do trabalho.

Etapa 1: Criar a máquina de estado

  1. Abra o console do Step Functions e clique em Criar máquina de estado.

  2. Selecione Criar a partir do modelo e encontre o modelo inicial relacionado. Escolha Próximo para continuar.

  3. Escolha como usar o modelo:

    1. Executar uma demonstração: cria uma máquina de estado somente leitura. Após a revisão, você pode criar o fluxo de trabalho e todos os recursos relacionados.

    2. Comece a criar: fornece uma definição de fluxo de trabalho editável que você pode revisar, personalizar e implantar com seus próprios recursos. (Recursos relacionados, como perfis ou filas, não serão criados automaticamente.)

  4. Escolha Usar modelo para continuar com a seleção.

    nota

    Cobranças padrão são aplicadas aos serviços implantados na conta.

Etapa 2: Executar a máquina de estado de demonstração

Se você escolher a opção Executar uma demonstração, todos os recursos relacionados serão implantados e estarão prontos para execução. Se você escolheu a opção Comece a criar, talvez seja necessário definir valores de espaço reservado e criar recursos adicionais antes de executar seu fluxo de trabalho personalizado.

  1. Selecione Implantar e executar.

  2. Aguarde até que a pilha do CloudFormation seja implantada. Esse processo pode levar até 10 minutos.

  3. Depois que a opção Iniciar execução for exibida, revise a Entrada e selecione Iniciar execução.

Parabéns!

Agora você deve ter uma demonstração em execução da máquina de estado. Você pode escolher estados na visualização do gráfico para revisar a entrada, a saída, as variáveis, a definição e os eventos.