2016-03-31 3 views
0

У меня есть следующий завиток команду:Как выполнить эту команду curl в моем java-коде?

curl -XPOST 'localhost:9200/indexname/status/_search?pretty=1&size=1000000&q=date:"2012/10/10"' -d '{"_source": {"include": [ "ID", "Name" ]}}' 

Мой Java-код, как это:

public static void main(String[] args) throws IOException{ 

ProcessBuilder pb = new ProcessBuilder("curl","-g","-H", "Accept:application/json", "-XPOST","localhost:9200/indexname/status/_search?pretty=1&size=10000","-d '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}'"); 

    pb.directory(new File("localpath")); 
    pb.redirectErrorStream(true); 
    Process p = pb.start(); 
    InputStream is = p.getInputStream(); 

    FileOutputStream outputStream = new FileOutputStream(
      "localpath/data.json"); 

    String line; 
    BufferedInputStream bis = new BufferedInputStream(is); 
    byte[] bytes = new byte[100]; 
    int numberByteReaded; 
    while ((numberByteReaded = bis.read(bytes, 0, 100)) != -1) { 

     outputStream.write(bytes, 0, numberByteReaded); 
     Arrays.fill(bytes, (byte) 0); 
    } 
    outputStream.flush(); 
    outputStream.close(); 
} 

На выполнение кода, в data.json файл, хранящийся в моем локальном диске, я вижу это ошибка:

{ 
    "error" : "SearchPhaseExecutionException[Failed to execute phase [query], all shards failed; shardFailures {[EsJClybMTnONMBSDBIfS9g][indexname][0]: SearchParseException[[indexname][0]: from[-1],size[-1]: Parse Failure [Failed to parse source [ '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}']]]; nested: JsonParseException[Unexpected character (''' (code 39)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')\n at [Source: [[email protected]; line: 1, column: 3]]; }{[EsJClybMTnONMBSDBIfS9g][indexname][1]: SearchParseException[[indexname][1]: from[-1],size[-1]: Parse Failure [Failed to parse source [ '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}']]]; nested: JsonParseException[Unexpected character (''' (code 39)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')\n at [Source: [[email protected]; line: 1, column: 3]]; }{[EsJClybMTnONMBSDBIfS9g][indexname][2]: SearchParseException[[indexname][2]: from[-1],size[-1]: Parse Failure [Failed to parse source [ '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}']]]; nested: JsonParseException[Unexpected character (''' (code 39)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')\n at [Source: [[email protected]; line: 1, column: 3]]; }{[EsJClybMTnONMBSDBIfS9g][indexname][3]: SearchParseException[[indexname][3]: from[-1],size[-1]: Parse Failure [Failed to parse source [ '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}']]]; nested: JsonParseException[Unexpected character (''' (code 39)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')\n at [Source: [[email protected]; line: 1, column: 3]]; }{[EsJClybMTnONMBSDBIfS9g][indexname][4]: SearchParseException[[indexname][4]: from[-1],size[-1]: Parse Failure [Failed to parse source [ '{\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}']]]; nested: JsonParseException[Unexpected character (''' (code 39)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')\n at [Source: [[email protected]; line: 1, column: 3]]; }]", 
"status" : 400 
} 

Любая идея, почему это происходит? Я хочу сохранить пары значений ID и Name Key с даты, указанной в запросе. Любой совет? Благодарю.

+0

Почему вы не используете классы Java для выполнения этого POST, а не для использования внешнего процесса? –

+0

Пожалуйста, покажите мне пример? – Sweet

+0

Я думаю, что это может помочь http://stackoverflow.com/questions/3324717/sending-http-post-request-in-java –

ответ

0

Вы можете сделать это с помощью ES java client

client = new TransportClient(settings) 
      .addTransportAddress(new InetSocketTransportAddress(HOST, PORT)); 

String queryString = "{\"size\":10, \"query\": { \"term\": {\"date\": \"VALUE\"}},\"_source\": {\"include\": [ \"ID\", \"Name\" ]}}"; 
SearchResponse response = client.prepareSearch("indexname").setTypes("status").setSource(queryString) 
       .execute().actionGet(); 

Пожалуйста, прочтите java client for elasticsearch. Это может быть полезно для вас играть с ES java api.

Смежные вопросы