Referência de estatísticas do conector¶
Objetos e procedimentos de banco de dados¶
Os seguintes objetos de banco de dados são criados por meio do arquivo observability/connector_stats.sql
.
PUBLIC.GENERIC_CONNECTOR_STATS¶
Exibição não disponível para nenhuma função, acesso via exibição CONNECTOR_STATS
. Exibição fornecendo dados sobre execuções de ingestão em andamento e concluídas. Uma exibição que recupera e mapeia os dados da união de tabelas internas [STATE.INGESTION_RUN
/ STATE.RESOURCE_INGESTION_DEFINITION
/ STATE.INGESTION_PROCESS
].
A estrutura da exibição com mapeamento é a seguinte:
ID (col) → RUN_ID (col);
RESOURCE_INGESTION_DEFINITION_ID (col)
INGESTION_CONFIGURATION_ID (col)
INGESTION_PROCESS_ID (col)
NAME (col)
STARTED_AT (col)
UPDATED_AT (col)
COMPLETED_AT (col)
STATUS (col)
INGESTED_ROWS (col)
DATEDIFF(segundo de STARTED_AT e COMPLETED_AT) (col) → DURATION_S (col);
INGESTED_ROWS (col) / DURATION_S (col) → THROUGHPUT_RPS (col);
METADATA (col)
PUBLIC.AGGREGATED_CONNECTOR_STATS¶
Esta exibição é exposta às funções ADMIN
e VIEWER
. Ele retorna dados agregados da exibição acima e permite acesso para o usuário definido. As linhas serão agrupadas por horas truncadas e exibidas com linhas atualizadas somadas. Exibição fornecendo dados agregados sobre execuções de ingestão diárias.
Uma exibição que recupera e mapeia os dados da tabela interna GENERIC_CONNECTOR_STATS
O mapeamento é o seguinte:
GROUPED BY(horas de STARTED_AT (col)) → RUN_DATE (col);
SUM(INGESTED_ROWS (col)) → UPDATED_ROWS (col);
Exemplo de exibição AGGREGATED_CONNECTOR_STATS
criado no exemplo GENERIC_CONNECTOR_STATS:
RUN_DATE |
UPDATED_ROWS |
---|---|
<timestamp_ntz> |
20 |
<timestamp_ntz> |
40 |
… |
… |
Não é recomendado substituir esta exibição.
PUBLIC.CONNECTOR_STATS¶
Esta exibição é exposta à função ADMIN
. Ele retorna dados da exibição de estatísticas do conector e permite acesso ao usuário definido. Na implementação padrão, essa exibição existe apenas como uma camada adicional acima GENERIC_CONNECTOR_STATS
. Esta implementação deve ser substituída se alguns dados personalizados adicionais precisarem ser adicionados.