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:
https://github.com/RedisGears/AnimalRecognitionDemo
https://github.com/RedisGears/EdgeRealtimeVideoAnalytics
https://github.com/RedisGears/MultiModelExample
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 x
as 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)
gear_builder.foreach(process_stream).register('test:db')
def process_stream(x):
print(x['key'])