Partilhar via

  • Artigo

Como monitorar programaticamente a replicação (programação RMO)

O Replication Monitor é uma ferramenta gráfica que permite monitorar a topologia de replicação. É possível acessar os mesmos dados de monitoração de forma programática, por meio do RMO (Replication Management Objects). As classes RMO permitem programar as seguintes tarefas:

  • Monitorar os resultados das cinco últimas execuções do Merge Agent no Assinante.

  • Monitorar o estado de Publicadores, publicações e assinaturas.

  • Monitorar os comandos transacionais que estão esperando para serem aplicados a um ou mais Assinantes.

  • Definir os limites métricos que determinam quando uma publicação requer intervenção.

  • Monitorar o estado de tokens de rastreamento. Para obter mais informações, consulte Como medir a latência e validar conexões para replicação de transação (Programação RMO).

Para monitorar uma assinatura para uma publicação de mesclagem no Assinante

  1. Crie uma conexão com o Assinante usando a classe ServerConnection.

  2. Crie uma instância da classe MergeSubscriberMonitor e defina as propriedades Publisher, Publication, PublisherDB, SubscriberDB para a assinatura, e defina a propriedade ConnectionContext como ServerConnection criado na etapa 1.

  3. Chame um dos métodos seguintes para retornar informações sobre as sessões do Merge Agent para essa assinatura:

    • GetSessionsSummary()()()()- retorna uma matriz de objetos MergeSessionSummary com informações até as últimas cinco sessões do Merge Agent. Observe o valor SessionID()()()() para qualquer sessão do seu interesse.

    • GetSessionsSummary(Int32) - retorna uma matriz de objetos MergeSessionSummary com informações das sessões do Merge Agent que ocorreram durante o número de horas passadas no parâmetro hours (até as últimas cinco sessões). Observe o valor SessionID()()()() para qualquer sessão do seu interesse.

    • GetLastSessionSummary- retorna um objeto MergeSessionSummary com informações sobre a última sessão do Merge Agent. Observe o valor de SessionID()()()() para esta sessão.

    • GetSessionsSummaryDataSet- retorna uma matriz de objetos DataSet com informações até as últimas cinco sessões do Merge Agent, uma em cada linha. Observe o valor da coluna Session_id para qualquer sessão do seu interesse.

    • GetLastSessionSummaryDataRow- retorna um objeto DataRow com informações sobre a última sessão do Merge Agent. Observe o valor da coluna Session_id para essa sessão.

  4. (Opcional) Chame o RefreshSessionSummary(MergeSessionSummary%) para atualizar os dados para o objeto MergeSessionSummary passado como mss, ou chame RefreshSessionSummary(DataRow%) para atualizar os dados no objeto DataRow passado como drRefresh.

  5. Usando a id de sessão obtida na etapa 3, chame um dos métodos seguintes para retornar informações sobre os detalhes de uma sessão em particular:

Para monitorar as propriedades de replicação para todas as publicações em um Distribuidor

  1. Crie uma conexão com o Distribuidor usando a classe ServerConnection.

  2. Crie uma instância da classe ReplicationMonitor.

  3. Defina a propriedade ConnectionContext como ServerConnection criada na etapa 1.

  4. Chame o método LoadProperties para obter as propriedades do objeto.

  5. Execute um ou mais dos métodos seguintes para retornar informações de replicação para todos os Publicador que usam esse Distribuidor.

Para monitorar as propriedades de publicação para um Publicador específico no Distribuidor

  1. Crie uma conexão com o Distribuidor usando a classe ServerConnection.

  2. Consiga um objeto PublisherMonitor em um desses modos.

  3. Execute um ou mais dos métodos a seguir para retornar informações de replicação para todas as publicações que pertençam a esse Publicador.

Para monitorar as propriedades para uma publicação específica no Distribuidor

  1. Crie uma conexão com o Distribuidor usando a classe ServerConnection.

  2. Consiga um objeto PublicationMonitor em um desses modos.

  3. Execute um ou mais dos métodos seguintes para retornar informações sobre essa publicação.

Para monitorar os comandos transacionais que estão esperando para serem aplicados no Assinante.

  1. Crie uma conexão com o Distribuidor usando a classe ServerConnection.

  2. Consiga um objeto PublicationMonitor em um desses modos.

  3. Execute o método TransPendingCommandInfo que retorna um objeto PendingCommandInfo.

  4. Use as propriedades desse objeto PendingCommandInfo para determinar o número estimado de comandos pendentes e o tempo que levará para completar a entrega desses comandos.

Para definir os limites de aviso de monitoração para uma publicação

  1. Crie uma conexão com o Distribuidor usando a classe ServerConnection.

  2. Consiga um objeto PublicationMonitor em um desses modos.

  3. Execute o método EnumMonitorThresholds. Observe as configurações de limite atuais no ArrayList retornado de objetos MonitorThreshold.

  4. Execute o método ChangeMonitorThreshold. Passe os seguintes parâmetros:

    • metricID- um valor Int32 que representa a métrica de limite de monitoração da tabela a seguir:

      Valor

      Descrição

      1

      expiration- monitora a expiração iminente de assinaturas para publicações transacionais.

      2

      latency- monitora o desempenho de assinaturas para publicações transacionais.

      4

      mergeexpiration- monitora a expiração iminente de assinaturas para publicações de mesclagem.

      5

      mergeslowrunduration- monitora a duração de sincronizações de mesclagem em conexões da baixa largura da banda (dial-up).

      6

      mergefastrunduration- monitora a duração de sincronizações de mesclagem em conexões de alta largura de banda (LAN).

      7

      mergefastrunspeed - monitora a taxa de sincronizações de mesclagem em conexões de alta largura da banda (LAN).

      8

      mergeslowrunspeed - monitora a taxa de sincronizações de mesclagem em conexões de baixa largura da banda (dial-up).

    • enable- Boolean valor que indica se a métrico está habilitado para a publicação.

    • thresholdValue- valor inteiro que define o limite.

    • shouldAlert- inteiro que indica se esse limite deve gerar um alerta.