Step1：安裝mongo-connector和elastic-doc-namager外掛

pip installmongo-connector

#Elasticsearch 1.x

pip install 'mongo-connector[elastic]'

#Elasticsearch 2.x

pip install 'mongo-connector[elastic2]'

#Elasticsearch 5.x

pip install 'mongo-connector[elastic5]'

Step2：設定MongoDB複製集（在搭建MongoDB複製集叢集時已經做好）

Step3：Elasticsearch與MongoDB開啟同步

# mongo-connector-m MongoDB_IP: MongoDB_port-tElasticsearch_IP: Elasticsearch_port-delastic2_doc_manager

 注：-m，-t分別為MongoDB和Elasticsearch的ip地址和埠

         -d：doc_manager的名稱，2.x版本為elastic_2_doc_manager

Step4：同步驗證：

（1）MongoDB端先插入資料

#Mongo建立資料庫（對應ES的Index）

rs0:PRIMARY>use test_index

switched to dbtest_index

#Mongo

rs0:PRIMARY>db.col_02.insert({name:"zhangsan", birth:"1964-03-21", sex:"man", company:"baidu"});

WriteResult({ "nInserted" : 1 })

rs0:PRIMARY>db.col_02.insert({name:"lisi", birth:"1954-03-21", sex:"man", company:"huawei"});

（2）視覺化檢視及ES端檢索驗證

# curl -XGEThttp://es_ip:9200/test_index/col_02/_search?pretty

{

"took":4,

"timed_out":false,

"_shards": {

"total":8,

"successful":8,

"failed":0

  },

"hits": {

"total":2,

"max_score":1.0,

"hits": [ {

"_index":"test_index",

"_type":"col_02",

"_id":"577b7d8ceb8e3dc2d1db12a9",

"_score":1.0,

"_source": {

"company":"huawei",

"name":"lisi",

"birth":"1954-03-21",

"sex":"man"

  }

  }, {

"_index":"test_index",

"_type":"col_02",

"_id":"577b7d4aeb8e3dc2d1db12a7",

"_score":1.0,

"_source": {

"company":"baidu",

"name":"zhangsan",

"birth":"1964-03-21",

"sex":"man"

  }

  } ]

  }

}