AWS Athena
Saiba mais sobre o conector AWS Athena e como usá-lo na Digibee Integration Platform.
O conteúdo desta documentação está em revisão e pode ser alterado. Agradecemos sua compreensão enquanto trabalhamos para melhorá-la.
AWS Athena acessa o serviço AWS Athena usando a versão 2.x do AWS SDK.
Parâmetros
Dê uma olhada nos parâmetros de configuração do conector. Parâmetros suportados por expressões Double Braces estão marcados com (DB).
Aba General
Dynamic Account
Quando ativo, o conector usará a conta dinamicamente. Caso contrário, usará a conta de forma estática.
False
Booleano
Account Name (DB)
O nome da conta dinâmica usada pelo conector. Esta conta deve ter sido previamente configurada em um conector Store Account no pipeline para que este processo tenha efeito. Este parâmetro fica disponível apenas se o parâmetro Dynamic Account estiver ativo.
N/A
String
Account
A conta usada pelo conector. Este parâmetro fica disponível apenas se o parâmetro Dynamic Account estiver inativo.
N/A
Account
Label (DB)
Nome lógico.
N/A
String
Fail On Error
Se a opção for ativada, a execução do pipeline com erro será interrompida. Caso contrário, a execução do pipeline continua, mas o resultado mostrará um valor falso para a propriedade "success".
False
Booleano
Aba Optional
Database (DB)
O banco de dados Athena a ser utilizado.
N/A
String
Delay
Milissegundos antes da próxima verificação do status de execução da consulta.
2000
Integer
Encryption Option
O tipo de criptografia a ser usado ao armazenar os resultados da consulta no S3.
N/A
String
Include Trace
Inclui informações úteis de rastreamento no início das consultas como um comentário SQL (prefixado com –).
False
Boolean
Initial Delay
Milissegundos antes da primeira verificação do status de execução da consulta.
1000
Integer
Kms Key (DB)
Para SSE-KMS e CSE-KMS, esta é a ARN ou ID da chave KMS.
N/A
String
Max Attempts
Número máximo de tentativas para executar uma consulta. Defina como 1 para desativar tentativas adicionais.
1
Integer
Max Results
Número máximo de resultados a serem retornados para a operação especificada (se suportado pelo endpoint da API Athena). Se não definido, será usado o padrão da API Athena para a operação.
N/A
Integer
Next Token (DB)
Token de paginação a ser usado caso a resposta da solicitação anterior tenha sido truncada.
N/A
String
Operation
A função da API Athena a ser chamada.
Start Query Execution
String
Output Location (DB)
A localização no Amazon S3 onde os resultados da consulta são armazenados, como s3://caminho/para/bucket/. Certifique-se de que este valor termine com uma barra (‘/’).
N/A
String
Output Type
Como os resultados da consulta devem ser retornados. Uma das opções: Stream List (padrão - retorna um GetQueryResultsIterable que pode paginar todos os resultados), Select List (retorna no máximo 1.000 linhas por vez, além de um valor NextToken como cabeçalho, que pode ser usado para paginação manual dos resultados), S3 Pointer (retorna um caminho S3 apontando para os resultados).
Stream List
String
Query Execution Id (DB)
O ID exclusivo que identifica a execução da consulta.
N/A
String
Query String (DB)
A consulta SQL a ser executada. Exceto para consultas simples, prefira configurar isso como o corpo do Exchange ou como um cabeçalho usando Athena2Constants.QUERY_STRING para evitar problemas com codificação de URL.
N/A
String
Region (DB)
A região onde o cliente Athena precisa operar. Ao usar este parâmetro, a configuração esperará o nome da região em letras minúsculas (por exemplo, ap-east-1). Será necessário usar o nome Region.EU_WEST_1.id().
N/A
String
Reset Wait Timeout On Retry
Reinicia a contagem regressiva do waitTimeout em caso de nova tentativa de consulta. Se definido como true, o tempo máximo potencial de espera por consultas será igual a waitTimeout x maxAttempts.
True
Boolean
Retry
Lista opcional, separada por vírgulas, de tipos de erro para os quais a consulta deve ser repetida. Use Retryable para repetir todas as condições de falha repetíveis (por exemplo, erros genéricos e recursos esgotados), Generic para repetir falhas do tipo ‘GENERIC_INTERNAL_ERROR’, Exhausted para repetir consultas que esgotaram os limites de recursos, Always para sempre repetir independentemente da condição de falha, ou Never ou null para nunca repetir (padrão).
Never
String
Wait Timeout
Tempo máximo de espera opcional em milissegundos para aguardar a conclusão bem-sucedida de uma consulta.
0
Integer
Work Group (DB)
O grupo de trabalho a ser usado para executar a consulta.
N/A
String
Client Request Token (DB)
Uma string exclusiva para garantir que as consultas emitidas sejam idempotentes. É improvável que você precise definir isso.
N/A
String
Aba Headers
Query Execution Id (DB)
O ID exclusivo que identifica a execução da consulta.
N/A
String
Query Execution State
O estado da execução da consulta.
N/A
String
Delay
Milissegundos antes da próxima verificação do status de execução da consulta.
N/A
Integer
Reset Wait Timeout On Retry
Reinicia a contagem regressiva do waitTimeout em caso de nova tentativa de consulta. Se definido como true, o tempo máximo potencial de espera por consultas será igual a waitTimeout x maxAttempts.
False
Boolean
Start Query Execution Attempts
Número total de tentativas feitas para executar a consulta. Será maior que 1 se a consulta for repetida.
0
Integer
Start Query Execution Elapsed Millis
Tempo total em milissegundos gasto no startQueryExecution (principalmente relevante ao aguardar a conclusão da consulta dentro de startQueryExecution).
0
Integer
Aba Documentation
Documentation
Seção para documentar qualquer informação necessária sobre a configuração do conector e regras de negócio.
N/A
String
Atualizado