Monitoramento de replicação e failover¶

Exemplo¶

Veja o progresso da operação de atualização mais recente para o grupo de failover myfg:

SELECT phase_name, start_time, end_time, progress, details
  FROM TABLE(INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS('myfg'));

Exemplos¶

Consulte a função de tabela REPLICATION_GROUP_REFRESH_HISTORY do Information Schema para exibir o histórico de replicação de contas do grupo de failover myfg nos últimos 7 dias:

SELECT PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM TABLE(information_schema.replication_group_refresh_history('myfg'))
  WHERE START_TIME >= CURRENT_DATE() - INTERVAL '7 days';

Consulte a exibição REPLICATION_GROUP_REFRESH_HISTORY do Account Usage para ver o histórico de replicação da conta no mês atual:

SELECT REPLICATION_GROUP_NAME, PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM snowflake.account_usage.replication_group_refresh_history
  WHERE START_TIME >= DATE_TRUNC('month', CURRENT_DATE());

Consulta de exibições Account Usage¶

Os exemplos seguintes calculam os custos de replicação de banco de dados em um grupo de replicação para os últimos 30 dias.

1. Consulte a exibição REPLICATION_GROUP_REFRESH_HISTORY do Account Usage e calcule a soma do número de bytes replicados por banco de dados.

   Por exemplo, para calcular a soma do número de bytes replicados para bancos de dados no grupo de replicação myrg nos últimos 30 dias:

   SELECT SUM(value:totalBytesToReplicate) as sum_database_bytes
     FROM snowflake.account_usage.replication_group_refresh_history rh,
       LATERAL FLATTEN(input => rh.total_bytes:databases)
     WHERE rh.replication_group_name = 'MYRG' AND
           rh.start_time >= CURRENT_DATE() - INTERVAL '30 days';
   

   Copy

   Observe a saída da soma dos bytes do banco de dados:

   +--------------------+
   | SUM_DATABASE_BYTES |
   |--------------------|
   |              22016 |
   +--------------------+
   

2. Consulte a exibição REPLICATION_GROUP_USAGE_HISTORY do Account Usage e calcule a soma do número de créditos usados e a soma dos bytes transferidos para a replicação.

   Por exemplo, para calcular a soma do número de créditos utilizados e a soma dos bytes transferidos para replicação do grupo de replicação myrg nos últimos 30 dias:

   SELECT SUM(credits_used) AS credits_used, SUM(bytes_transferred) AS bytes_transferred
     FROM snowflake.account_usage.replication_group_usage_history
     WHERE replication_group_name = 'MYRG' AND
           start_time >= CURRENT_DATE() - INTERVAL '30 days';
   

   Copy

   Observe a saída da soma dos créditos utilizados e a soma dos bytes transferidos:

   +--------------+-------------------+
   | CREDITS_USED | BYTES_TRANSFERRED |
   |--------------+-------------------|
   |  1.357923604 |             22013 |
   +--------------+-------------------+
   

3. Calcule os custos de replicação para bancos de dados usando os valores dos bytes transferidos para bancos de dados, a soma dos créditos utilizados e a soma de todos os bytes transferidos para replicação das duas etapas anteriores:

   (<banco_de_dados_bytes_transferidos> / <bytes_transferidos>) * <créditos_usados>

   Por exemplo:

   (22016 / 22013) * 1.357923604 = 1.35810866)

Consulta de funções de tabela Information Schema¶

Para operações de atualização dentro dos últimos 14 dias, consulte as funções associadas da tabela Information Schema.

• REPLICATION_GROUP_REFRESH_HISTORY

• REPLICATION_GROUP_USAGE_HISTORY

1. Consulte a função da tabela REPLICATION_GROUP_REFRESH_HISTORY para visualizar a soma do número de bytes copiados para replicação do banco de dados para o grupo de replicação myrg:

   SELECT SUM(value:totalBytesToReplicate)
     FROM TABLE(information_schema.replication_group_refresh_history('myrg')) AS rh,
     LATERAL FLATTEN(input => total_bytes:databases)
     WHERE rh.phase_name = 'COMPLETED' AND
           rh.start_time >= CURRENT_DATE() - INTERVAL '14 days';
   

   Copy

2. Consulte a função da tabela REPLICATION_GROUP_USAGE_HISTORY para ver a soma do número de créditos utilizados e a soma dos bytes transferidos para replicação para o grupo de replicação myrg:

   SELECT SUM(credits_used), SUM(bytes_transferred)
     FROM TABLE(information_schema.replication_group_usage_history(
       date_range_start => DATEADD('day', -14, CURRENT_DATE()),
       replication_group_name => 'myrg'));
   

   Copy