mongodb - ElasticSearch with MongoDB 不索引大对象

Question

我使用以下信息创建了 ES(使用 MongoDB river 插件)索引:

{
    "type": "mongodb",
    "mongodb": {
        "db": "mydatabase",
        "collection": "Users"
    },
    "index": {
        "name": "users",
        "type": "user"
    }
}

当我插入像这样的简单对象时:

{
   "name": "Joe",
   "surname": "Black"
}

一切正常(我可以使用 ES Head 网络界面查看数据)。但是当我插入更大的对象时，它不会索引它:

{
    "object": {
        "text": "Let's do it again!",
        "boolTest": false
    },
    "type": "coolType",
    "tags": [
            ""
    ],
    "subObject1": {
        "count": 0,
        "last3": [],
        "array": []
    },
    "subObject2": {
        "count": 0,
        "last3": [],
        "array": []
    },
    "subObject3": {
        "count": 0,
        "last3": [],
        "array": []
    },
    "usrID": "5141a5a4d8f3a79c09000001",
    "created": Date(1363527664000),
    "lastUpdate": Date(1363527664000)
}

请问哪里有问题？

感谢您的帮助!

编辑:这是来自 ES 控制台的错误:

org.elasticsearch.index.mapper.MapperParsingException: object mapping for [stream] tried to parse as object, but got EOF, has a concrete value been provided to it? at org.elasticsearch.index.mapper.object.ObjectMapper.parse(ObjectMapper.java:457) at org.elasticsearch.index.mapper.DocumentMapper.parse(DocumentMapper.java:486) at org.elasticsearch.index.mapper.DocumentMapper.parse(DocumentMapper.java:430) at org.elasticsearch.index.shard.service.InternalIndexShard.prepareIndex(InternalIndexShard.java:318) at org.elasticsearch.action.bulk.TransportShardBulkAction.shardOperationOnPrimary(TransportShardBulkAction.java:157) at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction.performOnPrimary(TransportShardReplicationOperationAction.java:533) at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1.run(TransportShardReplicationOperationAction.java:431) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:722) [2013-03-20 10:35:05,697][WARN ][org.elasticsearch.river.mongodb.MongoDBRiver$Indexer] failed to executefailure in bulk execution: [0]: index [stream], type [stream], id [514982c9b7f3bfbdb488ca81], message [MapperParsingException[object mapping for [stream] tried to parse as object, but got EOF, has a concrete value been provided to it?]] [2013-03-20 10:35:05,698][INFO ][org.elasticsearch.river.mongodb.MongoDBRiver$Indexer] Indexed 1 documents, 1 insertions 0, updates, 0 deletions, 0 documents per second

Answer 1

您使用的是哪个版本的 MongoDB river？请查看第 26 期 [1]。它包含有关毫无问题地索引大型 json 文档的示例。

如果您仍然可以重现问题，请提供更多详细信息:river 设置、mongodb(版本、特定设置)、elasticsearch(版本、特定设置)。

1. https://github.com/richardwilly98/elasticsearch-river-mongodb/issues/26