LoginSignup
0
0

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 5 years have passed since last update.

@szit(Suzu Ito)

CouchDB レプリケーションにおける衝突を再現するスクリプト

Last updated at Posted at 2014-12-31

CouchDB におけるレプリケーション。
衝突しているドキュメントを取得するまでを地道に試してみた。

やってみて分かったこと。

  • push、pull レプリケーションタスクが完了するまで待つ、という処理を書かなければならない。
% # --------------------------- 
% # --------------------------- 
% # db の初期化。
% # --------------------------- 
% # --------------------------- 
% curl -X DELETE -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card
% # response ---> {"ok":true}
% # status ---> 200

% curl -X DELETE -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.58.2:5984/business_card
% # response ---> {"ok":true}
% # status ---> 200

% curl -X PUT -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card
% # response ---> {"ok":true}
% # status ---> 201

% curl -X PUT -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.58.2:5984/business_card
% # response ---> {"ok":true}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # ドキュメント bob を作成する。
% # --------------------------- 
% # --------------------------- 
% curl -X PUT -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"number":"000-0000-0000","email":"bob@hoge.com"} http://192.168.57.2:5984/business_card/bob
% # response ---> {"ok":true,"id":"bob","rev":"1-67a3d3f4e49023faf4865a65fb2157ad"}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # bob をレプリケーションする。
% # --------------------------- 
% # --------------------------- 
% curl -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"source":"business_card","target":"http://192.168.58.2:5984/business_card","create_target":true} http://192.168.57.2:5984/_replicator
% # response ---> {"ok":true,"id":"e59d9a9247a97492e1ca9ae04801d971","rev":"1-5d0e76b1f0a1e4e0973c3e225d65b3be"}
% # status ---> 201

% curl -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"source":"http://192.168.58.2:5984/business_card","target":"business_card","create_target":true} http://192.168.57.2:5984/_replicator
% # response ---> {"ok":true,"id":"e59d9a9247a97492e1ca9ae04801e7b9","rev":"1-0d931d3c5e54ea24fefc380994a5f4d3"}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # 現在の状態を確認する。
% # --------------------------- 
% # --------------------------- 
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card/bob?a=b&c=d
{"_id":"bob","_rev":"1-67a3d3f4e49023faf4865a65fb2157ad","number":"000-0000-0000","email":"bob@hoge.com"}
% # status ---> 200

% # この時点で以下のようなリビジョンツリーである。
% # 
% # 192.168.57.2/business_card/bob
% # 1-67a3d3f4e49023faf4865a65fb2157ad
% # 
% # 192.168.58.2/business_card/bob
% # 1-67a3d3f4e49023faf4865a65fb2157ad
% # --------------------------- 
% # --------------------------- 
% # ドキュメント bob の v2a リビジョンを作成する。
% # --------------------------- 
% # --------------------------- 
% curl -X PUT -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"_id":"bob","_rev":"1-67a3d3f4e49023faf4865a65fb2157ad","number":"111-1111-1111","email":"bob@hoge.com"} http://192.168.57.2:5984/business_card/bob
% # response ---> {"ok":true,"id":"bob","rev":"2-b941314df69d8fe88067373460759e59"}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # 現在の状態を確認する。
% # --------------------------- 
% # --------------------------- 
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card/bob?a=b&c=d
% # response ---> {"_id":"bob","_rev":"2-b941314df69d8fe88067373460759e59","number":"111-1111-1111","email":"bob@hoge.com"}
% # status ---> 200

% # --------------------------- 
% # --------------------------- 
% # ドキュメント bob の v2b リビジョンを作成する。
% # --------------------------- 
% # --------------------------- 
% curl -X PUT -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"_id":"bob","_rev":"1-67a3d3f4e49023faf4865a65fb2157ad","number":"000-0000-0000","email":"bob@fuga.com"} http://192.168.58.2:5984/business_card/bob
% # response ---> {"ok":true,"id":"bob","rev":"2-3b416dfe57b51349bdacbc654efcfadc"}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # 現在の状態を確認する。
% # --------------------------- 
% # --------------------------- 
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.58.2:5984/business_card/bob?a=b&c=d
% # response ---> {"_id":"bob","_rev":"2-3b416dfe57b51349bdacbc654efcfadc","number":"000-0000-0000","email":"bob@fuga.com"}
% # status ---> 200

% # この時点で以下のようなリビジョンツリーである。
% # 
% # 192.168.57.2/business_card/bob
% # 1-67a3d3f4e49023faf4865a65fb2157ad --- 2-b941314df69d8fe88067373460759e59
% # 
% # 192.168.58.2/business_card/bob
% # 1-67a3d3f4e49023faf4865a65fb2157ad --- 2-3b416dfe57b51349bdacbc654efcfadc
% # --------------------------- 
% # --------------------------- 
% # 以下のレプリケーション処理において衝突が発生する。
% # --------------------------- 
% # --------------------------- 
% curl -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"source":"business_card","target":"http://192.168.58.2:5984/business_card","create_target":true} http://192.168.57.2:5984/_replicator
% # response ---> {"ok":true,"id":"e59d9a9247a97492e1ca9ae04801f1fd","rev":"1-5d0e76b1f0a1e4e0973c3e225d65b3be"}
% # status ---> 201

% curl -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -d {"source":"http://192.168.58.2:5984/business_card","target":"business_card","create_target":true} http://192.168.57.2:5984/_replicator
% # response ---> {"ok":true,"id":"e59d9a9247a97492e1ca9ae04801fad3","rev":"1-0d931d3c5e54ea24fefc380994a5f4d3"}
% # status ---> 201

% # --------------------------- 
% # --------------------------- 
% # 衝突しているリビジョン情報を含めて、ドキュメントを取得する。
% # --------------------------- 
% # --------------------------- 
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card/bob?conflicts=true
% # response ---> {"_id":"bob","_rev":"2-b941314df69d8fe88067373460759e59","number":"111-1111-1111","email":"bob@hoge.com"}
% # status ---> 200

% # 衝突が発生したとしても、ドキュメントの最新版は、CouchDB 内の決定的なアルゴリズムにより一意に定まる。
% # 最新版(winner)はこちら:2-b941314df69d8fe88067373460759e59
% # しかし、実際には 最新版(winner) ではない、隠されたリビジョン(losers)が存在する。
% # 隠されたリビジョン(losers)が存在する。
% # 隠されたリビジョン(losers)はこちら:undefined
% # --------------------------- 
% # --------------------------- 
% # もうかたほうのインスタンスでもまったく同じ結果となる。 
% # --------------------------- 
% # --------------------------- 
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.58.2:5984/business_card/bob?conflicts=true
% # response ---> {"_id":"bob","_rev":"2-b941314df69d8fe88067373460759e59","number":"111-1111-1111","email":"bob@hoge.com","_conflicts":["2-3b416dfe57b51349bdacbc654efcfadc"]}
% # status ---> 200

% # 最新版(winner)はこちら:2-b941314df69d8fe88067373460759e59
% # 隠されたリビジョン(losers)はこちら:["2-3b416dfe57b51349bdacbc654efcfadc"]
% # この時点で以下のようなリビジョンツリーである。
% # 
% # 192.168.57.2/business_cardbob
% # 1-67a3d3f4e49023faf4865a65fb2157ad -+- 2-b941314df69d8fe88067373460759e59
% #                                     |  
% #                                     +- 2-3b416dfe57b51349bdacbc654efcfadc
% # 
% # 192.168.58.2/business_cardbob
% # 1-67a3d3f4e49023faf4865a65fb2157ad -+- 2-b941314df69d8fe88067373460759e59
% #                                     |  
% #                                     +- 2-3b416dfe57b51349bdacbc654efcfadc
% # 
% # --------------------------- 
% # --------------------------- 
% # リビジョンツリーの葉ノードだけを取得することができる。
% # --------------------------- 
% # --------------------------- 
% # open_revs オプションは、他のオプションと併用できない。
% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.57.2:5984/business_card/bob?open_revs=all
% # response ---> [{"ok":{"_id":"bob","_rev":"2-b941314df69d8fe88067373460759e59","number":"111-1111-1111","email":"bob@hoge.com"}}]
% # status ---> 200

% curl -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' http://192.168.58.2:5984/business_card/bob?open_revs=all
% # response ---> [{"ok":{"_id":"bob","_rev":"2-3b416dfe57b51349bdacbc654efcfadc","number":"000-0000-0000","email":"bob@fuga.com"}},{"ok":{"_id":"bob","_rev":"2-b941314df69d8fe88067373460759e59","number":"111-1111-1111","email":"bob@hoge.com"}}]
% # status ---> 200
0
0
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
0
0

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?