Hello Philipp, thanks for your prompt response. I think the source of my problem was some kind of "overlap" of various Streampipes versions (0.66, 0.67, compose, cli, etc...). I've done a total prune (images, containers, volumes, etc), and switched to the cli version 0.67 full, now everything works fine.
Probably the misleading fact was that i've manually installed the Frequency Counter over a minimal compose installation and something was missed, because the attribute selector once you insert the processor was empty, so subsequently it was not able to push the event/message to the next step. Once reinstalled the full version, the processor works as expected, providing a list of attributes coming from the previous node (an mqtt source). So my fault :) To answer your question about the process, i'm trying to simulate a stream where i send an MQTT message with a "device error" status when a light was blinking, and then a "device ready" status when the light goes off. The blinking status is coming from a remote I/O (Moxa 1212) that reads the light, there's then a python script that reads the ModBus and send an mqtt "blink" any time the light change its state. Now that i've solved the frequency counter problem i've two new tasks to complete: - remove the python modbus part and read the Moxa using PLC4X - understand how to keep the last status sent (device error/device ready) cause i've to send the MQTT message with the status just once on change. Usually i do this kind of things in Flink saving the information inside the context state. Thank you for your support, any insight or hint you would provide is welcome! Greetings, Alessio On Sat, Jan 30, 2021 at 3:29 PM Philipp Zehnder <[email protected]> wrote: > Hi Alessio, > > welcome to the mailing list and thank you for writing us and reporting the > problem. > > That is a strange behavior and I will look into it. > You should always be able to use the dashboard sink. This is also the one > I usually use for testing pipelines. > > Can you please provide me with some more information? > Which StreamPipes version are you using and did you install it the “light” > (this is the default) or “full" version? > What is the exact name of the processor that is not working? > > Can you also tell me what is the goal you want to achieve? > Do you want to get a total count of events of a specific topic, or are you > rather interested in a frequency (e.g. Events / second)”? > > We really appreciate your feedback, so please do not hesitate to contact > us if there are any other problems / questions. > > Philipp > > > > > On 30. Jan 2021, at 13:55, Alessio Bernesco Làvore < > [email protected]> wrote: > > > > Hi everyone, > > > > i'm trying to count how many MQTT messages are landing on a topic. > > > > I just created the MQTT connector, if i pass it directly, for example, > to the Notification Sink everything works fine, i see the variables > extracted from the mqtt message. > > > > If i try to insert in the middle a Frequency Counter then i cannot find > a sink able to process the output. > > > > How i'm supposed to use this processor? > > > > Greetings, > > Alessio > >
