복제 슬롯 및 게시 만들기

이 문서에서는 AlloyDB Omni에서 논리적 복제 슬롯을 만드는 방법을 설명합니다. PostgreSQL에서 논리 복제는 게시자 데이터베이스에서 데이터 변경사항을 데이터베이스 또는 기타 애플리케이션일 수 있는 하나 이상의 구독자로 복사하는 방법입니다. AlloyDB Omni Kubernetes 연산자를 사용하여 만든 클러스터에서 논리적 복제를 사용 설정하고 구성할 수 있습니다.

스트리밍된 변경사항은 개별 행 업데이트, 삽입 또는 삭제일 수 있습니다. 구독자는 지속적인 연결을 보장하는 고유한 복제 슬롯을 통해 게시자에 연결됩니다. 영구 연결은 데이터 스트리밍 상태를 유지하므로 중단이 발생하면 중단된 지점부터 스트리밍이 재개됩니다.

PostgreSQL의 논리 복제에 대한 자세한 내용은 논리 복제를 참고하세요.

이 페이지의 코드 스니펫은 값을 자체 AlloyDB Omni 리소스의 값으로 대체하여 모델로 사용할 수 있는 예시입니다.

시작하기 전에

• Kubernetes에 Omni Operator를 설치합니다.

게시자 클러스터 만들기

복제 슬롯을 만들기 전에 논리적 복제가 사용 설정된 게시자 클러스터를 만들어야 합니다. DBCluster 매니페스트에서 wal_level 매개변수를 logical로 설정해야 합니다.

논리 복제가 사용 설정된 게시자 데이터베이스 클러스터를 만들려면 다음 매니페스트를 적용하세요.

  apiVersion: v1
  kind: Secret
  metadata:
    name: db-pw-DB_CLUSTER_NAME
    namespace: DB_CLUSTER_NAMESPACE
  type: Opaque
  data:
    DB_CLUSTER_NAME: "ENCODED_PASSWORD"
  ---
  apiVersion: alloydbomni.dbadmin.goog/v1
  kind: DBCluster
  metadata:
    name: DB_CLUSTER_NAME
    namespace: DB_CLUSTER_NAMESPACE
  spec:
    databaseVersion: "ALLOYDB_OMNI_VERSION"
    spec:
    availability:
      numberOfStandbys: 1
    primarySpec:
      parameters:
        wal_level: "logical"
      adminUser:
        passwordRef:
          name: db-pw-DB_CLUSTER_NAME
      resources:
        cpu: CPU_COUNT
        memory: MEMORY_SIZE
        disks:
        - name: DataDisk
          size: DISK_SIZE

다음을 바꿉니다.

• DB_CLUSTER_NAME: 이 데이터베이스 클러스터의 이름입니다(예: publisher).

• DB_CLUSTER_NAMESPACE(선택사항): 데이터베이스 클러스터를 만들려는 네임스페이스입니다(예: publisher-namespace).

• ENCODED_PASSWORD: 기본 postgres 사용자 역할의 데이터베이스 로그인 비밀번호로, base64 문자열로 인코딩됩니다(예: ChangeMe123의 경우 Q2hhbmdlTWUxMjM=).

• ALLOYDB_OMNI_VERSION: AlloyDB Omni 버전, 15.7.0 이상

• CPU_COUNT: 이 데이터베이스 클러스터의 각 데이터베이스 인스턴스에서 사용할 수 있는 CPU 수입니다.

• MEMORY_SIZE: 이 데이터베이스 클러스터의 데이터베이스 인스턴스당 메모리 양입니다. CPU당 8GB로 설정하는 것이 좋습니다. 예를 들어 이 매니페스트에서 이전에 cpu를 2로 설정한 경우 memory를 16Gi로 설정하는 것이 좋습니다.

• DISK_SIZE: 데이터베이스 인스턴스당 디스크 크기입니다(예: 10Gi).

복제 슬롯 만들기

게시자 클러스터를 만든 후 게시자 클러스터에서 Replication 리소스를 사용하여 논리 복제 슬롯을 만들 수 있습니다. 각 Replication 리소스는 해당 데이터베이스 클러스터 리소스와 연결됩니다. 데이터베이스 클러스터에는 연결된 논리적 복제 리소스가 여러 개 있을 수 있습니다.

게시자 클러스터에서 복제 슬롯을 구성하려면 다음 매니페스트를 적용하세요.

$ cat << EOF | kubectl apply -f -
apiVersion: v1
kind: Secret
metadata:
  name: USER_PASSWORD_SECRET_NAME
  namespace: USER_PASSWORD_SECRET_NAMESPACE
type: Opaque
---
apiVersion: alloydbomni.dbadmin.goog/v1
kind: Replication
metadata:
  name: REPLICATION_NAME
  namespace: NAMESPACE
spec:
  dbcluster:
    name: DB_CLUSTER_NAME
  upstream:
    logicalReplication:
      pluginName: DECODER_PLUGIN
      databaseName: DATABASE_NAME
    applicationName: APPLICATION_NAME
    replicationSlotName: REPLICATION_SLOT_NAME
    synchronous: "REPLICATION_MODE"
    username: APPLICATION_USER
    password:
      name: USER_PASSWORD_SECRET_NAME
      namespace: USER_PASSWORD_SECRET_NAMESPACE
EOF

다음을 바꿉니다.

• REPLICATION_NAME: 이 Replication 리소스의 이름입니다(예: replication-1).
• NAMESPACE: 이 Replication 리소스의 Kubernetes 네임스페이스입니다. 데이터베이스 클러스터의 네임스페이스와 일치해야 합니다.
• DB_CLUSTER_NAME: 데이터베이스 클러스터의 이름입니다. 데이터베이스 클러스터를 만들 때 할당했습니다.
• DECODER_PLUGIN: 논리 복제에 사용할 디코딩 플러그인(예: pgoutput)으로 설정합니다. 다양한 디코딩 플러그인에 대한 자세한 내용은 출력 플러그인을 참고하세요.
• DATABASE_NAME: 변경사항을 복제 슬롯으로 스트리밍하려는 데이터베이스의 이름으로 설정합니다. 데이터베이스가 게시자 클러스터에 이미 생성되어 있는지 확인합니다.
• APPLICATION_NAME (선택사항): 복제 슬롯에 연결할 애플리케이션 이름으로 설정됩니다. 스트리밍 모드가 동기식으로 설정된 경우 이 필드는 필수입니다.
• REPLICATION_MODE (선택사항): 비동기 복제의 경우 false로 설정합니다. 동기 복제를 사용 설정하되 속도는 희생하려면 이 값을 true로 설정합니다. 명시적으로 설정하지 않으면 기본값은 false입니다.
• REPLICATION_SLOT_NAME: 생성되고 구독자가 사용할 복제 슬롯의 이름입니다(예: logicalrepltestslot).
• REPLICATION_USER (선택사항): 복제 슬롯에 연결하는 사용자의 이름입니다. 복제 사용자를 설정하는 경우 보안 비밀 이름, 네임스페이스, 비밀번호를 설정해야 합니다.
• USER_PASSWORD_SECRET_NAME (선택사항): 애플리케이션 사용자의 Kubernetes 보안 비밀 이름입니다. 애플리케이션 사용자가 설정된 경우 필수입니다.
• USER_PASSWORD_SECRET_NAMESPACE (선택사항): 애플리케이션 사용자의 Kubernetes 보안 비밀이 있는 네임스페이스입니다. 애플리케이션 사용자가 설정된 경우 필수입니다.

복제 슬롯 상태 보기

복제 슬롯의 상태를 확인하려면 다음 명령어를 실행합니다.

kubectl get replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACE -oyaml

status 필드와 기타 세부정보가 응답에 포함됩니다.

apiVersion: alloydbomni.dbadmin.goog/v1
kind: Replication
metadata:
  name: REPLICATION_NAME
  namespace: NAMESPACE
...
...
status:
  conditions:
  - lastTransitionTime: "2025-01-25T06:49:25Z"
    message: Ready for replication
    reason: Ready
    status: "True"
    type: Ready
  - lastTransitionTime: "2025-01-25T06:49:25Z"
    message: Replication slot is not being used
    reason: Unhealthy
    status: "False"
    type: Healthy
  observedGeneration: 2
  upstream:
    host: DATABASE_ENDPOINT
    password:
      name: USER_PASSWORD_SECRET_NAME
      namespace: USER_PASSWORD_SECRET_NAMESPACE
    port: DATABASE_PORT
    replicationSlotName: REPLICATION_SLOT_NAME
    username: APPLICATION_USER

DATABASE_ENDPOINT에는 데이터베이스에 연결하는 데 사용하는 IP 주소가 표시됩니다. READY 열의 상태 TRUE은 슬롯이 스트리밍할 준비가 되었음을 나타냅니다. 구독자 DBCluster 또는 애플리케이션이 복제 슬롯에 연결되면 HEALTHY 열의 상태가 TRUE로 변경됩니다.

게시자 클러스터 구성

1. 필요한 포드를 찾습니다.

   $ kubectl get pod -l "alloydbomni.internal.dbadmin.goog/dbcluster=DB_CLUSTER_NAME, alloydbomni.internal.dbadmin.goog/task-type=database, dbs.internal.dbadmin.goog/ha-role=Primary"
   

2. psql을 사용하여 게시자 클러스터의 기본 포드에 연결합니다.

   psql -h IP_ADDRESS -U USERNAME -d DATABASE_NAME

   다음을 바꿉니다.

   • IP_ADDRESS: 게시자 클러스터의 기본 포드 IP 주소입니다.
   • USERNAME: 데이터베이스의 postgres 사용자입니다.
   • DATABASE_NAME: 구독자가 구독하려는 데이터베이스입니다.

3. 복제 리소스에 지정된 DATABASE_NAME가 없으면 데이터베이스를 만듭니다.

   CREATE DATABASE DATABASE_NAME;
   

4. 선택사항: 테스트 목적으로 데이터베이스에 테이블을 추가하고 데이터를 삽입합니다. 이 데이터를 사용하여 게시자에서 구독자로의 데이터 복제를 관찰할 수 있습니다.

   $ psql -h localhost -U postgres DATABASE_NAME
   customer=# CREATE TABLE TABLE_NAME(
   customer(#    ID INT PRIMARY KEY     NOT NULL,
   customer(#    NAME           TEXT    NOT NULL,
   customer(#    AGE            INT     NOT NULL,
   customer(#    SALARY         REAL
   customer(# );
   CREATE TABLE
   customer=# INSERT INTO TABLE_NAME (ID,NAME,AGE,SALARY) VALUES
   customer-# (1, 'Quinn', 25, 65000.00),
   customer-# (2, 'Kim', 22, 72250.00),
   customer-# (3, 'Bola', 31, 53000.00),
   customer-# (4, 'Sasha', 33, 105000.00),
   customer-# (5, 'Yuri', 27, 85000.00);
   INSERT 0 5
   customer=# \dt
             List of relations
   Schema |  Name   | Type  |  Owner
   --------+---------+-------+----------
   public | company | table | postgres
   (1 row)
   
   customer=# select * from TABLE_NAME;
   id | name  | age | salary
   ----+-------+-----+--------
     1 | Quinn  |  25 |  65000
     2 | Kim  |  22 |  72250
     3 | Bola   |  31 |  53000
     4 | Sasha |  33 | 105000
     5 | Yuri |  27 |  85000
   (5 rows)
   

   TABLE_NAME을 데이터를 저장하고 구독자가 구독하는 테이블로 바꿉니다.

5. 권한을 부여합니다.

   GRANT SELECT ON ALL TABLES IN SCHEMA public TO REPLICATION_USER;
   GRANT USAGE ON SCHEMA public TO REPLICATION_USER;
   ALTER DEFAULT PRIVILEGES IN SCHEMA public
   GRANT SELECT ON TABLES TO REPLICATION_USER;
   

6. 다음 명령어를 실행하여 게시를 만듭니다.

   CREATE PUBLICATION PUBLICATION_NAME;
   ALTER PUBLICATION PUBLICATION_NAME ADD TABLE TABLE_NAME;
   

   다음을 바꿉니다.

   • PUBLICATION_NAME: 구독자가 구독하는 데 사용할 게시 이름입니다.

게시를 만든 후 논리적 복제를 위해 구독자 클러스터를 설정하거나 복제를 시작하도록 애플리케이션을 구성할 수 있습니다.

제한사항

• 복제 슬롯 구성 업데이트는 지원되지 않습니다. 구성을 업데이트하려면 복제 슬롯을 삭제하고 업데이트된 구성으로 다시 만듭니다.

  복제 슬롯을 삭제하려면 다음 명령어를 실행합니다.

  kubectl delete replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACE
  

• 게시자 데이터베이스에서만 논리적 복제 슬롯을 구성할 수 있습니다. 복제 API는 논리적 복제 구독자 DBCluster 또는 애플리케이션을 지원하지 않습니다.

• 복제 객체에서 참조하는 데이터베이스 클러스터가 고가용성으로 구성된 경우 장애 조치 후 승격된 대기 서버에서 논리 복제 슬롯이 다시 생성됩니다. 복제 슬롯이 다시 생성되면 슬롯의 스트림 위치를 더 이상 사용할 수 없으며 스트림을 구독하는 모든 애플리케이션은 스트림을 다시 연결하고 재생해야 합니다.

다음 단계

• 논리 복제를 위한 구독자 클러스터 구성