Conecta-seEntrar na plataforma

Athena

Executar consultas SQL sobre dados armazenados no Amazon S3 por meio do AWS Athena.

Integrações e ferramentasDados e análisesConexão: Credencial protegida

O que faz

Integre o AWS Athena aos fluxos. Execute consultas SQL em dados do S3, acompanhe o status e as estatísticas de execução das consultas, obtenha resultados, gerencie consultas salvas e instruções preparadas e inspecione catálogos de dados, bancos de dados, tabelas e grupos de trabalho. Exige uma chave de acesso da AWS e a respectiva chave de acesso secreta.

Quando usar: Use quando o seu fluxo precisar executar consultas SQL sobre dados armazenados no Amazon S3 por meio do AWS Athena.

Exemplo de situação: Consultar indicadores e usar o resultado em uma decisão do fluxo.

Antes de começar

Conexão necessária: Credencial protegida.

Escolha uma conexão ou credencial já cadastrada no workspace. Nunca cole senhas ou chaves em campos de texto comuns.

Passo a passo

  1. Adicione Athena ao desenho a partir da aba Blocos e ligue a entrada dele à etapa anterior.
  2. Escolha uma conexão ou credencial já cadastrada no workspace. Nunca cole senhas ou chaves em campos de texto comuns.
  3. Escolha a operação. O painel mostra só os campos que essa operação usa.
  4. Preencha os campos obrigatórios. Para usar um dado de uma etapa anterior, digite < e escolha o bloco e o campo.
  5. Clique em Executar com dados de teste e confira, no terminal, o que entrou e o que saiu do bloco.
  6. Só publique depois de conferir o resultado da execução de teste.

Operações

OperaçãoO que faz
Iniciar consultaInicia consulta com o bloco Athena.
Obter execução da consultaObtém execução da consulta com o bloco Athena.
Obter resultados da consultaObtém resultados da consulta com o bloco Athena.
Interromper consultaInterrompe consulta com o bloco Athena.
Listar execuções de consultasLista execuções de consultas com o bloco Athena.
Criar consulta salvaCria consulta salva com o bloco Athena.
Obter consulta salvaObtém consulta salva com o bloco Athena.
Listar consultas salvasLista consultas salvas com o bloco Athena.

Campos

Mostrar campos de
  • Operação

    Escolhe qual ação este bloco executará.

    Opções:
    Iniciar consulta · Obter execução da consulta · Obter resultados da consulta · Interromper consulta · Listar execuções de consultas · Criar consulta salva · Obter consulta salva · Listar consultas salvas
    Padrão:
    Iniciar consulta
  • Região da AWS

    Obrigatório

    Região da AWS onde estão o Athena e os dados consultados (ex.: sa-east-1, São Paulo).

    Exemplo:
    us-east-1
  • ID da chave de acesso da AWS

    ObrigatórioDado protegido

    Informa o identificador exato do recurso na plataforma conectada.

    Padrão:
    Segredo protegido
  • Chave de acesso secreta da AWS

    ObrigatórioDado protegido

    Informe a sua chave de acesso secreta.

    Padrão:
    Segredo protegido
  • Consulta SQL

    Obrigatório conforme a operação

    SELECT * FROM my_table LIMIT 10.

    Aparece em:
    Iniciar consulta, Criar consulta salva
    Exemplo:
    SELECT * FROM clientes WHERE status = 'ativo'
  • Banco de dados

    Obrigatório conforme a operação

    Banco de dados do catálogo em que a consulta SQL vai rodar; na consulta salva, é o banco ao qual ela fica associada (ex.: vendas).

    Aparece em:
    Iniciar consulta, Criar consulta salva
    Exemplo:
    nome_do_banco
  • Catálogo de dados

    Em campos adicionais

    Catálogo de dados onde fica o banco consultado; mantenha AwsDataCatalog, o catálogo padrão do AWS Glue, a menos que use outra fonte de dados conectada ao Athena.

    Aparece em:
    Iniciar consulta
    Exemplo:
    AwsDataCatalog
  • Local de saída (S3)

    Em campos adicionais

    Pasta no S3 onde o Athena grava os resultados da consulta (ex.: s3://minha-empresa-athena/resultados/); se ficar vazio, vale o local configurado no grupo de trabalho.

    Aparece em:
    Iniciar consulta
    Exemplo:
    s3://my-bucket/athena-results/
  • Grupo de trabalho

    Em campos adicionais

    Grupo de trabalho do Athena que executa e organiza as consultas, com seus limites e local de resultados (ex.: primary); nas listagens, mostra só as execuções ou consultas salvas desse grupo.

    Aparece em:
    Iniciar consulta, Listar execuções de consultas, Criar consulta salva, Listar consultas salvas
    Exemplo:
    primary
  • Parâmetros de execução

    Em campos adicionais

    Lista em JSON com os valores que substituem os marcadores ? da consulta, na mesma ordem em que aparecem (ex.: ["2025-01-01", "BR"]).

    Aparece em:
    Iniciar consulta
    Exemplo:
    ["2024-01-01", "BR"] — valores para os marcadores ?, na ordem
  • Reutilizar resultados anteriores

    Em campos adicionais

    Ativa ou desativa este comportamento.

    Aparece em:
    Iniciar consulta
    Exemplo:
    false
  • Idade máxima do resultado (minutos)

    Em campos adicionais

    Define um valor numérico, quantidade ou limite da operação.

    Aparece em:
    Iniciar consulta
    Exemplo:
    10
  • ID da execução da consulta

    Obrigatório conforme a operação

    Informa o identificador exato do recurso na plataforma conectada.

    Aparece em:
    Obter execução da consulta, Obter resultados da consulta, Interromper consulta
    Exemplo:
    id-do-recurso
  • ID da consulta salva

    Obrigatório conforme a operação

    Informa o identificador exato do recurso na plataforma conectada.

    Aparece em:
    Obter consulta salva
    Exemplo:
    id-do-recurso
  • Nome da consulta

    Obrigatório conforme a operação

    Minha consulta salva.

    Aparece em:
    Criar consulta salva
    Exemplo:
    SELECT * FROM clientes WHERE status = 'ativo'
  • Descrição

    Em campos adicionais

    Descrição do que esta consulta faz.

    Aparece em:
    Criar consulta salva
    Exemplo:
    SELECT * FROM clientes WHERE status = 'ativo'
  • Máximo de resultados

    Em campos adicionais

    Define um valor numérico, quantidade ou limite da operação.

    Aparece em:
    Obter resultados da consulta, Listar execuções de consultas, Listar consultas salvas
    Exemplo:
    10
  • Token de paginação

    Em campos adicionais

    Token da requisição anterior.

    Aparece em:
    Obter resultados da consulta, Listar execuções de consultas, Listar consultas salvas
    Exemplo:
    Token da requisição anterior

Saídas

Para usar um resultado deste bloco em uma etapa seguinte, digite < no campo e escolha o bloco e o campo. A referência tem o formato <athena.queryExecutionId>: antes do ponto vai o nome do bloco no seu fluxo, em minúsculas, sem espaços e sem acentos.

ReferênciaTipoO que contém
<athena.queryExecutionId>stringID da execução da consulta.
<athena.query>stringConsulta SQL.
<athena.state>stringEstado da consulta (QUEUED, RUNNING, SUCCEEDED, FAILED, CANCELLED) ou do grupo de trabalho (ENABLED, DISABLED).
<athena.stateChangeReason>stringMotivo da mudança de estado.
<athena.statementType>stringTipo de instrução (DDL, DML, UTILITY).
<athena.database>stringNome do banco de dados.
<athena.catalog>stringNome do catálogo de dados.
<athena.workGroup>stringNome do grupo de trabalho.
<athena.submissionDateTime>numberHora de envio da consulta (Unix epoch em ms).
<athena.completionDateTime>numberHora de conclusão da consulta (Unix epoch em ms).
<athena.dataScannedInBytes>numberDados verificados, em bytes.
<athena.engineExecutionTimeInMillis>numberTempo de execução no motor, em ms.
<athena.queryPlanningTimeInMillis>numberTempo de planejamento da consulta, em ms.
<athena.queryQueueTimeInMillis>numberTempo na fila, em ms.
<athena.totalExecutionTimeInMillis>numberTempo total de execução, em ms.
<athena.outputLocation>stringLocal no S3 dos resultados da consulta.
<athena.columns>arrayMetadados das colunas (nome e tipo).
<athena.rows>arrayLinhas do resultado como objetos chave-valor.
<athena.nextToken>stringToken de paginação da próxima página.
<athena.updateCount>numberLinhas afetadas por INSERT/UPDATE.
<athena.success>booleanIndica se a operação foi concluída com sucesso.
<athena.queryExecutionIds>arrayLista de IDs de execução de consultas.
<athena.namedQueryId>stringID da consulta salva.
<athena.name>stringNome da consulta salva, do banco de dados, do catálogo de dados ou do grupo de trabalho.
<athena.description>stringDescrição da consulta salva, do banco de dados, do catálogo de dados ou do grupo de trabalho.
<athena.queryString>stringSQL da consulta salva.
<athena.namedQueryIds>arrayLista de IDs de consultas salvas.
<athena.queryExecutions>arrayDetalhes de cada execução de consulta (da obtenção em lote de execuções).
<athena.unprocessedQueryExecutionIds>arrayIDs de execução de consultas que não puderam ser obtidos, com detalhes do erro.
<athena.databases>arrayLista de bancos de dados (nome, descrição, parâmetros).
<athena.rowStatistics>jsonContagem de linhas e bytes da execução da consulta (inputRows, inputBytes, outputRows, outputBytes).
<athena.tables>arrayMetadados das tabelas (nome, tipo, colunas, chaves de partição).
<athena.timeline>jsonDetalhamento dos tempos de execução da consulta, em milissegundos.
<athena.outputStage>jsonResumo da etapa final da consulta.
<athena.namedQueries>arrayDetalhes de cada consulta salva (da obtenção em lote de consultas salvas).
<athena.unprocessedNamedQueryIds>arrayIDs de consultas salvas que não puderam ser obtidos, com detalhes do erro.
<athena.parameters>jsonPropriedades chave/valor do banco de dados, da tabela ou do catálogo de dados.
<athena.tableType>stringTipo da tabela (ex.: EXTERNAL_TABLE, VIRTUAL_VIEW).
<athena.createTime>numberHora de criação da tabela (Unix epoch em ms).
<athena.lastAccessTime>numberHora do último acesso à tabela (Unix epoch em ms).
<athena.partitionKeys>arrayColunas da chave de partição (nome, tipo, comentário).
<athena.dataCatalogs>arrayResumos dos catálogos de dados (nome, tipo, status, tipo de conexão).
<athena.type>stringTipo do catálogo de dados (LAMBDA, GLUE, HIVE, FEDERATED).
<athena.status>stringStatus da criação ou exclusão do catálogo de dados.
<athena.connectionType>stringTipo de conector dos catálogos de dados FEDERATED.
<athena.error>stringTexto do erro na criação ou exclusão do catálogo de dados.
<athena.workGroups>arrayResumos dos grupos de trabalho (nome, estado, descrição, versão do motor).
<athena.creationTime>numberHora de criação do grupo de trabalho (Unix epoch em ms).
<athena.engineVersion>jsonVersão do motor do grupo de trabalho (selecionada e efetiva).
<athena.identityCenterApplicationArn>stringARN do aplicativo do IAM Identity Center do grupo de trabalho.
<athena.encryptionOption>stringOpção de criptografia dos resultados do grupo de trabalho (SSE_S3, SSE_KMS, CSE_KMS).
<athena.kmsKey>stringChave KMS usada na criptografia dos resultados do grupo de trabalho.
<athena.expectedBucketOwner>stringConta proprietária esperada do bucket de resultados do grupo de trabalho.
<athena.managedQueryResultsEnabled>booleanIndica se os resultados do grupo de trabalho ficam em armazenamento gerenciado pelo Athena.
<athena.enforceWorkGroupConfiguration>booleanIndica se as configurações do grupo de trabalho substituem as configurações do lado do cliente.
<athena.publishCloudWatchMetricsEnabled>booleanIndica se o grupo de trabalho publica métricas no CloudWatch.
<athena.bytesScannedCutoffPerQuery>numberLimite de dados verificados por consulta no grupo de trabalho, em bytes.
<athena.requesterPaysEnabled>booleanIndica se o grupo de trabalho pode consultar buckets com Requester Pays.
<athena.enableMinimumEncryptionConfiguration>booleanIndica se o grupo de trabalho exige um nível mínimo de criptografia.
<athena.executionRole>stringARN do papel de execução do grupo de trabalho.
<athena.statementName>stringNome da instrução preparada.
<athena.queryStatement>stringTexto SQL da instrução preparada.
<athena.workGroupName>stringGrupo de trabalho ao qual a instrução preparada pertence.
<athena.lastModifiedTime>numberHora da última modificação da instrução preparada (Unix epoch em ms).
<athena.preparedStatements>arrayDetalhes ou resumos das instruções preparadas.
<athena.unprocessedPreparedStatementNames>arrayNomes de instruções preparadas que não puderam ser obtidos, com detalhes do erro.

Exemplo de uso

Objetivo: Consultar indicadores e usar o resultado em uma decisão do fluxo.

InícioAthenapróxima etapa
Operação
Iniciar consulta
Região da AWS
us-east-1
Consulta SQL
SELECT * FROM clientes WHERE status = 'ativo'
Banco de dados
nome_do_banco

Os valores são ilustrativos. Teste primeiro com dados fictícios ou de homologação.

Erros comuns e como resolver

O bloco não executa
Confira se existe um caminho de setas que parte do gatilho (ou do Início) até este bloco. Blocos soltos no desenho são ignorados.
Aparece “Validação do fluxo” no terminal
Há campo obrigatório vazio. Clique no aviso, abra o bloco indicado e preencha o campo marcado.
Um campo chega vazio na etapa seguinte
Confira se a referência aponta para um bloco que já executou e para um campo que existe, como <athena.queryExecutionId>. O nome antes do ponto é o nome do bloco no seu fluxo, em minúsculas, sem espaços e sem acentos.
O campo que eu procuro não aparece
Os campos mudam conforme a operação escolhida. Escolha a operação primeiro; campos menos usados ficam em “Mostrar campos adicionais”.
Credencial ausente ou recusada
Escolha uma conexão válida do workspace. Se a senha ou a chave mudou no serviço, atualize a conexão cadastrada em vez de colar o segredo no bloco.
O serviço recusou a chamada ou devolveu erro
Leia a mensagem no terminal: ela traz o motivo informado pelo serviço. Confira IDs, limites de uso e permissões, e teste antes com um recurso de homologação.

Blocos relacionados