Python Zenoh Flow API

Zenoh Flow provides a Zenoh-based dataflow programming framework for computations that span from the cloud to the device.

⚠️ This software is still in alpha status and should not be used in production. Breaking changes are likely to happen and the API is not stable.

Requirements

• Rust: see the installation page
• a matching version of libpython. On linux systems, it's typically packaged separately as ``libpython3.x-devorpython3.x-dev`.
• Python >= 3.7
• pip >= 22
• virtualenv

How to build

Create and activate a python virtual environment:

$ python3 -m virtualenv venv
$ source venv/bin/activate

Build the Python Wheel within a Python virtual environment.

$ python3 -m venv venv
$ source venv/bin/activate
(venv) $ git clone https://github.com/atolab/zenoh-flow-python
(venv) $ cd zenoh-flow-python/zenoh-flow-python
(venv) $ pip3 install -r requirements-dev.txt
(venv) $ maturin build --release

Deactivate the venv and install the python bindings.

(venv) deactivate
$ pip3 install ./target/wheels/<there should only be one .whl file here>

Build the wrappers

Build the Python wrappers.

⚠️ Python Wrappers SHOULD NOT be built within a Python virtual environment

$ cargo build --release -p py-op -p py-sink -p py-source

Build the docs

Once you have installed the Python binding you can also generate the documentation.

$ cd docs
$ pip3 install sphinx_rtd_theme sphinx -y
$ make html

The docs will be available under _build/html/index.html.

Run an example

Clone, build and install Zenoh Flow, and then use the provided py-pipeline.yml example to run it.

💡 Note that you actually only need to update the paths in py-pipeline.yml file.

$ zfctl launch py-pipeline.yml