PostgreSQL 10 Logical Replication

作者： -


發佈端 Publisher
login as: root
root@192.168.235.10's password:
Last login: Mon Jun 11 10:14:09 2018 from 192.168.235.1
[root@vsource ~]# su - postgres
Last login: Mon Jun 11 11:14:06 CST 2018 on pts/1
-bash-4.2$ psql
psql (10.4)
Type "help" for help.

postgres=# ALTER SYSTEM SET listen_addresses to '*';
ALTER SYSTEM
postgres=# ALTER SYSTEM SET wal_level = 'logical';
ALTER SYSTEM
postgres=# SHOW max_wal_senders;
 max_wal_senders
-----------------
 10
(1 row)

postgres=# SHOW max_replication_slots;
 max_replication_slots
-----------------------
 10
(1 row)
postgres-# \q
-bash-4.2$ /usr/pgsql-10/bin/pg_ctl -D $PGDATA restart
waiting for server to shut down.... done
server stopped
waiting for server to start....2018-06-11 15:04:57.851 CST [3618] LOG:  listening on IPv4 address "0.0.0.0", port 5432
2018-06-11 15:04:57.851 CST [3618] LOG:  listening on IPv6 address "::", port 5432
2018-06-11 15:04:57.853 CST [3618] LOG:  listening on Unix socket "/var/run/postgresql/.s.PGSQL.5432"
2018-06-11 15:04:57.856 CST [3618] LOG:  listening on Unix socket "/tmp/.s.PGSQL.5432"
2018-06-11 15:04:57.869 CST [3618] LOG:  redirecting log output to logging collector process
2018-06-11 15:04:57.869 CST [3618] HINT:  Future log output will appear in directory "log".
 done
server started
-bash-4.2$ psql
psql (10.4)
Type "help" for help.

postgres=# CREATE TABLE test(
postgres(# id int primary key,
postgres(# txt text
postgres(# );
CREATE TABLE

Insert 10筆資料
postgres=# INSERT INTO test SELECT generate_series(1,10), random()::text;
INSERT 0 10
postgres=# CREATE PUBLICATION testpub FOR TABLE test
postgres-# WITH (publish = 'insert, update, delete');
CREATE PUBLICATION
postgres=# select * from pg_publication_tables ;
 pubname | schemaname | tablename
---------+------------+-----------
 testpub | public     | test
(1 row)

postgres=# select * from pg_publication;
 pubname | pubowner | puballtables | pubinsert | pubupdate | pubdelete
---------+----------+--------------+-----------+-----------+-----------
 testpub |       10 | f            | t         | t         | t
(1 row)

postgres=# select * from pg_stat_replication;
 pid | usesysid | usename | application_name | client_addr | client_hostname | c
ent_port | backend_start | backend_xmin | state | sent_lsn | write_lsn | flush_l
 | replay_lsn | write_lag | flush_lag | replay_lag | sync_priority | sync_state
-----+----------+---------+------------------+-------------+-----------------+--
---------+---------------+--------------+-------+----------+-----------+--------
-+------------+-----------+-----------+------------+---------------+------------
(0 rows)

查看目前table資料
postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
(10 rows)

再insert 10筆資料
postgres=# INSERT INTO test SELECT generate_series(11,20), random()::text;
INSERT 0 10
再查看table資料及到Subsciber查看table資料是否抄寫正常
postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
 11 | 0.233744856435806
 12 | 0.310788231901824
 13 | 0.854852778837085
 14 | 0.352138324640691
 15 | 0.329302508849651
 16 | 0.192081692628562
 17 | 0.719286013394594
 18 | 0.566931300330907
 19 | 0.843170332722366
 20 | 0.263836818281561
(20 rows)

再insert 1筆資料
postgres=# INSERT INTO test VALUES (21,'hello');
INSERT 0 1
再查看table資料及到Subsciber查看table資料是否抄寫正常
postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
 11 | 0.233744856435806
 12 | 0.310788231901824
 13 | 0.854852778837085
 14 | 0.352138324640691
 15 | 0.329302508849651
 16 | 0.192081692628562
 17 | 0.719286013394594
 18 | 0.566931300330907
 19 | 0.843170332722366
 20 | 0.263836818281561
 21 | hello
(21 rows)

postgres=#


訂閱端 Subscriber
login as: root
root@192.168.235.11's password:
Last login: Mon Jun 11 13:44:42 2018 from 192.168.235.1
[root@vsource ~]# su - postgres
Last login: Mon Jun 11 11:14:06 CST 2018 on pts/1
-bash-4.2$ psql
psql (10.4)
Type "help" for help.

postgres=# ALTER SYSTEM SET listen_addresses to '*';
ALTER SYSTEM
postgres=# ALTER SYSTEM SET wal_level = 'logical';
ALTER SYSTEM
postgres=# SHOW max_wal_senders;
 max_wal_senders
-----------------
 10
(1 row)

postgres=# SHOW max_replication_slots;
 max_replication_slots
-----------------------
 10
(1 row)

postgres=#\q
-bash-4.2$ /usr/pgsql-10/bin/pg_ctl -D $PGDATA restart
waiting for server to shut down.... done
server stopped
waiting for server to start....2018-06-11 15:37:53.710 CST [6101] LOG:  listening on IPv4 address "0.0.0.0", port 5432
2018-06-11 15:37:53.710 CST [6101] LOG:  listening on IPv6 address "::", port 5432
2018-06-11 15:37:53.712 CST [6101] LOG:  listening on Unix socket "/var/run/postgresql/.s.PGSQL.5432"
2018-06-11 15:37:53.714 CST [6101] LOG:  listening on Unix socket "/tmp/.s.PGSQL.5432"
2018-06-11 15:37:53.726 CST [6101] LOG:  redirecting log output to logging collector process
2018-06-11 15:37:53.726 CST [6101] HINT:  Future log output will appear in directory "log".
 done
server started
-bash-4.2$ psql
psql (10.4)
Type "help" for help.

postgres=# CREATE TABLE test(
postgres(# id int primary key,
postgres(# txt text
postgres(# );
CREATE TABLE

postgres=# CREATE SUBSCRIPTION testsub
CONNECTION 'host=192.168.235.10 dbname=postgres'
PUBLICATION testpub
WITH (copy_data='true',create_slot='true',
 enabled='true',synchronous_commit='off');
NOTICE:  created replication slot "testsub" on publisher
CREATE SUBSCRIPTION

確認資料抄寫正常
postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
(10 rows)

postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
 11 | 0.233744856435806
 12 | 0.310788231901824
 13 | 0.854852778837085
 14 | 0.352138324640691
 15 | 0.329302508849651
 16 | 0.192081692628562
 17 | 0.719286013394594
 18 | 0.566931300330907
 19 | 0.843170332722366
 20 | 0.263836818281561
(20 rows)

postgres=# select * from test;
 id |        txt
----+-------------------
  1 | 0.521709179040045
  2 | 0.865239345468581
  3 | 0.683285959996283
  4 | 0.528353065252304
  5 | 0.934886322356761
  6 | 0.918178070802242
  7 | 0.357960605528206
  8 | 0.336081576067954
  9 | 0.348159779794514
 10 | 0.722193683031946
 11 | 0.233744856435806
 12 | 0.310788231901824
 13 | 0.854852778837085
 14 | 0.352138324640691
 15 | 0.329302508849651
 16 | 0.192081692628562
 17 | 0.719286013394594
 18 | 0.566931300330907
 19 | 0.843170332722366
 20 | 0.263836818281561
 21 | hello
(21 rows)

postgres=#

留言

張貼留言

這個網誌中的熱門文章

MSSQL 瘦身 : 壓縮資料庫

作者： -
圖片
資料庫經過一段時間後，經常碰到的是空間管理的問題，尤其是資料量成長太快的情況下，例如一些稽核軟體，在蒐集異動事件 Log 的行為上，非預期的發現資料量成長快速，通常會設定資料保留多久的時間，然後定期做 Purge，在第一次做 Purge 後發現奇怪的事情是，資料庫檔案為何沒有變小。如果加上空間快不夠用的情況，會有種火燒屁股的感覺。 在執行大量 Delete 後，資料庫不會立即釋放出原本占用的空間，會保留給新增進來的資料，所以看到 MDF 檔案大小並沒有變小。此時我們可以做 壓縮資料庫 ( Shrink Database ) 的動作，此行為會釋放出占用的空間。執行步驟如下： A) 使用SSMS 選取 Database > 工作 > 壓縮 > 資料庫 檔案壓縮後的最大可用空間 N%，可自行調整。此範例為10% B) 使用指令 USE [ChangeAuditor] GO DBCC SHRINKDATABASE(N'ChangeAuditor', 10 ) GO 執行壓縮資料庫會同時壓縮 MDF 與 LDF 檔案，也可以只壓縮 MDF 或只壓縮 LDF，執行步驟： 選取 Database > 工作 > 壓縮 > 檔案 此畫面可以選擇 檔案(MDF) 或 記錄檔(LDF)。
閱讀完整內容

InTrust 自動幫您蒐集 AD 帳號的登入/登出紀錄，長時間保存並保護

作者： -
圖片
基於資訊安全的考量下，電腦主機、系統伺服器、個人電腦及系統操作行為等，這些行為均需要被記錄下來，我們稱之為 Log，這些 Log 不旦需要記錄下來，且要確保保留的時間夠長以便能夠在發生問題時得以查詢。但如何確保這些重要的 Log 並長時間保存並且受到保護而不被串改呢？我們今天要討論的重點在於AD帳號在任何主機上登入及登出的行為需要被記錄下來，並且確定儲存下來的資料是正確的，最重要的是能夠在這些大量的資料中快速查到資料 (搜尋快速是很重要的)。 如何記錄所有AD帳號在伺服器上登入登出的Log，其實 Windows 有內建此功能，只是要手動把這功能 Enable 起來。 步驟如下 開啟 群組原則管理 到 網域 | Domain.com | Domain Controllers 按右鍵，選擇編輯，會跳出一個警示訊息提醒你所做的修改會套用，按「是」進入編輯 編輯畫面 到 電腦設定 | 原則 | Windows 設定 | 安全性設定 | 本機原則 | 稽核原則 設定「稽核帳號登入事件」 勾選如下畫面，套用 接著是透過 InTrust 這個工具來蒐集 DC 上的 Log 在 InTrust 安裝完成後，開啟 InTrust Manager，透過以下設定步驟，將 DC 新增進來 選擇要蒐集的主機 → Domain Controller 接著安裝Agent，安裝完之後便會開始蒐集 Log。到這裡就算設定完成囉，步驟其實很簡單。 接著我們關心的就如何查找這些紀錄，InTrust 的工具 Repository Viewer 提供方便的搜尋功能，我們來看看能如何做搜尋，查到我們想要找的資料。 下圖就是 Repository Viewer 的畫面，左邊預設幫你分類了幾個項目，右邊則是顯示結果。 我們可以透過右邊畫面中的欄位進行搜尋，也可利用下方 Search Filter 頁籤新增搜尋的條件。 舉例：我想找到 admin01 這個帳號在所有伺服器上是否有做登入/登入的行為，如何查找？ 將 Who 這個條件勾選進來，畫面中下方便可輸入帳號當作搜尋的條件。 條件輸入後，剪輯右上方的 Go 開始進行搜尋，並將結果顯示出來。 點擊其中任一事...
閱讀完整內容

[SAP] 什麼是SAP? R/3 and S/4 是什麼意思? 差別在哪? (勿轉臉書)

作者： -
圖片
什麼是SAP? SAP 是 Systems Applications and Products in Data Processing 的縮寫。 R/3 and S/4 是什麼意思?  差別在哪? 如果我們去搜尋一下，可以發現更多的名詞。譬如 SAP R/2 SAP R/3 SAP ECC SAP Business Suite on HANA SAP S/4 HANA SAP S/4 HANA on cloud 白話來說，這些都是SAP ERP系統的版本，例如 基於SAP Main frame的ERP系統稱為SAP R/2。 在1997年，當SAP轉換到client server架構時，它被稱為SAP R/3 (3 Tier Architecture)。然後在一段時間內，它也被稱為MySAP business suite。 隨後SAP推出了6.0的新版本，並將其更名為ECC (ERP Core Component)。 在6.0之後，SAP推出了HANA數據庫，並將其ERP產品遷移到了HANA。然後ECC（ERP產品）被重命名為 S/4 HANA。 如果不想使用S/4 HANA 但仍想使用HANA的功能或提高效能，則可以選擇 SAP Business Suite on HANA，這是S/4 HANA 和 ECC 6 EHP7之間的版本。 S/4 HANA 也可以在雲上使用，它被稱為S/4 HANA cloud，它與 on premise 幾乎相同，但有一些限制 (Cloud)。 簡而言之，這些都是SAP ERP系統的不同版本，當然還有一些功能和架構上的演進。 版本推出的順序大約是這樣: SAP R/1 → SAP R/2 → SAP R/3 → SAP ECC → SAP Business Suite on HANA → SAP S/4 HANA → SAPS/4 HANA Cloud SAP S/4 HANA 於2015年2月發佈，是SAP公司繼SAP R/3和SAP ECC之後的第4代ERP產品。S/4 HANA主要有以下三個版本: Public Cloud Managed Cloud On-Premise SAP Business Su...
閱讀完整內容