Slack Invite help and Missing Events Irregular alerts

22 views
Skip to first unread message

Madhuri Jain

unread,
May 5, 2022, 6:05:48 PM5/5/22
to siddhi-dev
Hi,
I had a few questions. How can I join the slack users group for siddhi?
I don't think the dialog box to get an invite on https://siddhi.io/community/ is still working.

Also, I am trying to detect missing events from an event stream using siddhi. My query looks like:

from not inputStream[objid == '${objid1}']
for 20 sec
select '${objid1}' as objid, '${gapRuleId1}' as ruleId, 'Gap Detected' as alert, '20sec time gap' as timeGap
insert into GapCaseOutputStream;
from every f1 = inputStream[objid == '${objid1}'] -> not flattenedStream[f1.objid == objid] for 20 sec
select '${objid1}' as objid, '${gapRuleId1}' as ruleId,
 'Gap Detected' as alert, '20sec time gap' as timeGap
insert into GapCaseOutputStream;

I am sending multiple of these rules each with a different objid. I have noticed that the output is not always consistent.

I have seen the following cases happen:
1. Get correct alerts for all the necessary objids.
2. Skips the alerts for few objids
3. Skips the alerts completely
4. Alerts for the same objid more than once and skips the others

Could you please help me understand how can this be solved? Is the shared state in Siddhi Context somehow triggering this behavior? I also noticed this behavior while debugging using Siddhi Editor.

Would appreciate your help on this.

Senthuran Ambalavanar

unread,
May 17, 2022, 11:06:36 AM5/17/22
to Madhuri Jain, siddhi-dev
Hi,

Will you be able to provide some more context on the use case that you are trying to achieve, please?

Please mention the exact use case, along with the events that you simulate to inputStream stream, and what are the expected results in the GapCaseOutputStream stream.

Regarding the Slack channel, 
Siddhi has been now integrated with WSO2 Streaming Integrator, which is part of WSO2 APIM. Therefore, please join the #streaming-integrator slack channel of WSO2-APIM slack workspace.
Please use the following invite link to join:
https://join.slack.com/t/wso2-apim/shared_invite/zt-193q1xgud-JMiwuxxDf19LAOuA57PeWA

Thanks,
Senthuran.




--
Siddhi homepage: http://siddhi.io/
Siddhi Github repo: https://github.com/siddhi-io/siddhi
 
You received this message because you are subscribed to the Google Groups "Siddhi-dev" group.
To post to this group, send email to siddh...@googlegroups.com
To unsubscribe from this group, send email to siddhi-dev+...@googlegroups.com
For more options, visit this group at http://groups.google.com/group/siddhi-dev?hl=en?hl=en
---
You received this message because you are subscribed to the Google Groups "siddhi-dev" group.
To unsubscribe from this group and stop receiving emails from it, send an email to siddhi-dev+...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/siddhi-dev/77279225-2ec1-4678-8201-ef6875c34a90n%40googlegroups.com.


--
Senthuran Ambalavanar | Senior Software Engineer | WSO2 Inc.
Reply all
Reply to author
Forward
0 new messages