Hey @leonh, regarding your first question, if you are using v0.4.0, it is possible to see registered executions using 'RG.DUMPREGISTRATIONS' command (https://oss.redislabs.com/redisgears/commands.html#rgdumpregistrations) then you can unregistered a specific registration using 'RG.UNREGISTER' (https://oss.redislabs.com/redisgears/commands.html#rgunregister). Notice that each time a registration is triggered it creates an execution, those executions can be managed using 'RG.DUMPEXECUTIONS', 'RG.GETEXECUTION' and 'RG.DROPEXECUTION'.
Regarding examples, there is a very small and simple examples here: https://oss.redislabs.com/redisgears/examples.html.
For more complex examples, take a look at those links:
I've been a Redis fan for a while, and this provides some great new abilities. I'm able to make everything work except the StreamReader. Using the Basic Redis Stream Processing example found here: https://oss.redislabs.com/redisgears/examples.html#basic-redis-stream-processing
Should I have to do anything more except publish to 'mystream'?
bin/linux-x64-release/python3_<version>from my local machine!
.foreach(lambda x: ...)gives
xas the batch of the size specified in the
.register, however, I'm getting each record replayed one by one ... how can I process entire batch at once?
gb = GearsBuilder("StreamReader") gb.foreach(lambda x: process_batch(x)) gb.register("livestream:*", trimStream=False, batch=STREAM_BATCH_SIZE)
def process_stream(x): print(x['key'])