이 페이지에서는 컨테이너 배포 옵션을 사용하여 AlloyDB Omni 버전 15.5.5를 설명합니다. 다른 배포 옵션을 선택합니다.

pglogical 복제를 사용한 전환 및 장애 조치

문서 버전을 선택합니다.

이 페이지에서는 pglogical 복제를 사용하여 전환하고 장애 조치를 수행하는 방법을 설명합니다.

시작하기 전에

pglogical 복제가 설정되고 실행 가능한 고가용성(HA) 및 재해 복구(DR) 솔루션이 있으며 논리 복제에서 true 및 모든 데이터베이스 객체의 포괄적인 복제를 제공하지 않음을 인식한 후에는 이 구성을 사용하기 전에 테스트해야 합니다.

pglogical 확장 프로그램에 대한 자세한 내용은 pglogical 정보를 참조하세요.

pglogical을 사용한 데이터 복제에 대한 자세한 내용은 PostgreSQL용 AlloyDB와 AlloyDB Omni 간 데이터 복제 및 AlloyDB Omni와 다른 데이터베이스 간 데이터 복제를 참조하세요.

pglogical 복제를 사용한 전환

전환은 제공업체 데이터베이스와 구독자 데이터베이스 간에 역할을 전환하는 데 사용되는 제어된 프로세스입니다. 전환을 수행하면 두 데이터베이스(제공업체 및 구독자)의 역할이 반전됩니다. 제공업체가 구독자가 되고 구독자가 제공업체가 됩니다.

이 전환 기능은 운영체제 업그레이드, PostgreSQL 업그레이드 또는 장애 조치 테스트에 중요합니다.

단방향 복제 구성에서 전환하려면 새 제공업체/구독자 관계를 설정하고 이전 제공업체/구독자 관계를 삭제해야 합니다.

새 제공업체/구독자 구성 빌드

애플리케이션이 제공업체 시스템에 쓰는 것을 중지하여 추가 데이터베이스 변경을 방지하고 복제 지연을 확인하여 모든 트랜잭션이 구독자 노드에서 재생되는지 확인합니다.

SELECT application_name,
    state,
    sync_state,
    client_addr,
    client_hostname,
    pg_wal_lsn_diff(pg_current_wal_lsn(),sent_lsn) AS sent_lag,
    pg_wal_lsn_diff(sent_lsn,flush_lsn) AS receiving_lag,
    pg_wal_lsn_diff(flush_lsn,replay_lsn) AS replay_lag,
    pg_wal_lsn_diff(pg_current_wal_lsn(),replay_lsn) AS total_lag,
    now()-reply_time AS reply_delay
FROM pg_stat_replication
ORDER BY client_hostname;

모든 지연 필드에 0이 표시되면 복제가 최신 상태이며 데이터베이스를 전환할 수 있습니다.

출력은 다음과 비슷합니다.

-[ RECORD 1 ]----+------------------------------
application_name | test_sub_1
state            | streaming
sync_state       | async
client_addr      | 10.45.0.80
client_hostname  | 
sent_lag         | 0
receiving_lag    | 0
replay_lag       | 0
total_lag        | 0
reply_delay      | 00:00:26.203433

구독자 데이터베이스를 제공업체 데이터베이스로 변환합니다.
1. 기존 구독자 구독을 중지합니다.
2. 필요한 경우 복제 세트를 추가합니다.
3. 필요한 테이블을 복제 세트에 추가합니다.
4. 새 구독자 데이터베이스에 새 구독자 구독을 빌드합니다.
5. 애플리케이션을 새 제공업체로 리디렉션합니다.
기존 구독자 데이터베이스에서 구독을 중지합니다. 이 데이터베이스는 새 제공업체가 됩니다.
```
SELECT pglogical.alter_subscription_disable(SUBSCRIPTION_NAME);
```
(선택사항) 원래 제공업체 데이터베이스 정의와 일치하는 복제 세트를 만듭니다. 기본 복제 세트를 사용하는 경우에는 필요하지 않습니다.
```
SELECT pglogical.create_replication_set(REPLICATION_SET_NAME);
```
해당 복제 세트에 테이블을 추가합니다.
```
SELECT pglogical.replication_set_add_table(REPLICATION_SET_NAME, TABLE_NAME);
```
다음을 바꿉니다.
- REPLICATION_SET_NAME: 복제 세트 이름
- TABLE_NAME: 스키마 소유자의 테이블 이름. 예를 들면 ARRAY['public']입니다.

이전에는 제공업체 데이터베이스였던 새 구독자 데이터베이스에서 synchronize_data 옵션을 false로 설정하여 초기 테이블 로드를 방지하는 새 구독을 만듭니다.

SELECT pglogical.create_subscription (
           subscription_name := '<subscription name>',
           replication_sets := array['default'],
           synchronize_data := false,
           provider_dsn := 'host=<hostname or IP> port=5432 
           dbname=<db name> user=pglogical_replication password=<password>');

제공업체 노드에서 구독이 작동하는지 확인합니다.

SELECT application_name,
    state,
    sync_state,
    client_addr,
    client_hostname,
    pg_wal_lsn_diff(pg_current_wal_lsn(),sent_lsn) AS sent_lag,
    pg_wal_lsn_diff(sent_lsn,flush_lsn) AS receiving_lag,
    pg_wal_lsn_diff(flush_lsn,replay_lsn) AS replay_lag,
    pg_wal_lsn_diff(pg_current_wal_lsn(),replay_lsn) AS total_lag,
    now()-reply_time AS reply_delay
FROM pg_stat_replication
ORDER BY client_hostname;

복제가 작동하는 경우 새 제공업체 데이터베이스를 사용하도록 애플리케이션 연결 문자열을 변경하고 애플리케이션 등급을 다시 시작합니다.

구독자가 중지된 후 이전 제공업체 노드의 데이터를 변경하면 이러한 변경사항이 복제되지 않아 데이터가 손실됩니다. 원래 제공업체 데이터베이스에 복제되지 않은 데이터 변경사항이 있거나 새 구독자인 원래 제공업체가 이전 구독자인 새 제공업체 데이터베이스와 일치하는 상태가 아니면 새 구독자 데이터베이스를 완전히 빌드해야 합니다.

이전 제공업체 및 구독 삭제

단방향 복제를 사용하려면 이전 제공업체/구독자 구성을 삭제해야 합니다.

새 제공업체에서 이전 구독을 삭제합니다.

SELECT pglogical.drop_subscription('<subscription name>')

새 구독자에서 복제 세트를 삭제하거나 복제 세트에서 모든 테이블을 삭제합니다.

SELECT pglogical.drop_replication_set('<replication set name>')

SELECT pglogical.replication_set_remove_table('<replication set name>','<table name>')

양방향 복제

다운타임 없이 전환하거나 계획되지 않은 데이터 변경으로 인해 데이터가 손실되지 않게 하려면 양방향 복제를 사용해야 합니다. 양방향 복제를 구현할 때는 동시에 두 노드에 대한 쓰기 액세스를 방지하는 엄격한 제어가 마련되어 있지 않은 한 충돌 해결을 고려하세요.

다음 pglogical.conflict_resolution 설정을 사용하여 충돌 해결 구성을 설정할 수 있습니다.

error: 충돌이 감지되면 구독자가 중지됩니다.
apply_remote: 구독자 데이터베이스의 데이터와 관계없이 항상 수신되는 변경사항을 적용합니다. 기본 설정입니다.
keep_local: 충돌하는 수신 데이터를 항상 무시하고 변경사항 충돌을 삭제합니다.
last_update_wins: 최신 커밋 타임스탬프가 있는 데이터 버전이 커밋된 데이터입니다.
first_update_wins: 가장 오래된 타임스탬프가 있는 데이터 버전이 커밋된 데이터입니다.

양방향 복제를 설정하려면 복제가 양방향으로 진행되도록 제공업체와 구독자를 설정합니다. 원래 구독자도 원래 제공업체와 동일한 복제 세트를 사용하는 제공업체가 됩니다. 테이블 생성 및 PostgreSQL용 AlloyDB 제공업체 데이터베이스의 기본 복제 세트에 추가를 참조하여 초기 제공업체 데이터베이스의 원래 복제 세트를 복제하는 복제 세트를 만듭니다.

기존 제공업체에서 새 구독자를 추가해야 합니다. AlloyDB Omni 구독자 데이터베이스에서 노드 및 구독 만들기를 참조하여 명령 pglogical.create_subscription의 synchronize_data 파라미터가 false로 설정되어 있는지 확인하면서 새 구독자를 만듭니다. 이렇게 하면 데이터의 초기 테이블 복사가 방지됩니다.

pglogical 복제를 사용한 장애 조치

장애 조치는 어떤 이유로든 제공업체 데이터베이스를 사용할 수 없게 될 때 발생하며 애플리케이션을 전환하여 구독자 데이터베이스를 사용해야 합니다.

중복 데이터가 우발적으로 장애 조치된 구독자 데이터베이스에 적용되지 않게 하려면 구독을 사용 중지해야 합니다. 이렇게 하면 제공업체가 다시 사용 가능해질 때 복원된 제공업체의 변경사항이 실수로 적용되지 않습니다.

구독자 test_sub_1을 중지합니다.

SELECT pglogical.alter_subscription_disable(`test_sub_1`);

상태가 disabled로 설정되어 있는지 확인합니다.

SELECT pglogical.show_subscription_status('test_sub_1');