MongoDB数据导入到Elasticsearch搜索引擎？数据定时同步？

为了将MongoDB数据导入到Elasticsearch并实现数据的定时同步，你可以使用以下方法：

1. 使用Logstash：

Logstash是一个强大的数据处理管道平台，可以同时用于数据的导入和定时同步。

配置文件 (logstash.conf) 示例：

input {
  mongodb {
    uri => 'mongodb://<username>:<password>@<host>:<port>/<database>'
    placeholder_db_dir => '/opt/logstash-mongodb/'
    placeholder_db_name => 'logstash_sqlite.db'
    collection => '<collection_name>'
    batch_size => 5000
  }
}
 
filter {
  json {
    source => "message"
  }
}
 
output {
  elasticsearch {
    hosts => ["<es_host>:<es_port>"]
    index => "mongo_index"
    document_type => "mongo_type"
  }
}

运行Logstash:

bin/logstash -f logstash.conf

2. 使用Elasticsearch的自动发现功能：

如果你的Elasticsearch集群开启了自动发现功能，你可以直接通过Elasticsearch的自动发现功能来实现MongoDB数据的同步。

在MongoDB中配置一个变更流并使用Elasticsearch的自动发现功能来监听变更。

3. 使用Kibana的MongoDB应用：

Kibana提供了一个MongoDB应用，可以直接连接到MongoDB并实现数据的可视化和同步。

在Kibana中配置MongoDB连接，它会自动同步数据到Elasticsearch。

4. 使用定时任务（如Cron Job）：

你可以使用操作系统的定时任务（如Cron Job）来周期性地执行数据导入脚本。

脚本示例（使用mongoexport和elasticsearch-dump）:

#!/bin/bash

# 导出MongoDB数据
mongoexport --host=<mongodb_host> --port=<mongodb_port> --db=<database_name> --collection=<collection_name> --out=<output_file>.json

# 将数据导入到Elasticsearch
elasticsearch-dump --input=json --file=<output_file>.json --output=http://<elasticsearch_host>:<elasticsearch_port> --type=data

将此脚本添加到Cron Job，设置为定时运行。

确保你已经安装了mongoexport和elasticsearch-dump工具，并且根据你的环境配置好了MongoDB和Elasticsearch的连接信息。