bq-nats-client 0.1.0

Python gRPC client for NATS Go sidecar

bq-nats-client

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

Architecture

Python app  ──gRPC──►  Go sidecar  ──NATS──►  NATS server

The Go sidecar handles the NATS connection; this library talks to it over gRPC on localhost:50052 (or any address you configure).

Install

pip install bq-nats-client

Usage

import asyncio
from nats_client import NATSClient, Msg

async def main():
    nc = NATSClient("localhost:50052")

    # 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="localhost:50052")

Method	Description
publish(subject, payload, reply, headers)	Core NATS publish
jetstream(prefix, domain, timeout)	Configure JetStream context (call once)
js_publish(subject, payload, ...) → PubAck	JetStream publish
subscribe(subject, cb, queue, ...) → Task	Subscribe; cb fires per message
close()	Cancel subscribers and close gRPC channel

Requirements

• Go sidecar running (go run ./go/main.go or compiled binary)
• NATS server reachable from the sidecar