Different frequences for different sensors

[JRV77]

Hi,

How is the Stream generator behaving with a mix of sensors with different intervals for measurements?
In the example below: S001 gets a value every second, S002 every 1 minute and S003 every 30 sec.
I never get any answer from Starql queries for S002 and S003 even though I see them listed using http://docker-machine-ip:8989/measurement.
2016-02-19T08:03:00+00:00,S001,0.0421
2016-02-19T08:03:00+00:00,S002,1.5953
2016-02-19T08:03:00+00:00,S003,12.951
2016-02-19T08:03:01+00:00,S001,0.0421
2016-02-19T08:03:02+00:00,S001,0.0694
2016-02-19T08:03:03+00:00,S001,0.0323
2016-02-19T08:03:04+00:00,S001,0.0694
2016-02-19T08:03:05+00:00,S001,0.0566
2016-02-19T08:03:06+00:00,S001,0.0694
2016-02-19T08:03:07+00:00,S001,0.0694
2016-02-19T08:03:08+00:00,S001,0.0694
2016-02-19T08:03:09+00:00,S001,0.0596
2016-02-19T08:03:10+00:00,S001,0.061
2016-02-19T08:03:11+00:00,S001,0.0587
2016-02-19T08:03:12+00:00,S001,0.0694
2016-02-19T08:03:13+00:00,S001,0.0177
2016-02-19T08:03:14+00:00,S001,0.0468
2016-02-19T08:03:15+00:00,S001,0.0694
2016-02-19T08:03:16+00:00,S001,0.0694
2016-02-19T08:03:17+00:00,S001,0.0694
2016-02-19T08:03:18+00:00,S001,0.054
2016-02-19T08:03:19+00:00,S001,0.0365
2016-02-19T08:03:20+00:00,S001,0.0694
2016-02-19T08:03:21+00:00,S001,0.0452
2016-02-19T08:03:22+00:00,S001,0.0694
2016-02-19T08:03:23+00:00,S001,0.0203
2016-02-19T08:03:24+00:00,S001,0.0694
2016-02-19T08:03:25+00:00,S001,0.0194
2016-02-19T08:03:26+00:00,S001,0.0694
2016-02-19T08:03:27+00:00,S001,0.0279
2016-02-19T08:03:28+00:00,S001,0.0593
2016-02-19T08:03:29+00:00,S001,0.0674
2016-02-19T08:03:30+00:00,S001,0.0674
2016-02-19T08:03:30+00:00,S003,12.959
2016-02-19T08:03:31+00:00,S001,0.0674
2016-02-19T08:03:32+00:00,S001,0.0694
2016-02-19T08:03:33+00:00,S001,0.0694
2016-02-19T08:03:34+00:00,S001,0.0523
2016-02-19T08:03:35+00:00,S001,0.0694
2016-02-19T08:03:36+00:00,S001,0.0437
2016-02-19T08:03:37+00:00,S001,0.0203
2016-02-19T08:03:38+00:00,S001,0.0694
2016-02-19T08:03:39+00:00,S001,0.0694
2016-02-19T08:03:40+00:00,S001,0.021
2016-02-19T08:03:41+00:00,S001,0.0205
2016-02-19T08:03:42+00:00,S001,0.0694
2016-02-19T08:03:43+00:00,S001,0.0315
2016-02-19T08:03:44+00:00,S001,0.0694
2016-02-19T08:03:45+00:00,S001,0.0315
2016-02-19T08:03:46+00:00,S001,0.0694
2016-02-19T08:03:47+00:00,S001,0.0559
2016-02-19T08:03:48+00:00,S001,0.0358
2016-02-19T08:03:49+00:00,S001,0.054
2016-02-19T08:03:50+00:00,S001,0.0694
2016-02-19T08:03:51+00:00,S001,0.0694
2016-02-19T08:03:52+00:00,S001,0.054
2016-02-19T08:03:53+00:00,S001,0.0632
2016-02-19T08:03:54+00:00,S001,0.0546
2016-02-19T08:03:55+00:00,S001,0.0239
2016-02-19T08:03:56+00:00,S001,0.0694
2016-02-19T08:03:57+00:00,S001,0.0634
2016-02-19T08:03:58+00:00,S001,0.0661
2016-02-19T08:03:59+00:00,S001,0.0694
2016-02-19T08:04:00+00:00,S001,0.0449
2016-02-19T08:04:00+00:00,S002,1.6873
2016-02-19T08:04:00+00:00,S003,12.966
2016-02-19T08:04:01+00:00,S001,0.0694
2016-02-19T08:04:02+00:00,S001,0.0688
2016-02-19T08:04:03+00:00,S001,0.0694
2016-02-19T08:04:04+00:00,S001,0.0694
2016-02-19T08:04:05+00:00,S001,0.0386
2016-02-19T08:04:06+00:00,S001,0.0694
2016-02-19T08:04:07+00:00,S001,0.0694
2016-02-19T08:04:08+00:00,S001,0.0694
2016-02-19T08:04:09+00:00,S001,0.0694
2016-02-19T08:04:10+00:00,S001,0.0694
2016-02-19T08:04:11+00:00,S001,0.0694
2016-02-19T08:04:12+00:00,S001,0.0694
2016-02-19T08:04:13+00:00,S001,0.0694
2016-02-19T08:04:14+00:00,S001,0.0694
2016-02-19T08:04:15+00:00,S001,0.0694
2016-02-19T08:04:16+00:00,S001,0.0694
2016-02-19T08:04:17+00:00,S001,0.0694
2016-02-19T08:04:18+00:00,S001,0.0694
2016-02-19T08:04:19+00:00,S001,0.0503
2016-02-19T08:04:20+00:00,S001,0.032
2016-02-19T08:04:21+00:00,S001,0.0694
2016-02-19T08:04:22+00:00,S001,0.0339
2016-02-19T08:04:23+00:00,S001,0.0694
2016-02-19T08:04:24+00:00,S001,0.0572
2016-02-19T08:04:25+00:00,S001,0.0694

Maybe I need to create another Stream Engine?
Thanks.

Jean-Raphaël

[csvingos]

Hello Jean, If you get the appropriate output using the url this means that the problem isn't to the Stream Server. So no you mustn't create a new stream. Are you sure that the query didn't filters the other sensors? thanks, Christoforos

…

On Thu, Dec 1, 2016 at 2:28 PM JRV77 ***@***.***> wrote: Hi, How is the Stream generator behaving with a mix of sensors with different intervals for measurements? In the example below: S001 gets a value every second, S002 every 1 minute and S003 every 30 sec. I never get any answer from Starql queries for S002 and S003 even though I see them listed using http://docker-machine-ip:8989/measurement. *2016-02-19T08:03:00+00:00,S001,0.0421 2016-02-19T08:03:00+00:00,S002,1.5953 2016-02-19T08:03:00+00:00,S003,12.951* 2016-02-19T08:03:01+00:00,S001,0.0421 2016-02-19T08:03:02+00:00,S001,0.0694 2016-02-19T08:03:03+00:00,S001,0.0323 2016-02-19T08:03:04+00:00,S001,0.0694 2016-02-19T08:03:05+00:00,S001,0.0566 2016-02-19T08:03:06+00:00,S001,0.0694 2016-02-19T08:03:07+00:00,S001,0.0694 2016-02-19T08:03:08+00:00,S001,0.0694 2016-02-19T08:03:09+00:00,S001,0.0596 2016-02-19T08:03:10+00:00,S001,0.061 2016-02-19T08:03:11+00:00,S001,0.0587 2016-02-19T08:03:12+00:00,S001,0.0694 2016-02-19T08:03:13+00:00,S001,0.0177 2016-02-19T08:03:14+00:00,S001,0.0468 2016-02-19T08:03:15+00:00,S001,0.0694 2016-02-19T08:03:16+00:00,S001,0.0694 2016-02-19T08:03:17+00:00,S001,0.0694 2016-02-19T08:03:18+00:00,S001,0.054 2016-02-19T08:03:19+00:00,S001,0.0365 2016-02-19T08:03:20+00:00,S001,0.0694 2016-02-19T08:03:21+00:00,S001,0.0452 2016-02-19T08:03:22+00:00,S001,0.0694 2016-02-19T08:03:23+00:00,S001,0.0203 2016-02-19T08:03:24+00:00,S001,0.0694 2016-02-19T08:03:25+00:00,S001,0.0194 2016-02-19T08:03:26+00:00,S001,0.0694 2016-02-19T08:03:27+00:00,S001,0.0279 2016-02-19T08:03:28+00:00,S001,0.0593 2016-02-19T08:03:29+00:00,S001,0.0674 2016-02-19T08:03:30+00:00,S001,0.0674 *2016-02-19T08:03:30+00:00,S003,12.959* 2016-02-19T08:03:31+00:00,S001,0.0674 2016-02-19T08:03:32+00:00,S001,0.0694 2016-02-19T08:03:33+00:00,S001,0.0694 2016-02-19T08:03:34+00:00,S001,0.0523 2016-02-19T08:03:35+00:00,S001,0.0694 2016-02-19T08:03:36+00:00,S001,0.0437 2016-02-19T08:03:37+00:00,S001,0.0203 2016-02-19T08:03:38+00:00,S001,0.0694 2016-02-19T08:03:39+00:00,S001,0.0694 2016-02-19T08:03:40+00:00,S001,0.021 2016-02-19T08:03:41+00:00,S001,0.0205 2016-02-19T08:03:42+00:00,S001,0.0694 2016-02-19T08:03:43+00:00,S001,0.0315 2016-02-19T08:03:44+00:00,S001,0.0694 2016-02-19T08:03:45+00:00,S001,0.0315 2016-02-19T08:03:46+00:00,S001,0.0694 2016-02-19T08:03:47+00:00,S001,0.0559 2016-02-19T08:03:48+00:00,S001,0.0358 2016-02-19T08:03:49+00:00,S001,0.054 2016-02-19T08:03:50+00:00,S001,0.0694 2016-02-19T08:03:51+00:00,S001,0.0694 2016-02-19T08:03:52+00:00,S001,0.054 2016-02-19T08:03:53+00:00,S001,0.0632 2016-02-19T08:03:54+00:00,S001,0.0546 2016-02-19T08:03:55+00:00,S001,0.0239 2016-02-19T08:03:56+00:00,S001,0.0694 2016-02-19T08:03:57+00:00,S001,0.0634 2016-02-19T08:03:58+00:00,S001,0.0661 2016-02-19T08:03:59+00:00,S001,0.0694 2016-02-19T08:04:00+00:00,S001,0.0449 *2016-02-19T08:04:00+00:00,S002,1.6873 2016-02-19T08:04:00+00:00,S003,12.966* 2016-02-19T08:04:01+00:00,S001,0.0694 2016-02-19T08:04:02+00:00,S001,0.0688 2016-02-19T08:04:03+00:00,S001,0.0694 2016-02-19T08:04:04+00:00,S001,0.0694 2016-02-19T08:04:05+00:00,S001,0.0386 2016-02-19T08:04:06+00:00,S001,0.0694 2016-02-19T08:04:07+00:00,S001,0.0694 2016-02-19T08:04:08+00:00,S001,0.0694 2016-02-19T08:04:09+00:00,S001,0.0694 2016-02-19T08:04:10+00:00,S001,0.0694 2016-02-19T08:04:11+00:00,S001,0.0694 2016-02-19T08:04:12+00:00,S001,0.0694 2016-02-19T08:04:13+00:00,S001,0.0694 2016-02-19T08:04:14+00:00,S001,0.0694 2016-02-19T08:04:15+00:00,S001,0.0694 2016-02-19T08:04:16+00:00,S001,0.0694 2016-02-19T08:04:17+00:00,S001,0.0694 2016-02-19T08:04:18+00:00,S001,0.0694 2016-02-19T08:04:19+00:00,S001,0.0503 2016-02-19T08:04:20+00:00,S001,0.032 2016-02-19T08:04:21+00:00,S001,0.0694 2016-02-19T08:04:22+00:00,S001,0.0339 2016-02-19T08:04:23+00:00,S001,0.0694 2016-02-19T08:04:24+00:00,S001,0.0572 2016-02-19T08:04:25+00:00,S001,0.0694 Maybe I need to create another Stream Engine? Thanks. Jean-Raphaël — You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub <#11>, or mute the thread <https://github.com/notifications/unsubscribe-auth/ALRKVTKenbEoGQcG3zyh19TdeBy92qtbks5rDr1tgaJpZM4LBVcW> .

[JRV77]

Hi, Thanks for quick answer. You're right, the Stream Server itself seems to produce the streams but I understood earlier that event stream had to be cleaned up so that the timeframe would be more "predictable", can it be the same kind of issue or should have posted the question on the Exareme github? The Starql query looks ok and the unfolded SQL looks ok and identical to the one for sensor S001. The inner query (RDBMS part) gives an answer. What I don't know is if the "CREATE STREAM measurement AS WCACHE SELECT * FROM (newtimeslidingwindow timecolumn:0 timewindow:10 frequency:1 granularity:1 equivalence:floor SELECT cast(strftime('%s', timestamp) as float) as epoch, * FROM (file dialect:json 'http://streamserver:8989/measurement'));" retrieves some values for S003. cheers, Jean-Raphaël

________________________________ De : csvingos <notifications@github.com> Envoyé : jeudi 1 décembre 2016 13:51:32 À : madgik/Docker-StreamServer Cc : JRV77; Author Objet : Re: [madgik/Docker-StreamServer] Different frequences for different sensors (#11) Hello Jean, If you get the appropriate output using the url this means that the problem isn't to the Stream Server. So no you mustn't create a new stream. Are you sure that the query didn't filters the other sensors? thanks, Christoforos

On Thu, Dec 1, 2016 at 2:28 PM JRV77 ***@***.***> wrote: Hi, How is the Stream generator behaving with a mix of sensors with different intervals for measurements? In the example below: S001 gets a value every second, S002 every 1 minute and S003 every 30 sec. I never get any answer from Starql queries for S002 and S003 even though I see them listed using http://docker-machine-ip:8989/measurement. *2016-02-19T08:03:00+00:00,S001,0.0421 2016-02-19T08:03:00+00:00,S002,1.5953 2016-02-19T08:03:00+00:00,S003,12.951* 2016-02-19T08:03:01+00:00,S001,0.0421 2016-02-19T08:03:02+00:00,S001,0.0694 2016-02-19T08:03:03+00:00,S001,0.0323 2016-02-19T08:03:04+00:00,S001,0.0694 2016-02-19T08:03:05+00:00,S001,0.0566 2016-02-19T08:03:06+00:00,S001,0.0694 2016-02-19T08:03:07+00:00,S001,0.0694 2016-02-19T08:03:08+00:00,S001,0.0694 2016-02-19T08:03:09+00:00,S001,0.0596 2016-02-19T08:03:10+00:00,S001,0.061 2016-02-19T08:03:11+00:00,S001,0.0587 2016-02-19T08:03:12+00:00,S001,0.0694 2016-02-19T08:03:13+00:00,S001,0.0177 2016-02-19T08:03:14+00:00,S001,0.0468 2016-02-19T08:03:15+00:00,S001,0.0694 2016-02-19T08:03:16+00:00,S001,0.0694 2016-02-19T08:03:17+00:00,S001,0.0694 2016-02-19T08:03:18+00:00,S001,0.054 2016-02-19T08:03:19+00:00,S001,0.0365 2016-02-19T08:03:20+00:00,S001,0.0694 2016-02-19T08:03:21+00:00,S001,0.0452 2016-02-19T08:03:22+00:00,S001,0.0694 2016-02-19T08:03:23+00:00,S001,0.0203 2016-02-19T08:03:24+00:00,S001,0.0694 2016-02-19T08:03:25+00:00,S001,0.0194 2016-02-19T08:03:26+00:00,S001,0.0694 2016-02-19T08:03:27+00:00,S001,0.0279 2016-02-19T08:03:28+00:00,S001,0.0593 2016-02-19T08:03:29+00:00,S001,0.0674 2016-02-19T08:03:30+00:00,S001,0.0674 *2016-02-19T08:03:30+00:00,S003,12.959* 2016-02-19T08:03:31+00:00,S001,0.0674 2016-02-19T08:03:32+00:00,S001,0.0694 2016-02-19T08:03:33+00:00,S001,0.0694 2016-02-19T08:03:34+00:00,S001,0.0523 2016-02-19T08:03:35+00:00,S001,0.0694 2016-02-19T08:03:36+00:00,S001,0.0437 2016-02-19T08:03:37+00:00,S001,0.0203 2016-02-19T08:03:38+00:00,S001,0.0694 2016-02-19T08:03:39+00:00,S001,0.0694 2016-02-19T08:03:40+00:00,S001,0.021 2016-02-19T08:03:41+00:00,S001,0.0205 2016-02-19T08:03:42+00:00,S001,0.0694 2016-02-19T08:03:43+00:00,S001,0.0315 2016-02-19T08:03:44+00:00,S001,0.0694 2016-02-19T08:03:45+00:00,S001,0.0315 2016-02-19T08:03:46+00:00,S001,0.0694 2016-02-19T08:03:47+00:00,S001,0.0559 2016-02-19T08:03:48+00:00,S001,0.0358 2016-02-19T08:03:49+00:00,S001,0.054 2016-02-19T08:03:50+00:00,S001,0.0694 2016-02-19T08:03:51+00:00,S001,0.0694 2016-02-19T08:03:52+00:00,S001,0.054 2016-02-19T08:03:53+00:00,S001,0.0632 2016-02-19T08:03:54+00:00,S001,0.0546 2016-02-19T08:03:55+00:00,S001,0.0239 2016-02-19T08:03:56+00:00,S001,0.0694 2016-02-19T08:03:57+00:00,S001,0.0634 2016-02-19T08:03:58+00:00,S001,0.0661 2016-02-19T08:03:59+00:00,S001,0.0694 2016-02-19T08:04:00+00:00,S001,0.0449 *2016-02-19T08:04:00+00:00,S002,1.6873 2016-02-19T08:04:00+00:00,S003,12.966* 2016-02-19T08:04:01+00:00,S001,0.0694 2016-02-19T08:04:02+00:00,S001,0.0688 2016-02-19T08:04:03+00:00,S001,0.0694 2016-02-19T08:04:04+00:00,S001,0.0694 2016-02-19T08:04:05+00:00,S001,0.0386 2016-02-19T08:04:06+00:00,S001,0.0694 2016-02-19T08:04:07+00:00,S001,0.0694 2016-02-19T08:04:08+00:00,S001,0.0694 2016-02-19T08:04:09+00:00,S001,0.0694 2016-02-19T08:04:10+00:00,S001,0.0694 2016-02-19T08:04:11+00:00,S001,0.0694 2016-02-19T08:04:12+00:00,S001,0.0694 2016-02-19T08:04:13+00:00,S001,0.0694 2016-02-19T08:04:14+00:00,S001,0.0694 2016-02-19T08:04:15+00:00,S001,0.0694 2016-02-19T08:04:16+00:00,S001,0.0694 2016-02-19T08:04:17+00:00,S001,0.0694 2016-02-19T08:04:18+00:00,S001,0.0694 2016-02-19T08:04:19+00:00,S001,0.0503 2016-02-19T08:04:20+00:00,S001,0.032 2016-02-19T08:04:21+00:00,S001,0.0694 2016-02-19T08:04:22+00:00,S001,0.0339 2016-02-19T08:04:23+00:00,S001,0.0694 2016-02-19T08:04:24+00:00,S001,0.0572 2016-02-19T08:04:25+00:00,S001,0.0694 Maybe I need to create another Stream Engine? Thanks. Jean-Raphaël - You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub <#11>, or mute the thread <https://github.com/notifications/unsubscribe-auth/ALRKVTKenbEoGQcG3zyh19TdeBy92qtbks5rDr1tgaJpZM4LBVcW> .

- You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub<#11 (comment)>, or mute the thread<https://github.com/notifications/unsubscribe-auth/AO7UwuwqOfIHR-GcAPSVrGwVfcQpqzgDks5rDtDkgaJpZM4LBVcW>.