Elasticsearch -从json文件加载ILM策略

Question

我已经通过JAVA api实现了一个ILM策略。我的代码看起来像这样：

        Map<String, Phase> phases = new HashMap<>();

    Map<String, LifecycleAction> hotActions = new HashMap<>();
    hotActions.put(RolloverAction.NAME,
            new RolloverAction(new ByteSizeValue(30, ByteSizeUnit.GB),
                    new TimeValue(maxDaysPerIndex, TimeUnit.DAYS),
                    maxRecordsPerIndex));
    phases.put("hot", new Phase("hot", TimeValue.ZERO, hotActions));

    Map<String, LifecycleAction> warmActions = new HashMap<>();
    warmActions.put(ForceMergeAction.NAME, new ForceMergeAction(1));
    phases.put("warm", new Phase("warm", TimeValue.ZERO, warmActions));

    Map<String, LifecycleAction> deleteActions = Collections.singletonMap(DeleteAction.NAME, new DeleteAction());
    phases.put("delete", new Phase("delete", new TimeValue(retentionPeriodDays, TimeUnit.DAYS), deleteActions));

    LifecyclePolicy policy = new LifecyclePolicy("my_policy", phases);

    restHighLevelClient.indexLifecycle()
            .putLifecyclePolicy(new PutLifecyclePolicyRequest(policy), RequestOptions.DEFAULT);

现在，作为JSON的策略如下所示：

"my_policy" : {
"version" : 3,
"modified_date" : "2019-06-17T08:33:08.356Z",
"policy" : {
  "phases" : {
    "warm" : {
      "min_age" : "0ms",
      "actions" : {
        "forcemerge" : {
          "max_num_segments" : 1
        }
      }
    },
    "hot" : {
      "min_age" : "0ms",
      "actions" : {
        "rollover" : {
          "max_size" : "30gb",
          "max_age" : "1d",
          "max_docs" : 5000000
        }
      }
    },
    "delete" : {
      "min_age" : "29d",
      "actions" : {
        "delete" : { }
      }
    }
  }
}

}

现在，我不想使用java api创建策略，而是创建一个json文件，并将其作为策略加载，如下所示：

JsonFILE jsonFile = loadJsonFromFile("fileName");
LifecyclePolicy policy = new LifecyclePolicy("my_policy", jsonFile);
restHighLevelClient.indexLifecycle().putLifecyclePolicy(new 
PutLifecyclePolicyRequest(policy), RequestOptions.DEFAULT);

底线--有没有办法通过JAVA加载一个配置ILM策略的json文件？

Answer 1

您可以使用低级客户端，而不是高级客户端来直接request ES REST APIs：

RestClient restClient = RestClient.builder(
    new HttpHost("localhost", 9200, "http")).build();

String source = new String(Files.readAllBytes(
    new File("path/to/file.json", StandardCharsets.UTF_8);

Request request = new Request("PUT", "_ilm/policy/name");
request.setJsonEntity(source);

restClient.performRequest(request);