Hi All,
@Reka: Thank you for your suggestion. I think its the best way of doing
it..
@Ashan: How are we using *Interval *parameter. AFAIK all graph needs to
update automatically(near real-time) + update according to the user
selection. How we are planning to handle this?
Can you share some real queries including {interval} format.
Regards,
*Dakshika Jayathilaka*
PMC Member & Committer of Apache Stratos
Senior Software Engineer
WSO2, Inc.
lean.enterprise.middleware
0771100911
On Tue, Jul 14, 2015 at 10:25 PM, Ashan Dhananjaya <dhananjay...@gmail.com>
wrote:
> Hi Reka,
>
> $Noted.
>
> Thank You!
> Best Regards,
> Ashan
>
> On Tue, Jul 14, 2015 at 7:14 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
>>
>>
>>
>
