转自:https://blog.csdn.net/ACxlm/article/details/76473537
1安装必要工具包
(1)安装 mongo-connector
pip install mongo-connector
(2)安装 elastic2-doc-manager(根据ElasticSearch版本选择安装)
https://github.com/mongodb-labs/elastic2-doc-manager
2.MongoDB开启复制集
注:在此项实时同步实验中,在开启复制集之前,应确保数据清空状态;
若保留大量旧数据,则在旧数据之上开启复制集的话,后续同步时会将旧数据快速且疯狂地写入ElasticSearch,造成网络堵塞报错(报错:“连接被对端重置”)
(1)通过制定--replSet选项来启动MongoDB。(此操作之前,确保MongoDB已经关闭)
基本语法如下:
./mongod --port "PORT" --dbpath "YOUR_DB_DATA_PATH" --replSet "REPLICA_SET_INSTANCE_NAME"
实例:./mongod --port 27017 --dbpath "/data/rs0" --replSet rs0
(2)启动MongoDB客户端并连接副本集成员
进入Mongodb/bin目录下:运行mongodb.exe
(3)开启同步
在bin目录下:mongo-connector -m localhost:27017 -t localhost:9200 -d elastic2_doc_manager
参数:(1)-m MongoDB的地址和端口,默认为27017
(2)-t ES的地址和端口,默认为9200
(3)doc manager的名称,2.x版本为: elastic2-doc-manager
效果图: