Francesco Boscarino

I think it should be possible to define notification id (actually is fixed to 1) in push message itself, this way is possible to send multiple push without loosing them.

System window by key

1

Hi, I've setup a pipeline to process messages coming from sensors over MQTT. Messages are sent every second and I would like to have the max value over 1 minute...

nodeUnselected event does not report id

1

It would very useful, especially when it is possible to select multiple nodes at a time, to report unselected nodes id. Same should apply for nodeSelected if multiple selection is...

Send only if value changes does not work

2

Hi, I upgraded from a very old version of zigbee2mqtt and nodes and now, even with cache_state: false in configuration.xml, I receive all the states from the devices. I tried...

Propose: add interpolation to output inproc

1

Having bloblang interpolation for inproc output would avoid having a long switch with every possible value. Use case is a kafka input which should route to different stream based on...

INFO[0000] Starting sync INFO[0001] Sync file Content-Type=image/jpeg key=weapons/DSC_0001.JPG size=1127801 panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x8d87e6] goroutine 83 [running]: github.com/larrabee/s3sync/pipeline/collection.glob..func17(0x0?,...

provided "value" is invalid using fetch with dynamic value

1

Hi, I have a select like this: ``` ``` `tag` and `q` will depend on other fields and when they change the select will re-do the fetch but if at...

Redis processor fails with HGETALL

5

Hi, I was trying to use redid processor with command HGETALL to retrieve all the fields and values inside an hashset but the processor return always nothing (it prints a...

Save streams configured with HTTP

2

Hi, I have a requirement for using benthos as a dynamic processor inside kubernetes. The idea is to have an external tool which will deploy a number of streams on...