Eclipse Zenoh

Eclipse Zenoh：零开销的发布/订阅、存储/查询和计算。

Zenoh（发音为/zeno/）统一了动态数据、静态数据和计算。它将传统的发布/订阅与地理分布存储、查询和计算巧妙地结合在一起，同时保持了超越任何主流堆栈的时间空间效率。

查看网站 zenoh.io 和 路线图 获取更多信息。

InfluxDB后端

在Zenoh中，后端是一种存储技术（如DBMS、时序数据库、文件系统等），允许通过Zenoh存储键/值发布，并在查询时返回它们。有关更多信息，请参阅Zenoh文档。

此后端依赖于InfluxDB服务器来实施存储。Zenoh将依赖于以下名称（无操作系统特定前缀和扩展）来查找并加载它：zenoh_backend_influxdb。

👉 安装最新版本：请参阅下面

👉 构建"master"分支：请参阅下面

⚠️尚不支持InfluxDB 2.x。需要InfluxDB 1.8最低版本。

⚠️旧版本0.5的文档

以下是与"master"分支中当前正在开发的0.6.x版本相关的文档。

有关旧版本，请参阅相应标记版本的README和代码

• 0.5.0-beta.9
• 0.5.0-beta.8

使用示例

先决条件

• 您已安装zenoh路由器（zenohd），并且zenoh_backend_influxdb库文件位于~/.zenoh/lib。
• 您有一个运行在https://127.0.0.1:8086上的InfluxDB服务。

您可以通过配置文件在 Zenoh 路由器启动时设置存储，也可以通过 Zenoh 管理空间在运行时设置，例如使用 REST API。

通过 JSON5 配置文件设置

• 创建一个 zenoh.json5 配置文件，例如

  {
    plugins: {
      // configuration of "storage_manager" plugin:
      storage_manager: {
        volumes: {
          // configuration of a "influxdb" volume (the "zenoh_backend_influxdb" backend library will be loaded at startup)
          influxdb: {
            // URL to the InfluxDB service
            url: "https://127.0.0.1:8086",
            private: {
              // If needed: InfluxDB credentials, preferably admin for databases creation and drop
              //username: "admin",
              //password: "password"
            }
          }
        },
        storages: {
          // configuration of a "demo" storage using the "influxdb" volume
          demo: {
            // the key expression this storage will subscribes to
            key_expr: "demo/example/**",
            // this prefix will be stripped from the received key when converting to database key.
            // i.e.: "demo/example/a/b" will be stored as "a/b"
            // this option is optional
            strip_prefix: "demo/example",
            volume: {
              id: "influxdb",
              // the database name within InfluxDB
              db: "zenoh_example",
              // if the database doesn't exist, create it
              create_db: true,
              // strategy on storage closure
              on_closure: "drop_db",
              private: {
                // If needed: InfluxDB credentials, with read/write privileges for the database
                //username: "user",
                //password: "password"
              }
            }
          }
        }
      },
      // Optionally, add the REST plugin
      rest: { http_port: 8000 }
    }
  }
  

• 使用以下命令运行 Zenoh 路由器
  zenohd-c zenoh.json5

通过 curl 命令在管理空间中设置

• 运行 Zenoh 路由器，并具有写入其管理空间的权限
  zenohd--adminspace-permissions rw
• 添加 "influxdb" 卷（将加载 "zenoh_backend_fs" 库），连接到位于 https://127.0.0.1:8086 的 InfluxDB 服务：curl -X PUT -H 'content-type:application/json' -d '{url:"https://127.0.0.1:8086"}' https://127.0.0.1:8000/@/router/local/config/plugins/storage_manager/volumes/influxdb
• 使用 "influxdb" 卷添加 "demo" 存储：curl -X PUT -H 'content-type:application/json' -d '{key_expr:"demo/example/**",volume:{id:"influxdb",db:"zenoh_example",create_db:true}}' https://127.0.0.1:8000/@/router/local/config/plugins/storage_manager/storages/demo

使用 REST API 进行测试

使用 curl 发布和查询键/值，您可以

# Put some values at different time intervals
curl -X PUT -d "TEST-1" https://127.0.0.1:8000/demo/example/test
curl -X PUT -d "TEST-2" https://127.0.0.1:8000/demo/example/test
curl -X PUT -d "TEST-3" https://127.0.0.1:8000/demo/example/test

# Retrive them as a time serie where '_time=[..]' means "infinite time range"
curl -g 'https://127.0.0.1:8000/demo/example/test?_time=[..]'

卷配置

基于 InfluxDB 的卷需要一些配置才能工作

• "url" (必需)：InfluxDB 服务的 URL。示例：https://127.0.0.1:8086

• "username"（可选）：InfluxDB 管理员用户名。它将被用于创建数据库、授予映射到存储的数据库的读写权限以及删除数据库和度量。

• "password"（可选）：管理员用户的密码。

应将 username 和 password 隐藏在 private 门后面，如上面示例所示。一般来说，如果您希望配置查询时隐藏配置的一部分，您应将其隐藏在 private 门后面。

特定于卷的存储配置

依赖于基于 influxdb 的卷的存储可能通过 volume 部分进行额外的配置

• "db"（可选，字符串）："db" 存储将映射到的 InfluxDB 数据库名。如果没有指定，将生成随机名称，并将创建相应的数据库（即使未设置 "create_db"）。

• "create_db" (可选，布尔型) : 如果数据库不存在则创建InfluxDB数据库。默认情况下不会创建数据库，除非指定了"db"属性。(值不重要，只需检查属性是否存在)

• "on_closure" (可选，字符串) : 当Storage被移除时使用的策略。有3个选项

  • 未设置 或 "do_nothing"：数据库保持不变（这是默认行为）
  • "drop_db"：删除数据库（即移除）
  • "drop_series"：删除所有系列（测量），数据库保持为空。

• "username" (可选，字符串) : InfluxDB用户名（通常是非管理员）。它将用于GET/PUT/DELETE zenoh操作中数据库的读写。

• "password" (可选，字符串) : 用户的密码。

  # get the complete time-series
  /demo/example/**?_time=[..]

  # get points within a fixed date interval
  /demo/example/influxdb/**?_time=[2020-01-01T00:00:00Z..2020-01-02T12:00:00.000000000Z]

  # get points within a relative date interval
  /demo/example/influxdb/**?_time=[now(-2d)..now(-1d)]

echo "deb [trusted=yes] https://download.eclipse.org/zenoh/debian-repo/ /" | sudo tee -a /etc/apt/sources.list > /dev/null
sudo apt update
sudo apt install zenoh-backend-influxdb

$ rustup update

$ zenohd --version
The zenoh router v0.6.0-beta.1 built with rustc 1.64.0 (a55dd71d5 2022-09-19)

$ rustup default 1.64.0

$ cargo update -p zenoh --precise 1f20c86

$ cargo build --release --all-targets