Hi All, I have implemented the UI for the Health Statistics UI. The git hub commits can be find from here [1].
And im moving forward to replace the MySql database from the embedded H2 RDBMS as we discussed offline on 22nd of July. Thank You! Best Regards, Ashan [1]= https://github.com/ashandk/stratos/commit/310ea343d80d009778f572da12a4098c7d2177ec On Thu, Jul 16, 2015 at 7:29 PM, Ashan Dhananjaya <dhananjay...@gmail.com> wrote: > Hi Imesh, > > Noted. I will create a documentation for the REST API. > > Thank You! > Best Regards, > Ashan > > On Thu, Jul 16, 2015 at 10:51 AM, Imesh Gunaratne <im...@apache.org> > wrote: > >> >> On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu <r...@wso2.com> >> wrote: >>> >>> >>>> 1.getAverageClusterMemoryByClusterId >>>> >>> >>> /cluster/averageMemory/{Id}/{Interval}} >>> >>> >>>> 2.getAverageClusterLoadByClusterId >>>> >>> >>> /cluster/averageLoad/{Id}/{Interval}} >>> >>> >>>> 3.getAverageMemberMemoryByMemberId >>>> >>> >>> /member/averageMemory/{Id}/{Interval}} >>> >>> 4.getAverageMemberLoadByMemberId >>>> >>> >>> /member/averageLoad/{Id}/{Interval}} >>> >>> >>>> 5.getAverageClusterFlightRequestCountByClusterId >>>> >>> >>> /cluster/flightRequestCount/{Id}/{Interval}} >>> >> >> +1 A great thought! @Ashan: It would be better if you can document the >> API methods (may be in a Google doc). >> >> Thanks >> >> On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu <r...@wso2.com> >> wrote: >> >>> Hi Ashan, >>> >>> Wouldn't it be better to stick with the REST API paths currently used by >>> stratos? You can inherit and add more stuffs as you want. Please see below >>> for some sample paths: >>> >>> On Tue, Jul 14, 2015 at 1:55 AM, Ashan Dhananjaya < >>> dhananjay...@gmail.com> wrote: >>> >>>> Hi All, >>>> >>>> I have implemented the REST api methods for the health statistics UI in >>>> the stratos existing REST API. >>>> >>>> 1.getAverageClusterMemoryByClusterId >>>> >>> >>> /cluster/averageMemory/{Id}/{Interval}} >>> >>> >>>> 2.getAverageClusterLoadByClusterId >>>> >>> >>> /cluster/averageLoad/{Id}/{Interval}} >>> >>> >>>> 3.getAverageMemberMemoryByMemberId >>>> >>> >>> /member/averageMemory/{Id}/{Interval}} >>> >>> 4.getAverageMemberLoadByMemberId >>>> >>> >>> /member/averageLoad/{Id}/{Interval}} >>> >>> >>>> 5.getAverageClusterFlightRequestCountByClusterId >>>> >>> >>> /cluster/flightRequestCount/{Id}/{Interval}} >>> >>> Thanks, >>> Reka >>> >>>> >>>> Please find the Github commit here[1]. >>>> >>>> [1]= >>>> https://github.com/apache/stratos/commit/5ab9159744f136e649174f7293adabe5c77fb4bd >>>> >>>> >>>> Thank You! >>>> Best Regards, >>>> Ashan >>>> >>>> On Thu, Jul 9, 2015 at 8:30 PM, Ashan Dhananjaya < >>>> dhananjay...@gmail.com> wrote: >>>> >>>>> Noted Lahiru. >>>>> >>>>> On Thu, Jul 9, 2015 at 7:48 PM, Lahiru Sandaruwan <lahi...@wso2.com> >>>>> wrote: >>>>> >>>>>> Hi Ashan, >>>>>> >>>>>> Good stuff. It is fine to set the time stamp from CEP for now. But >>>>>> ultimately we need the timestamp to be sent from Python cartridge agent. >>>>>> Let's fix that part we proceed. >>>>>> >>>>>> Thanks. >>>>>> >>>>>> On Thu, Jul 9, 2015 at 7:38 PM, Ashan Dhananjaya < >>>>>> dhananjay...@gmail.com> wrote: >>>>>> >>>>>>> Hi All, >>>>>>> >>>>>>> I was able to get the TimeaStamp to the RDBMS without any conflict >>>>>>> AFAIK. I am testing the flow more. Please find the commits [1], [2] for >>>>>>> the >>>>>>> Formatters. >>>>>>> >>>>>>> [1]= >>>>>>> https://github.com/ashandk/stratos/commit/efa25eb255cadbf2843e5f0d0e13b34c09535f91 >>>>>>> [2]= >>>>>>> https://github.com/ashandk/stratos/commit/9c0fce9081c299c34031d602c94ea712602c7a6c >>>>>>> >>>>>>> Thank You! >>>>>>> Best Regards, >>>>>>> Ashan >>>>>>> >>>>>>> On Thu, Jul 9, 2015 at 2:41 PM, Lahiru Sandaruwan <lahi...@wso2.com> >>>>>>> wrote: >>>>>>> >>>>>>>> Great work Ashan. >>>>>>>> >>>>>>>> On Thu, Jul 9, 2015 at 2:39 PM, Ashan Dhananjaya < >>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>> >>>>>>>>> Hi All, >>>>>>>>> >>>>>>>>> I was able to take the timestamp from the cartridge agent >>>>>>>>> (WSO2CEPHealthStatisticsPublisher and >>>>>>>>> WSO2CEPInFlightRequestPublisher) to >>>>>>>>> CEP PayLoad definition.Git Hub commits can be found here[1], [2]. >>>>>>>>> Currently >>>>>>>>> working on sending the timestamp to the RDBMS without conflicting >>>>>>>>> execution >>>>>>>>> plans. >>>>>>>>> >>>>>>>>> I have included the read-me [2] file to the cep extensions how to >>>>>>>>> configure should happen for the Health Stat publishing to the RDBMS. >>>>>>>>> >>>>>>>>> [1]= >>>>>>>>> https://github.com/apache/stratos/commit/4c65e705be822fd420b4e48ebafef789c8686b76 >>>>>>>>> [2]= >>>>>>>>> https://github.com/apache/stratos/commit/e09334cd98f245a4633c992f02db2878ac24d3d0 >>>>>>>>> [3]= >>>>>>>>> https://github.com/apache/stratos/commit/5ca895ef030f6aaeba56183d982aa5ae95db9337 >>>>>>>>> >>>>>>>>> Thank You! >>>>>>>>> Best Regards, >>>>>>>>> Ashan >>>>>>>>> >>>>>>>>> On Tue, Jul 7, 2015 at 1:13 PM, Lasantha Fernando < >>>>>>>>> lasantha....@gmail.com> wrote: >>>>>>>>> >>>>>>>>>> Hi Ashan, >>>>>>>>>> >>>>>>>>>> Currently, you would not be able to get the timestamp out of the >>>>>>>>>> event >>>>>>>>>> unless you use a databridge agent callback. In that case, you can >>>>>>>>>> use >>>>>>>>>> Java code to simply get by calling event.getTimestamp(). >>>>>>>>>> >>>>>>>>>> However, if you want to use the timestamp as an attribute while >>>>>>>>>> doing >>>>>>>>>> processing within CEP, you would have to pass the timestamp as an >>>>>>>>>> attribute of the stream. i.e. add it as an attribute of either >>>>>>>>>> meta, >>>>>>>>>> correlation or payload data. Then you can use that timestamp and >>>>>>>>>> format the output event as necessary. >>>>>>>>>> >>>>>>>>>> Thanks, >>>>>>>>>> Lasantha >>>>>>>>>> >>>>>>>>>> On Tue, Jul 7, 2015 at 1:04 PM, Ashan Dhananjaya < >>>>>>>>>> dhananjay...@gmail.com> wrote: >>>>>>>>>> > Hi All, >>>>>>>>>> > >>>>>>>>>> > I applied the above patch and get the timestamp in the Input >>>>>>>>>> Adapter. The >>>>>>>>>> > formatter i used was >>>>>>>>>> "member_average_memory_consumption_stats:1.0.0". I >>>>>>>>>> > tried several time to get the timeStamp attribute but failed. >>>>>>>>>> Is there any >>>>>>>>>> > way to get a data which is outside in the payload? The Input >>>>>>>>>> stream is as >>>>>>>>>> > below, >>>>>>>>>> > >>>>>>>>>> > 10:40:27,757 [-] [DataBridge-Core-pool-2-thread-1] INFO >>>>>>>>>> TenantId=-1234 : >>>>>>>>>> > Input Event Adaptor : DefaultWSO2EventInputAdaptor, received >>>>>>>>>> > >>>>>>>>>> > Event{ >>>>>>>>>> > streamId='cartridge_agent_health_stats:1.0.0', >>>>>>>>>> > timeStamp=1436245827731, >>>>>>>>>> > metaData=null, >>>>>>>>>> > correlationData=null, >>>>>>>>>> > payloadData=[single-cartridge-app.my-php.php.domain, >>>>>>>>>> > single-cartridge-app-1, network-partition-1, >>>>>>>>>> > >>>>>>>>>> single-cartridge-app.my-php.php.domaina5598e2b-995f-4620-b652-e66341e24c99, >>>>>>>>>> > partition-1, memory_consumption, 20.0], >>>>>>>>>> > arbitraryDataMap={}, >>>>>>>>>> > } >>>>>>>>>> > >>>>>>>>>> > Any help will be really appreciated. >>>>>>>>>> > >>>>>>>>>> > Thank You! >>>>>>>>>> > Best Regards, >>>>>>>>>> > Ashan >>>>>>>>>> > >>>>>>>>>> > On Tue, Jul 7, 2015 at 9:32 AM, Chamila De Alwis < >>>>>>>>>> chami...@wso2.com> wrote: >>>>>>>>>> >> >>>>>>>>>> >> Hi Ashan, >>>>>>>>>> >> >>>>>>>>>> >> As I've seen from the PCA testing recently, the timestamp is >>>>>>>>>> added to >>>>>>>>>> >> every ThriftEvent before publishing. Are you working on PCA or >>>>>>>>>> the Mock >>>>>>>>>> >> IaaS? I took a look at the Mock IaaS and the >>>>>>>>>> WSO2CEPStatisticsPublisher as >>>>>>>>>> >> well, and found out that the latter indeed doesn't add the >>>>>>>>>> timestamp to the >>>>>>>>>> >> ThriftEvents. This means that the JCA also publishes Thrift >>>>>>>>>> Events with >>>>>>>>>> >> empty timestamp fields. >>>>>>>>>> >> >>>>>>>>>> >> Following is the simple fix for that. I've attached the patch >>>>>>>>>> herewith. >>>>>>>>>> >> Could you quickly verify with the patch applied build also? >>>>>>>>>> >> >>>>>>>>>> >> chamilad@chamilad-ThinkPad-T530:~/dev/stratos[master *]$ git >>>>>>>>>> diff >>>>>>>>>> >> diff --git >>>>>>>>>> >> >>>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>> >> b/c >>>>>>>>>> >> index 653288d..f1fe426 100644 >>>>>>>>>> >> --- >>>>>>>>>> >> >>>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>> >> +++ >>>>>>>>>> >> >>>>>>>>>> b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java >>>>>>>>>> >> @@ -29,6 +29,7 @@ import >>>>>>>>>> >> >>>>>>>>>> org.wso2.carbon.databridge.agent.thrift.exception.AgentException; >>>>>>>>>> >> import org.wso2.carbon.databridge.commons.Event; >>>>>>>>>> >> import org.wso2.carbon.databridge.commons.StreamDefinition; >>>>>>>>>> >> >>>>>>>>>> >> +import java.util.Date; >>>>>>>>>> >> import java.util.HashMap; >>>>>>>>>> >> >>>>>>>>>> >> /** >>>>>>>>>> >> @@ -98,6 +99,7 @@ public class WSO2CEPStatisticsPublisher >>>>>>>>>> implements >>>>>>>>>> >> StatisticsPublisher { >>>>>>>>>> >> >>>>>>>>>> >> Event event = new Event(); >>>>>>>>>> >> event.setPayloadData(payload); >>>>>>>>>> >> + event.setTimeStamp(new Date().getTime()); >>>>>>>>>> >> event.setArbitraryDataMap(new HashMap<String, >>>>>>>>>> String>()); >>>>>>>>>> >> >>>>>>>>>> >> try { >>>>>>>>>> >> >>>>>>>>>> >> >>>>>>>>>> >> >>>>>>>>>> >> >>>>>>>>>> >> >>>>>>>>>> >> Regards, >>>>>>>>>> >> Chamila de Alwis >>>>>>>>>> >> Committer and PMC Member - Apache Stratos >>>>>>>>>> >> Software Engineer | WSO2 | +94772207163 >>>>>>>>>> >> Blog: code.chamiladealwis.com >>>>>>>>>> >> >>>>>>>>>> >> >>>>>>>>>> > >>>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> -- >>>>>>>> Lahiru Sandaruwan >>>>>>>> Committer and PMC member, Apache Stratos, >>>>>>>> Senior Software Engineer, >>>>>>>> WSO2 Inc., http://wso2.com >>>>>>>> lean.enterprise.middleware >>>>>>>> >>>>>>>> phone: +94773325954 >>>>>>>> email: lahi...@wso2.com blog: http://lahiruwrites.blogspot.com/ >>>>>>>> linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146 >>>>>>>> >>>>>>>> >>>>>>>> _______________________________________________ >>>>>>>> Dev mailing list >>>>>>>> d...@wso2.org >>>>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>>>>> >>>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> -- >>>>>> Lahiru Sandaruwan >>>>>> Committer and PMC member, Apache Stratos, >>>>>> Senior Software Engineer, >>>>>> WSO2 Inc., http://wso2.com >>>>>> lean.enterprise.middleware >>>>>> >>>>>> phone: +94773325954 >>>>>> email: lahi...@wso2.com blog: http://lahiruwrites.blogspot.com/ >>>>>> linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146 >>>>>> >>>>>> >>>>> >>>> >>> >>> >>> -- >>> Reka Thirunavukkarasu >>> Senior Software Engineer, >>> WSO2, Inc.:http://wso2.com, >>> Mobile: +94776442007 >>> >>> >>> >> >> >> -- >> Imesh Gunaratne >> >> Senior Technical Lead, WSO2 >> Committer & PMC Member, Apache Stratos >> > >
