Referência de funções da pgactive - Amazon Relational Database Service

Referência de funções da pgactive

Abaixo, você pode encontrar uma lista de funções da pgactive com os respectivos parâmetros, valores de retorno e observações práticas de uso para ajudar você a usá-las de forma eficaz:

get_last_applied_xact_info

Recupera as informações da última transação aplicada para um nó especificado.

Arguments (Argumentos)
  • sysid (text): OID de carimbo de data/hora

  • dboid (OID)

Tipo de retorno

Ela registra o seguinte:

  • last_applied_xact_id (OID)

  • last_applied_xact_committs (carimbo de data/hora com fuso horário)

  • last_applied_xact_at (carimbo de data/hora com fuso horário)

Observações de uso

Use esta função para recuperar as informações da última transação aplicada para um nó especificado.

pgactive_apply_pause

Pausa o processo apply da replicação.

Arguments (Argumentos)

Nenhum

Tipo de retorno

boolean

Observações de uso

Chame esta função para pausar o processo apply da replicação.

pgactive_apply_resume

Retoma o processo apply da replicação.

Arguments (Argumentos)

Nenhum

Tipo de retorno

nulo

Observações de uso

Chame essa função para retomar o processo apply da replicação.

pgactive_is_apply_paused

Verifica se o processo apply da replicação está em pausa no momento.

Arguments (Argumentos)

Nenhum

Tipo de retorno

boolean

Observações de uso

Use essa função para verificar se o processo apply da replicação está em pausa no momento.

pgactive_create_group

Cria um grupo da pgactive convertendo um banco de dados independente no nó inicial.

Arguments (Argumentos)
  • node_name (text)

  • node_dsn (text)

  • apply_delay integer DEFAULT NULL::integer - replication_sets text[] DEFAULT ARRAY[‘default’::text]

Tipo de retorno

nulo

Observações de uso

Cria um grupo da pgactive convertendo um banco de dados independente no nó inicial. A função realiza verificações de integridade antes de transformar o nó em um nó pgactive. Antes de usar essa função, o cluster do PostgreSQL deve ter max_worker_processes suficientes para comportar operadores em segundo plano da pgactive.

pgactive_detach_nodes

Remove os nós especificados do grupo da pgactive.

Arguments (Argumentos)
  • p_nodes (text[])

Tipo de retorno

nulo

Observações de uso

Use essa função para remover os nós especificados do grupo da pgactive.

pgactive_exclude_table_replication_set

Exclui uma tabela específica da replicação.

Arguments (Argumentos)
  • p_relation (regclass)

Tipo de retorno

nulo

Observações de uso

Use essa função para excluir uma tabela específica da replicação.

pgactive_get_replication_lag_info

Recupera informações detalhadas do atraso da replicação, incluindo detalhes do nó, status do WAL e valores de LSN.

Arguments (Argumentos)

Nenhum

Tipo de retorno

Registro SETOF: node_name text, node_sysid text, application_name text, slot_name text, active boolean, active_pid integer, pending_wal_decoding bigint (tamanho aproximado do WAL em bytes a ser decodificado no nó emissor), pending_wal_to_apply bigint (tamanho aproximado do WAL em bytes a ser decodificado no nó receptor), restart_lsn pg_lsn, confirmed_flush_lsn pg_lsn, sent_lsn pg_lsn, write_lsn pg_lsn, flush_lsn pg_lsn, replay_lsn pg_lsn

Observações de uso

Chame esta função para recuperar informações sobre o atraso da replicação, incluindo detalhes do nó, status do WAL e valores de LSN.

pgactive_get_stats

Recupera estatísticas de replicação da pgactive.

Arguments (Argumentos)

Nenhum

Tipo de retorno

Registro SETOF: rep_node_id oid, rilocalid oid, riremoteid text, nr_commit bigint, nr_rollback bigint, nr_insert bigint, nr_insert_conflict bigint, nr_update bigint, nr_update_conflict bigint, nr_delete bigint, nr_delete_conflict bigint, nr_disconnect bigint

Observações de uso

Use esta função para recuperar estatísticas de replicação da pgactive.

pgactive_get_table_replication_sets

Obtém a configuração do conjunto de replicações para uma relação específica.

Arguments (Argumentos)
  • relation (regclass)

Tipo de retorno

Registro SETOF

Observações de uso

Chame esta função para obter a configuração do conjunto de replicações para uma relação específica.

pgactive_include_table_replication_set

Inclui uma tabela específica na replicação.

Arguments (Argumentos)
  • p_relation (regclass)

Tipo de retorno

nulo

Observações de uso

Use esta função para incluir uma tabela específica na replicação.

pgactive_join_group

Adiciona um nó a um grupo existente da pgactive.

Arguments (Argumentos)
  • node_name (text)

  • node_dsn (text)

  • join_using_dsn (text)

  • apply_delay (integer, optional)

  • replication_sets (text[], default: ['default'])

  • bypass_collation_check (boolean, default: false)

  • bypass_node_identifier_creation (boolean, default: false)

  • bypass_user_tables_check (boolean, default: false)

Tipo de retorno

nulo

Observações de uso

Chame essa função para adicionar um nó a um grupo existente da pgactive. O cluster do PostgreSQL deve ter max_worker_processes suficientes para os operadores em segundo plano da pgactive.

pgactive_remove

Remove todos os componentes da pgactive do nó local.

Arguments (Argumentos)
  • force (boolean, default: false)

Tipo de retorno

nulo

Observações de uso

Chame esta função para remover todos os componentes da pgactive do nó local.

pgactive_snowflake_id_nextval

Gera valores de sequência exclusivos específicos do nó.

Arguments (Argumentos)
  • regclass

Tipo de retorno

bigint

Observações de uso

Use esta função para gerar valores de sequência exclusivos específicos do nó.

pgactive_update_node_conninfo

Atualiza as informações de conexão de um nó da pgactive.

Arguments (Argumentos)
  • node_name_to_update (text)

  • node_dsn_to_update (text)

Tipo de retorno

nulo

Observações de uso

Usa esta função para atualizar as informações de conexão de um nó da pgactive.

pgactive_wait_for_node_ready

Monitora o progresso das operações de criação de grupo ou junção.

Arguments (Argumentos)
  • timeout (integer, default: 0)

  • progress_interval (integer, default: 60)

Tipo de retorno

nulo

Observações de uso

Chame esta função para monitorar o progresso das operações de criação de grupo ou junção.