Question

Win 10 x64,pill 3.10

The publisher code,

# z_sensor.py

import zenoh, random, time

random.seed()

def read_temp():
    return random.randint(15, 30)

if __name__ == "__main__":
    session = zenoh.open()
    key =  myhome/kitchen/temp 
    pub = session.declare_publisher(key)
    while True:
        t = read_temp()
        buf = f"{t}"
        print(f"Putting Data ( {key} :  {buf} )...")
        pub.put(buf)
        time.sleep(1)

用户代码,

# z_subsciber.py

import zenoh, time

def listener(sample):
    print(f"Received {sample.kind} ( {sample.key_expr} :  {sample.payload.decode( utf-8 )} )")

if __name__ == "__main__":
    session = zenoh.open()
    sub = session.declare_subscriber( myhome/kitchen/temp , listener)
    time.sleep(60)

我开始修建2个Anaconda指挥窗口和营地;在这两处都启动我的Zeoh环境。

我在第一个窗口中操作用户代码,然后在第二个窗口中由出版商操作。

出版商窗口正在推出数据与册;按预期印刷到窗户,

Putting Data ( myhome/kitchen/temp :  28 )...
Putting Data ( myhome/kitchen/temp :  27 )...
Putting Data ( myhome/kitchen/temp :  25 )...
Putting Data ( myhome/kitchen/temp :  16 )...
Putting Data ( myhome/kitchen/temp :  19 )...
Putting Data ( myhome/kitchen/temp :  25 )...
Putting Data ( myhome/kitchen/temp :  28 )...
.....

但是,用户窗口没有任何东西。听众的职能没有印刷版。

在安装了Rust仪器后,我安装了pip。

Anyone know what s going on here?

Answer 1

如果你在没有任何参数的情况下说明这个例子,他们就会试图通过多播种的排出而发现,因此需要使多播种成为可能。视窗违约后,视窗防火墙不允许。

你可以尝试利用定位器确保多播音确实是问题。

3. 改变用户对特定港口的聆听:

import zenoh, time, json

def listener(sample):
    print(f"Received {sample.kind} ( {sample.key_expr} :  {sample.payload.decode( utf-8 )} )")

if __name__ == "__main__":
    cfg = zenoh.Config()
    cfg.insert_json5(zenoh.config.LISTEN_KEY, json.dumps(["tcp/127.0.0.1:7447"]))
    session = zenoh.open(cfg)
    sub = session.declare_subscriber( myhome/kitchen/temp , listener)
    while True:
        time.sleep(60)

以及你的传感器与这一用户连接:

import zenoh, random, time, json

random.seed()

def read_temp():
    return random.randint(15, 30)

if __name__ == "__main__":
    cfg = zenoh.Config()
    cfg.insert_json5(zenoh.config.CONNECT_KEY, json.dumps(["tcp/127.0.0.1:7447"]))
    session = zenoh.open()
    key =  myhome/kitchen/temp 
    pub = session.declare_publisher(key)
    while True:
        t = read_temp()
        buf = f"{t}"
        print(f"Putting Data ( {key} :  {buf} )...")
        pub.put(buf)
        time.sleep(1)

如果能做到这一点,那么,你需要能够在Windows防火墙上进行多播。

友情链接