本文不提供 mongoDB和 ElasticSearch 的环境搭建！

前提

首先安装好 python3 的环境，安装教程见链接

安装 mongo-connector 和 elastic2-doc-manager

  1. pip install elastic2-doc-manager[elastic5]
  2. #等待安装完毕
  3. pip install mongo-connector[elastic5]

测试同步数据

输入如下命令同步 momgoDB里的testdb.book数据到ElasticSearch

  1. mongo-connector -m 192.168.110.128:27001 -n appdb.book -t 192.168.110.128:9200 -d elastic2_doc_manager

如果mongoDB 配置了密码，使用下面命令

  1. mongo-connector -m 192.168.110.128:27001 -a admin -p 123456 -n appdb.book -t 192.168.110.128:9200 -d elastic2_doc_manager

同步成功后，执行下面命令可验证

  1. curl http://192.168.110.128:9200/_cat/indices?v
  2. #输出如下
  3. health status index        uuid                   pri rep docs.count docs.deleted store.size pri.store.size
  4. green  open   appdb        y9__zuFmR9e6ZhLDXvlBjg   5   1        500            0    285.5kb        142.7kb
  5. green  open   mongodb_meta l7hDHYUGSECTr50jWzJIdQ   5   1        500            0     79.8kb         37.8kb

重要参数说明

  1. -m   mongodb_host:port    —— 数据源地址，mongodb数据库地址。
  2. -t   target_host:port     —— 数据目的地地址，elasticsearch集群地址。
  3. -d   xxx_doc_manager      —— 数据目的地的document类型，elastic2_doc_manager或elastic_doc_manager。 
  4. -n   db.collection ...    —— 待同步的数据库及其collection。默认同步所有数据库。
  5. -a   admin-username       —— admin用户名
  6. -p   password             —— 密码
  7. 更过参数，请通过mongo-connector -h 命令查看