Skip to content

Zenoh Python bindings

1
pip install eclipse-zenoh

Examples

Pub/Sub

Simple pub sub

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
import zenoh
import time
import multiprocessing

KEY_EXPRESSION = "demo/example"

def publisher():
    config = zenoh.Config()
    session = zenoh.open(config)
    pub = session.declare_publisher(KEY_EXPRESSION)
    while True:
        pub.put('Hello, Zenoh!')
        time.sleep(1)

def subscriber():
    config = zenoh.Config()
    session = zenoh.open(config)
    sub = session.declare_subscriber(KEY_EXPRESSION, lambda sample: print(f'Received: {sample.payload.to_string()}'))
    while True:
        time.sleep(1)

if __name__ == '__main__':
    pub_process = multiprocessing.Process(target=publisher)
    sub_process = multiprocessing.Process(target=subscriber)

    pub_process.start()
    sub_process.start()

    pub_process.join()
    sub_process.join()