一个小型的点对点数据流库
simplestreamer的Python项目详细描述
#简单团队
这是一个小型（<；150 loc）对等数据流库，专为高频状态数据设计。 它使用pickle底层来序列化数据，因此您可以通过它转储任何python对象。
你可以用 pip install simplestreamer
下面是一个如何使用它的快速示例。希望这足够不言自明了。
节点1代码：
# just dumps time data into the streamer at 100 hz
import simplestreamer
import time
streamer = simplestreamer.SimpleStreamer(5200)
while True:
streamer.send_data({"current time.time()": time.time()})
time.sleep(0.01)
节点2（以及3、4等）代码：
# subscribes to the stream from node 1 and periodically reads the data
import simplestreamer
import time
streamer = simplestreamer.SimpleStreamer(5201)
streamer.subscribe("127.0.0.1", 5200, "streamer 1")
# You can optionally configure the rate at which the remote streamer sends you data
#streamer.subscribe("127.0.0.1", 5200, "streamer 1", updates_per_sec=1.5)
while True:
print(streamer.get_data("streamer 1"))
time.sleep(0.5)
欢迎加入QQ群-->： 979659372
