Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static void main(String[] args) {
- ElasticSearchManagement elasticSearchManagement = ElasticSearchManagement.getInstance();
- elasticSearchManagement.setDelegate(new ElasticSearchTransportConnection("127.0.0.1", 9300, "Superia", "docker-suricata-elk"));
- SuricataDao suricataDao = SuricataDao.getInstance();
- suricataDao.setDelegate(new DbSuricataDao());
- suricataDao.setElasticSearchManagement(elasticSearchManagement);
- System.out.println(suricataDao.getAllIndex());
- //System.out.println(suricataDao.getAllDocsFromIndex("logstash-2016.02.04"));
- List<ElasticSearchDocument> docs = suricataDao.getAllDocsFromIndex("logstash-2016.02.07", 10000000);
- List<String> eventTypes = new ArrayList<>();
- for(int i=0; i<docs.size(); i++){
- /**
- if(docs.get(i).getEsData().get("e))
- System.out.println(docs.get(i).getEsData());
- **/
- /** List all Suricata msg by type **/
- if(docs.get(i).getEsData().get("event_type").equals("stats")) {
- System.out.println(docs.get(i).getEsData());
- }
- /**
- // List all Suricata event_type
- if(!eventTypes.contains(docs.get(i).getEsData().get("event_type"))
- && docs.get(i).getEsData().get("event_type") != null) {
- eventTypes.add(docs.get(i).getEsData().get("event_type").toString());
- System.out.println(docs.get(i).getEsData().get("event_type").toString());
- }
- **/
- }
- /**
- List<ISuricataMessage> suricataMsg = suricataDao.transformElasticSearchDocumentsToSuricataMessages(docs);
- for(int i = 0; i<suricataMsg.size(); i++) {
- if(suricataMsg.get(i) instanceof SuricataFlowMessage)
- System.out.println(suricataMsg.get(i).getDest_ip());
- }
- **/
- //System.out.println(suricataDao.s
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement