測試ogg中斷之後,重新同步操作
ogg 修改 trail 檔案大小
alter extract pump1 etrollover
send extract ext1, rollover
在某些情況下,對於乙個已經running的ogg程序,對已同步的資料(正確的同步或者錯誤的同步)做修改,修改完之後,需要保持乙個一致點,從一致點繼續同步。
這是需要人工干涉產生乙個新的extract trail檔案,data pump和replicat程序都從該新檔案中讀取資料。
etrollover可以再重新啟動抽取程序時自動生成乙個新的trail檔案。
同時會提示並且必須指定datapump和replicat程序的seqno序號。
注意:源端的trail檔案序列號可能和目標端的trail檔案序列號不一致。所以在指定extseqno時,需要根據各自dirdat目錄下當前的序號而定。
ggsci (***ba) 87> stop ext1
sending stop request to extract ext1 ...
request processed.
在每個目標系統上,send replicat使用該status選項發出該命令,直到它顯示狀態「 at eof」,表示它已完成處理蹤跡中的所有資料。這必須在所有目標系統上完成,直到所有replicat程序返回「 at eof。」
ggsci (***ba) 50> send replicat rep1 status
sending status request to replicat rep1 ...
current status: at eof
sequence #: 8
rba: 1215
0 records in current transaction
--源端執行
ggsci (***ba) 89> stop pump1
sending stop request to extract pump1 ...
request processed.
--目標端執行
ggsci (***ba) 51> stop rep1
sending stop request to replicat rep1 ...
request processed.
提示要必須指定datapump和replicat程序的seqno序號
ggsci (***ba) 91> alter extract ext1 etrollover
extract altered.
ggsci (***ba) 92> alter extract pump1 etrollover
extract altered.
ggsci (***ba) 93> start ext1
sending start request to manager ...
extract ext1 starting
--源端執行
ggsci (***ba) 95> alter extract pump1,thread 1,extseqno 15,extrba 0
extract altered.
--目標端執行
ggsci (***ba) 54> alter replicat rep1, extseqno 13, extrba 0
replicat altered.
--源端執行
ggsci (***ba) 96> start pump1
sending start request to manager ...
extract pump1 starting
--目標端執行
ggsci (***ba) 55> start rep1
sending start request to manager ...
replicat rep1 starting
檢視pump,replicat 程序從新的trail檔案同步資料
ggsci (***ba) 98> info pump1
extract pump1 last started 2018-06-18 18:15 status running
checkpoint lag 00:00:00 (updated 00:00:09 ago)
log read checkpoint file ./dirdat/et000015
first record rba 1016
ggsci (***ba) 64> info rep1
replicat rep1 last started 2018-06-18 18:18 status running
checkpoint lag 00:00:00 (updated 00:00:03 ago)
log read checkpoint file ./dirdat/et000013
first record rba 0
--源端刪除一條資料
sql> delete from test where id=2005;
1 row deleted.
sql> commit;
commit complete.
sql> select count(*) from test;
count(*)
----------
999002
--目標端檢視資料
sql> select count(*) from test;
count(*)
----------
999002
ggsci (***ba) 104> info pump1
extract pump1 last started 2018-06-18 18:20 status running
checkpoint lag 00:00:00 (updated 00:00:03 ago)
log read checkpoint file ./dirdat/et000015
2018-06-18 18:21:37.000000 rba 1142
ggsci (***ba) 65> info rep1
replicat rep1 last started 2018-06-18 18:18 status running
checkpoint lag 00:00:00 (updated 00:00:05 ago)
log read checkpoint file ./dirdat/et000013
2018-06-18 18:21:34.043379 rba 1181
ggsci (***ba) 106> send extract ext1, rollover
sending rollover request to extract ext1 ...
request processed.
ggsci (***ba) 107> send extract pump1, rollover
sending rollover request to extract pump1 ...
request processed.
ggsci (***ba) 108> info pump1
extract pump1 last started 2018-06-18 18:20 status running
checkpoint lag 00:00:00 (updated 00:00:03 ago)
log read checkpoint file ./dirdat/et000016
2018-06-18 18:21:37.000000 rba 1016
ggsci (***ba) 66> info rep1
replicat rep1 last started 2018-06-18 18:18 status running
checkpoint lag 00:00:00 (updated 00:00:09 ago)
log read checkpoint file ./dirdat/et000014
2018-06-18 18:21:34.043379 rba 1090
--源端操作
sql> delete from test where id=2006;
1 row deleted.
sql> commit;
commit complete.
sql> select count(*) from test;
count(*)
----------
999001
--目標端檢視資料同步
sql> select count(*) from test;
count(*)
----------
999001
scrapy User Agent切換的兩種方法
第一種是使用在setting裡面設定middlewares。這個網上有較多版本,我覺得這個版本寫的比較好,也比較新。有的舊版本還在使用scrapy.contrib.middleware。scrapy新的版本裡已經不用contrib了,直接寫scrapy.middleware就可以了。note 另外為...
Redhat nis client兩種接入方式
redhat nis client兩種接入方式 在redhat上nis client有兩種方式接入nis伺服器 etc nsswitch.conf和system config authentication 通過 etc nsswitch.conf的方式使用者只能通過yppasswd進行修改密碼且無法...
python threading 兩種建立方式
作用 建立在thread模組之上,可以更容易地管理多個執行執行緒。通過使用執行緒,程式可以在同乙個程序空間併發地執行多個操作。threading模組建立在thread的底層特性基礎上,可以更容易地完成執行緒處理。1 呼叫函式 要使用thread,最簡單的方法就是用乙個目標函式例項化乙個thread物...