Mongo-连接器不向Elasticsearch发送数据
Mongo-连接器是一种用于将MongoDB数据库与Elasticsearch搜索引擎进行集成的工具。它通过监听MongoDB的变更操作，并将这些变更数据传输到Elasticsearch，以实现数据的实时同步和搜索功能。
Mongo-连接器的主要功能和优势包括：
- 数据同步：通过实时监听MongoDB的数据变更操作，将数据同步到Elasticsearch，确保两个系统之间的数据一致性。
- 实时搜索：将MongoDB中的数据实时索引到Elasticsearch中，以支持高效的全文搜索和复杂查询。
- 高性能：Mongo-连接器使用高效的数据传输机制和索引技术，保证了数据同步的高性能和低延迟。
- 简化开发：通过Mongo-连接器，开发人员可以利用MongoDB和Elasticsearch各自的优势，简化开发过程，提高开发效率。
- 扩展性：Mongo-连接器支持水平扩展，可以处理大规模的数据同步和搜索需求。
应用场景：
- 实时日志分析：将MongoDB中的日志数据实时同步到Elasticsearch中，以便进行实时的日志分析和搜索。
- 商品搜索：将MongoDB中的商品数据同步到Elasticsearch中，实现高效的商品搜索和推荐功能。
- 智能推荐：通过将用户行为数据同步到Elasticsearch中，实现智能推荐系统，提供个性化的推荐内容。
腾讯云相关产品： 腾讯云提供了与Mongo-连接器类似的产品，用于实现MongoDB和Elasticsearch之间的数据同步和搜索功能。其中包括：
- TCR（Tencent Cloud Repository）：用于存储和管理Docker镜像，可以用于部署Mongo-连接器的相关镜像。
- TencentDB for MongoDB：提供高性能、可扩展的MongoDB数据库服务，与Mongo-连接器配合使用，实现数据同步和搜索功能。
- Tencent Cloud Elasticsearch：提供稳定可靠的Elasticsearch云服务，与Mongo-连接器配合使用，实现高效的数据搜索和分析。
更多详细信息，请参考腾讯云官网相关产品文档：
相关·内容
我想将Elasticsearch与我本地的MongoDB链接起来 以下是我的mongoconnector.json配置 {
"oplogFile": "/usr/local/etc/oplog.timestamp/mongoconnector.json 当我第一次运行查询时，我得到了POST日志，这意味着这是有效的 2021-04-30 21:12:59,677 [INFO] elasticsearch:83- POST http://127.0.0.1
浏览 20提问于2021-05-01得票数 0
我想使用mongoconnector在kubernetes中我找到了这个
问题是如何在kubernetes中运行
浏览 0提问于2019-03-17得票数 0
我正在尝试使用mongo连接器将数据从mongo导入到弹性搜索。我遵守了链接中的指示：我们遇到的问题是，数据没有从mongodb导入到弹性搜索。查询：
如何创建一次索引。
浏览 3提问于2015-06-01得票数 2
ElasticSearch.提供了一个连接器，用于集成从数据库到目标的数据，例如Solr我使用这个连接器将数据从Mongo 从一个特定的数据库转移到ElasticSearch索引。我如何在将数据从数据库加载到ElasticSearch中的索引时排除指定字段？
浏览 2提问于2017-06-06得票数 1
': 'Current token (START_OBJECT) not numeric, can not use numeric value accessors\n at [Source: org.elasticsearch.common.bytes.BytesReferenceMarkSupportingStreamInputWrapper@6e2393ee; line: 1, column: 277]' }}
我的集合vehiclemodel在MongoDB中有两种类型的数据
浏览 8提问于2017-08-04得票数 0
我正在尝试将MongoDB与ElasticSearch5.5.2集成。有人能告诉我我该怎么做吗？我还没有找到适当的链接来集成它们。我知道我们需要安装mongo-连接器/river，但是我无法安装它。我还尝试了以下命令：m
浏览 0提问于2017-09-21得票数 0
回答已采纳
1回答
我正在使用MongoDB、Sails和ElasticSearch开发一个应用程序。问题是，我无法为存储lat和lon、父/子或分析器等字段维护我的geo_point映射。我也尝试创建一个映射文件并将其放置在elasticsearch/config/mappings
浏览 1提问于2015-05-23得票数 1
回答已采纳
我正在使用mongo连接器来同步MongoDB和SOLR之间的数据.我在RedHat 7 OS Server中工作，我想在Server中作为叉进程运行mongo-连接器命令，因为我需要没有任何中断的实时同步localhost:27017 -t http://localhost:8983/solr/Search --auto-commit-interval=0 -d solr_doc_manager
这将继续mongo-连接器服务，直到我退出命令接口
浏览 0提问于2016-11-16得票数 0
回答已采纳
例如，配置文件集合有多个文档，但需要索引年龄> 25且国家为"US“的文档我使用mongo-connector来索引集合(在elasticsearch中)
请建议可以采取的方法？
浏览 3提问于2016-04-02得票数 0
我想知道如何将数据从elasticsearch发送到kafka，然后再发送到influxdb？我已经尝试过使用来自elasticsearch的源连接器和从influxdb的接收器连接器的汇合平台，但问题是我不得不将数据从elasticsearch发送到kafka如何将数据从elasticsearch<
浏览 3提问于2022-09-15得票数 0
回答已采纳
我希望使用mongo-连接器为我的搜索应用程序从mongodb导入数据到solr。我遵循的步骤。
不起作用。
浏览 2提问于2016-06-18得票数 4
1回答
洗牌写入的数据帧是60 is。
我将使用mongo-火花-conector(mongo-火花-连接器_2.10)在mongodb中插入该数据。
浏览 2提问于2016-07-18得票数 0
我正在尝试实现从MongoDB获取文档并将其插入ElasticSearch的应用程序。下面是一段应该将文档插入到ElasticSearch索引的代码：
final Document o = (Document) document.get("o"); // this is where object(FieldTypeLookup.java:117) at org.elasticsearch.index.mapper.MapperService.checkNewMappersCompatibility(M
浏览 2提问于2016-01-08得票数 0
回答已采纳
我使用elasticsearch 6.2.2作为flink中的接收器，但在阅读apache flink文档时，我可以看到用于5.x版的连接器，但没有提到6.x版的连接器。flink是否支持elasticsearch 6.x的任何连接器？或者，我是否应该创建任何http客户端，并在每次创建或更新新文档时发出post请求？或者他们有其他的技术？
浏览 14提问于2018-02-28得票数 0
当我试图使用以下命令同步mongodb数据时，它将无限等待：ocalhost:27017 -t http://localhost:7474connect=True, replicaset='myDevReplSet'), 'local'), 'oplog.rs')", 6255589333701492738]
编辑:如果我使用-v选项初始化mongo-连接器，mongo-conn
浏览 4提问于2016-03-02得票数 0
我们在执行使用Kafka连接器将来自Kafka主题的消息发送到Elasticsearch的顺序时遇到了问题。在主题中，消息的顺序是正确的，有正确的偏移，但是如果有两条具有相同ID的消息被快速地连续创建，它们就会间歇地以错误的顺序发送到Elasticsearch。这导致Elasticsearch拥有第二条最后消息的数据，而不是最后一条消息的数据。如果我们在主题中的两个消息之间添加一些人为的一两秒钟的延迟，问题就会消失。FIRST UPDATE >&
浏览 1提问于2019-01-17得票数 1
回答已采纳
但这不会进入elasticsearch的主题。如果我不使用json过滤器，整个json将作为“message”进入ES。
任何帮助都将不胜感激。
浏览 0提问于2018-10-19得票数 0
回答已采纳
我使用mongo连接器并将整个集合从mongodb传输到elasticsearch。mongo-连接器配置json文件是： "verbosity": 1,
"continueOnError":false': u'Current token (VALUE_FALSE) not numeric, can not use numeric v
浏览 0提问于2018-09-04得票数 0
回答已采纳
你好，我目前正试图通过汇合连接器从kafka(MSK)(AWS)发送数据到elasticsearch。我有一个来自sql数据库的数据流。当我运行汇流连接器时，它会运行一段时间，将数据发送到elasticsearch，但在一两分钟后停止，错误如下。有大量的数据要流，并且想知道是否有更好的方法或特定的设置一次发送多个批，或者修复此错误的方法可能有帮助。我的elasticsear
浏览 1提问于2021-02-03得票数 0
我开始将数据从MongoDb迁移到ElasticSearch。为此，我使用了“monstache”。此连接器正在跟踪MongoDb的操作日志。问题是我已经在MongoDb中有了我也想发送到ElasticSearch中的数据。做这件事最好的方法是什么？
浏览 1提问于2018-12-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
