bq-nats-client

Python gRPC client for the NATS Go daemon. Exposes publish, subscribe, and JetStream operations via a thin async API that mirrors nats.py.

Architecture

Python app  ──gRPC (Bearer JWT)──►  Go daemon  ──NATS──►  NATS server

The Go daemon runs as its own deployment and owns the NATS connection. This library only connects to it over gRPC — it does not start or bundle the daemon. On the first call the client authenticates with its api-key, gets a short-lived JWT, and attaches it to every request automatically.

Install

pip install bq-nats-client

Configuration

The client reads these env vars (explicit constructor args take precedence):

Usage

import asyncio
from nats_client import NATSClient, Msg

async def main():
    # grpc_addr + api_key come from env, or pass explicitly:
    nc = NATSClient(grpc_addr="localhost:50052", api_key="<prime-api-key>")

    # plain publish
    await nc.publish("orders.new", b'{"id": 1}')

    # JetStream
    await nc.jetstream()
    ack = await nc.js_publish("orders.new", b'{"id": 2}')
    print(f"ack: stream={ack.stream} seq={ack.seq}")

    # subscribe
    async def on_msg(msg: Msg):
        print(f"[{msg.subject}] {msg.data}")

    await nc.subscribe("orders.>", cb=on_msg)
    await asyncio.sleep(10)
    await nc.close()

asyncio.run(main())

API

NATSClient(grpc_addr=None, api_key=None, tls_ca=None)

Requirements

• Go daemon running as a separate process/deployment (just run, or a compiled go/dist binary)
• NATS server reachable from the daemon
• A valid api-key for the daemon to verify