Looking for some input on using plasma.
We're trying to set up a system where a scala/JVM process adds objects
to Plasma, and then a separate Python process consumes the objects.
The Python piece currently looks something like this:
client = plasma.connect(...)
client.subscribe()
while True:
object_id, data_size, meta_size = client.get_next_notification()
if data_size >= 0:
data, = client.get_buffers([object_id])
# do stuff with data
client.delete([object_id])
Is this a reasonable way to approach using plasma? Is there a better way
to do this? Are we going to run in to any problems with this approach?
Thanks!
Eric
