I was trying to run below query with siddhi patterns but , I cannot get any output neither do I get any error as such, so I am in dilemma does siddhi patterns work with this library and below is my query:
"from inputStream select json:toObject(s3log) as obj insert into temp;" +
"from temp select " +
"json:getString(obj,'$.s3log.requestId') as access_requester," +
"json:getString(obj,'$.s3log.httpStatus') as attempted_response," +
"json:getString(obj,'$.s3log.bucket') as accessed_bucket," +
"json:getString(obj,'$.s3log.operation') as attempted_action " +
"insert into temp2;"+
"from every( e1 = temp2 ) -> e2 = temp2[ e1.access_requester == access_requester and " +
"(e1.attempted_response == attempted_response)] " +
"within 30 sec " +
"select e1.access_requester , e1.attempted_response, e1.accessed_bucket,e1.attempted_action " +
"insert into outputStream;"
Hi ,
I was trying to run below query with siddhi patterns but , I cannot get any output neither do I get any error as such, so I am in dilemma does siddhi patterns work with this library and below is my query:
"from inputStream select json:toObject(s3log) as obj insert into temp;" + "from temp select " + "json:getString(obj,'$.s3log.requestId') as access_requester," + "json:getString(obj,'$.s3log.httpStatus') as attempted_response," + "json:getString(obj,'$.s3log.bucket') as accessed_bucket," + "json:getString(obj,'$.s3log.operation') as attempted_action " + "insert into temp2;"+ "from every( e1 = temp2 ) -> e2 = temp2[ e1.access_requester == access_requester and " + "(e1.attempted_response == attempted_response)] " + "within 30 sec " + "select e1.access_requester , e1.attempted_response, e1.accessed_bucket,e1.attempted_action " + "insert into outputStream;"
Regards Dipanjan