Run a Zenoh based service into a custom Docker

[edgarriba]

hi! I have my own application for camera streaming which is implemented as a standole service as I want to integrate different protocols e.g Zenoh along with gRPC.

For this application, I need to have my custom dockerfile based on a nvidia image in order to install a bunch of system dependencies. I tried to run my service in that dockerfile as follows:

docker run -d \
    --name myapp \
    --privileged \
    --restart=unless-stopped \
    -p 50051:50051 \
    -p 7447:7447/tcp \
    -p 8000:8000/tcp \
    myapp

The server is running and no problem, however when I want to subscribe from a client in python from the outside, I'm not able to connect properly to the session. I attach a snippet similar to what I'm doing:

# establish a connection to the server
config = zenoh.Config()
config.insert_json5("mode", json.dumps(args.mode))
config.insert_json5("connect/endpoints", json.dumps(args.connect))

# create a subscriber
sub = session.declare_subscriber(
    "camera/0/frame", on_frame, reliability=zenoh.Reliability.RELIABLE
)

Then I run as follows: python py/client_zenoh.py -e tcp/localhost:7447 -m peer

NOTE: the server and then connecting with the client it works outside of the dockerfile. But I need to run it inside the docker to facilitate the deployment of this app.

Any help or tips are welcomed!

[gabrik]

Hi @edgarriba, can you share the Zenoh configuration of the "server side" along with the error you are getting when trying to connect?
Also please run with RUST_LOG=z=debug so we can have more info

[edgarriba]

hi @gabrik , thanks for replying. Here is the log i get from my server:

[2024-09-13T09:33:36Z DEBUG zenoh::api::session] Config: Config { id: 6a4db9a6f2c98efe6878b3bfa8197327, metadata: Null, mode: Some(Peer), connect: ConnectConfig { timeout_ms: None, endpoints: Unique([]), exit_on_failure: None, retry: None }, listen: ListenConfig { timeout_ms: None, endpoints: Dependent(ModeValues { router: Some([tcp/[::]:7447]), peer: Some([tcp/[::]:0]), client: None }), exit_on_failure: None, retry: None }, scouting: ScoutingConf { timeout: None, delay: None, multicast: ScoutingMulticastConf { enabled: None, address: None, interface: None, ttl: None, autoconnect: None, listen: None }, gossip: GossipConf { enabled: None, multihop: None, autoconnect: None } }, timestamping: TimestampingConf { enabled: None, drop_future_timestamp: None }, queries_default_timeout: None, routing: RoutingConf { router: RouterRoutingConf { peers_failover_brokering: None }, peer: PeerRoutingConf { mode: None } }, aggregation: AggregationConf { subscribers: [], publishers: [] }, transport: TransportConf { unicast: TransportUnicastConf { accept_timeout: 10000, accept_pending: 100, max_sessions: 1000, max_links: 1, lowlatency: false, qos: QoSUnicastConf { enabled: true }, compression: CompressionUnicastConf { enabled: false } }, multicast: TransportMulticastConf { join_interval: Some(2500), max_sessions: Some(1000), qos: QoSMulticastConf { enabled: false }, compression: CompressionMulticastConf { enabled: false } }, link: TransportLinkConf { protocols: None, tx: LinkTxConf { sequence_number_resolution: U32, lease: 10000, keep_alive: 4, batch_size: 65535, queue: QueueConf { size: QueueSizeConf { control: 1, real_time: 1, interactive_high: 1, interactive_low: 1, data_high: 2, data: 4, data_low: 2, background: 1 }, congestion_control: CongestionControlConf { wait_before_drop: 1000 }, batching: BatchingConf { enabled: true, time_limit: 1 } }, threads: 1 }, rx: LinkRxConf { buffer_size: 65535, max_message_size: 1073741824 }, tls: TLSConf { root_ca_certificate: None, server_private_key: None, server_certificate: None, client_auth: None, client_private_key: None, client_certificate: None, server_name_verification: None, root_ca_certificate_base64: None, server_private_key_base64: None, server_certificate_base64: None, client_private_key_base64: None, client_certificate_base64: None }, unixpipe: UnixPipeConf { file_access_mask: None } }, shared_memory: ShmConf { enabled: true }, auth: AuthConf { usrpwd: UsrPwdConf { user: None, password: None, dictionary_file: None }, pubkey: PubKeyConf { public_key_pem: None, private_key_pem: None, public_key_file: None, private_key_file: None, key_size: None, known_keys_file: None } } }, adminspace: AdminSpaceConf { enabled: false, permissions: PermissionsConf { read: true, write: false } }, downsampling: [], access_control: AclConfig { enabled: false, default_permission: Deny, rules: None, subjects: None, policies: None }, plugins_loading: PluginsLoading { enabled: false, search_dirs: LibSearchDirs([Spec(LibSearchSpec { kind: CurrentExeParent, value: None }), Path("."), Path("~/.zenoh/lib"), Path("/opt/homebrew/lib"), Path("/usr/local/lib"), Path("/usr/lib")]) }, plugins: Object {} }
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime] Zenoh Rust API v1.0.0-beta.1
[2024-09-13T09:33:36Z INFO  zenoh::net::runtime] Using ZID: 6a4db9a6f2c98efe6878b3bfa8197327
[2024-09-13T09:33:36Z DEBUG zenoh::net::routing::interceptor::access_control] Access control is disabled
[2024-09-13T09:33:36Z DEBUG zenoh::net::routing::hat::p2p_peer::gossip] [Gossip] Add node (self) 6a4db9a6f2c98efe6878b3bfa8197327
[2024-09-13T09:33:36Z DEBUG zenoh::net::routing::router] New Face{0, 6a4db9a6f2c98efe6878b3bfa8197327}
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] Try to add listener: tcp/[::]:0: ConnectionRetryConf { exit_on_failure: true, period_init_ms: 1000, period_max_ms: 4000, period_increase_factor: 2.0 }
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] Listener added: tcp/[::]:44843
[2024-09-13T09:33:36Z INFO  zenoh::net::runtime::orchestrator] Zenoh can be reached at: tcp/172.17.0.2:44843
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] UDP port bound to 224.0.0.224:7446
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] Joined multicast group 224.0.0.224 on interface 172.17.0.2
[2024-09-13T09:33:36Z INFO  zenoh::net::runtime::orchestrator] zenohd listening scout messages on 224.0.0.224:7446
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] UDP port bound to 172.17.0.2:56756
[2024-09-13T09:33:36Z DEBUG zenoh::net::runtime::orchestrator] Waiting for UDP datagram...
[2024-09-13T09:33:37Z DEBUG zenoh::net::routing::dispatcher::interests] Face{0, 6a4db9a6f2c98efe6878b3bfa8197327} Declare interest 2 (camera/0/frame)
[2024-09-13T09:33:37Z DEBUG zenoh::net::routing::hat::p2p_peer::interests] Propagate DeclareFinal Face{0, 6a4db9a6f2c98efe6878b3bfa8197327}:2

as for the config, I'm using the defaults as follows:

let zenoh_session = zenoh::open(zenoh::config::default())
        .await
        .map_err(|e| ServerError::FailedToStartZenohSession(e.to_string()))?;

[gabrik]

You are missing the actual listening locator, on your server side, please add something like tcp/[::]:7447 in your server configuration.
Please refer to documentation on how to configure a listener: https://docs.rs/zenoh/latest/zenoh/prelude/struct.Config.html

[edgarriba]

that worked ! thanks !