ElasticSearch：在物場的現有陣列追加對象

我的字段映射：ElasticSearch：在物場的現有陣列追加對象

"Pincode": { 

    "analyzer": "standard", 
    "type": "string" 

}, 
    "Residence_address": { 

     "include_in_parent": true, 


      "type": "nested", 
      "properties": { 
       "address": { 
        "analyzer": "standard", 
        "type": "string" 
       }, 
       "Address_type": { 
        "analyzer": "standard", 
        "type": "string" 
       }, 
       "Pincode": { 
        "analyzer": "standard", 
        "type": "string" 
       } 
      } 

     }

我有數據：

"Residence_address": [ 

     { 
      "address": "safadfsdf", 
      "Address_type": "Owned", 
      "Pincode": "50005756768674" 
     } 
     , 
     { 
      "address": "Collage of lkj", 
      "Address_type": "Rented", 
      "Pincode": "419005" 
     } 

    ], 
"Pincode": [ 

    "11" ,"12" 

]

當我插入pin碼：

"Pincode": ["15"]

其工作細。對於正常的數組字段（不是對象數組），附加工作正常。

但是當我要插入的對象爲：

"Residence_address": [ 
        { 
        "address": "abbbbbb", 
        "Address_type": "bcccccc", 
        "Pincode": "67999999" 
        } 
       ]

當我插入使用此代碼是：

 updateRequest.script("ctx._source.Residence_address += ADD"); 
      JSONArray Address = (JSONArray) temp.get("Residence_address");    
      i = 0; 
      while(i < Address.size()){ 
        System.out.println(Address.get(i).toString()); 
        updateRequest.addScriptParam("ADD", Address.get(i++).toString()); 
       }

它給我的錯誤：

org.elasticsearch.index.mapper.MapperParsingException: object mapping [Residence_address] trying to serialize a value with no field associated with it, current value [{"address":"abbbbbb","Address_type":"bcccccc","Pincode":"67999999"}] 
    at org.elasticsearch.index.mapper.object.ObjectMapper.serializeValue(ObjectMapper.java:702) 
    at org.elasticsearch.index.mapper.object.ObjectMapper.parse(ObjectMapper.java:497) 
    at org.elasticsearch.index.mapper.object.ObjectMapper.serializeValue(ObjectMapper.java:706) 
    at org.elasticsearch.index.mapper.object.ObjectMapper.serializeNonDynamicArray(ObjectMapper.java:695) 
    at org.elasticsearch.index.mapper.object.ObjectMapper.serializeArray(ObjectMapper.java:604) 
    at org.elasticsearch.index.mapper.object.ObjectMapper.parse(ObjectMapper.java:489) 
    at org.elasticsearch.index.mapper.DocumentMapper.parse(DocumentMapper.java:544) 
    at org.elasticsearch.index.mapper.DocumentMapper.parse(DocumentMapper.java:493) 
    at org.elasticsearch.index.shard.IndexShard.prepareIndex(IndexShard.java:493) 
    at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:192) 
    at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$PrimaryPhase.performOnPrimary(TransportShardReplicationOperationAction.java:574) 
    at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$PrimaryPhase.routeRequestOrPerformLocally(TransportShardReplicationOperationAction.java:444) 
    at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$PrimaryPhase.doRun(TransportShardReplicationOperationAction.java:370) 
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:36) 
    at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction.doExecute(TransportShardReplicationOperationAction.java:112) 
    at org.elasticsearch.action.index.TransportIndexAction.innerExecute(TransportIndexAction.java:136) 
    at org.elasticsearch.action.index.TransportIndexAction.doExecute(TransportIndexAction.java:114) 
    at org.elasticsearch.action.index.TransportIndexAction.doExecute(TransportIndexAction.java:63) 
    at org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:75) 
    at org.elasticsearch.action.update.TransportUpdateAction.shardOperation(TransportUpdateAction.java:217) 
    at org.elasticsearch.action.update.TransportUpdateAction.shardOperation(TransportUpdateAction.java:170) 
    at org.elasticsearch.action.support.single.instance.TransportInstanceSingleOperationAction$AsyncSingleAction$1.run(TransportInstanceSingleOperationAction.java:187) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745)

幫助，請。

來源

2016-07-29 Bond

如果您在Address中有多個地址，則會添加許多參數名稱相同的參數ADD，這將不起作用。

試試這個：

 String newAddrs = ""; 
     JSONArray Address = (JSONArray) temp.get("Residence_address");    
     int i = 0; 
     while(i < Address.size()){ 
       newAddrs += "ADD" + i + (i < Address.size() - 1 ? "," : ""); 
       updateRequest.addScriptParam("ADD"+i, Address.get(i++)); 
     } 
     updateRequest.script("ctx._source.Residence_address += ["+newAddrs+"]");

所以，如果你有3個地址，你就結束了一個腳本，看起來像：

ctx._source.Residence_address += [ ADD0, ADD1, ADD2 ]

而且你將有三個腳本參數命名ADD0， ADD1，ADD2

來源

2016-07-29 12:23:15 Val

謝謝@val。我試過了。但它給了我同樣的錯誤。 – Bond

添加腳本參數時可以刪除'toString（）'調用嗎？ – Val

其部分工作。我試圖追加兩個對象。但是我只能追加最後一個對象。 – Bond

ElasticSearch：在物場的現有陣列追加對象

回答

相關問題