updated kibana bulk file(s)

djptek · Oct 17, 2019 · 73d418d · 73d418d
1 parent 55ccf33
commit 73d418d
Show file tree

Hide file tree

Showing 5 changed files with 147 additions and 115 deletions.
diff --git a/.idea/misc.xml b/.idea/misc.xml
diff --git a/src/main/java/demos/KibanaObjectsLoader.java b/src/main/java/demos/KibanaObjectsLoader.java
@@ -3,28 +3,34 @@
 import org.apache.logging.log4j.Level;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
-import org.elasticsearch.action.bulk.BulkRequest;
 import org.elasticsearch.action.bulk.BulkResponse;
-import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.RestHighLevelClient;
 
 import java.io.File;
 import java.io.IOException;
-import java.util.Scanner;
 
 class KibanaObjectsLoader {
     private static Logger logger = LogManager.getLogger(App.class);
+    private static String[] filenames = {
+            "src/main/resources/.kibana_1_bulk.ndjson",
+            "src/main/resources/.kibana_2_bulk.ndjson"};
     private static BulkResponseDumper bulkResponseDumper = new BulkResponseDumper(logger);
-    private static String filename = "src/main/resources/kibana_1_bulk.ndjson";
-    private static File file = new File(filename);
+    private static BulkResponse bulkResponse;
     private static DataLoader dataLoader;
+    private static RestHighLevelClient client;
 
     KibanaObjectsLoader(RestHighLevelClient client) {
-        this.dataLoader = new DataLoader(client, file, logger);
+        this.client = client;
     }
 
     static void load() throws IOException {
-        dataLoader.load();
+        for (String filename : filenames) {
+            logger.log(Level.INFO, "Loading Kibana Objects "+filename);
+            File file = new File(filename);
+            dataLoader = new DataLoader(client, file, logger);
+            bulkResponse =  dataLoader.load();
+            bulkResponseDumper.dump(bulkResponse);
+        }
     }
 
 }