Advertisement
Guest User

Untitled

a guest
Feb 7th, 2016
59
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.71 KB | None | 0 0
  1. public static void main(String[] args) {
  2.         ElasticSearchManagement elasticSearchManagement = ElasticSearchManagement.getInstance();
  3.         elasticSearchManagement.setDelegate(new ElasticSearchTransportConnection("127.0.0.1", 9300, "Superia", "docker-suricata-elk"));
  4.        
  5.        
  6.         SuricataDao suricataDao = SuricataDao.getInstance();
  7.         suricataDao.setDelegate(new DbSuricataDao());
  8.         suricataDao.setElasticSearchManagement(elasticSearchManagement);
  9.         System.out.println(suricataDao.getAllIndex());
  10.        
  11.         //System.out.println(suricataDao.getAllDocsFromIndex("logstash-2016.02.04"));
  12.        
  13.        
  14.         List<ElasticSearchDocument> docs = suricataDao.getAllDocsFromIndex("logstash-2016.02.07", 10000000);
  15.         List<String> eventTypes = new ArrayList<>();
  16.         for(int i=0; i<docs.size(); i++){
  17.             /**
  18.             if(docs.get(i).getEsData().get("e))
  19.             System.out.println(docs.get(i).getEsData());
  20.             **/
  21.            
  22.             /** List all Suricata msg by type **/
  23.             if(docs.get(i).getEsData().get("event_type").equals("stats")) {
  24.                 System.out.println(docs.get(i).getEsData());
  25.             }
  26.            
  27.             /**
  28.             // List all Suricata event_type
  29.             if(!eventTypes.contains(docs.get(i).getEsData().get("event_type"))
  30.                     && docs.get(i).getEsData().get("event_type") != null) {
  31.                 eventTypes.add(docs.get(i).getEsData().get("event_type").toString());
  32.                 System.out.println(docs.get(i).getEsData().get("event_type").toString());
  33.             }
  34.             **/
  35.            
  36.         }
  37.         /**
  38.         List<ISuricataMessage> suricataMsg = suricataDao.transformElasticSearchDocumentsToSuricataMessages(docs);
  39.         for(int i = 0; i<suricataMsg.size(); i++) {
  40.             if(suricataMsg.get(i) instanceof SuricataFlowMessage)
  41.             System.out.println(suricataMsg.get(i).getDest_ip());
  42.         }
  43.         **/
  44.        
  45.        
  46.         //System.out.println(suricataDao.s
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement