15 lines
470 B
Python
15 lines
470 B
Python
import base64
|
|
import numpy
|
|
|
|
#"localhost:5554”
|
|
pipeline_client = PipelineClient("http://0.0.0.0:8889")
|
|
instance_id, pipeline_stream_address = pipeline_client.create_instance_from_name("simulation_sp", "simulation_sp3")
|
|
pipeline_host, pipeline_port = get_host_port_from_stream_address(pipeline_stream_address)
|
|
|
|
# Subscribe to the stream.
|
|
with source(host=pipeline_host, port=pipeline_port, mode=SUB) as stream:
|
|
# Receive next message.
|
|
data = stream.receive()
|
|
|
|
|
|
|