Nexo Client SDK

High-performance Python client for Nexo.

Quick Start

Run server

docker run -p 7654:7654 emanuelepifani/nexo:latest

This exposes:

  • Port 7654 (TCP): Main server socket for SDK clients.

Install SDK

uv add nexo-client

Or with pip:

pip install nexo-client

Connection

from nexo import NexoClient

client = await NexoClient.connect(host="localhost", port=7654)

1. STORE

# Set key
await client.store.map.set("user:1", {"name": "Max", "role": "admin"})
# Get key
user: User | None = await client.store.map.get("user:1")
# Delete key
await client.store.map.delete("user:1")

2. QUEUE

# Create queue
mail_q: NexoQueue[Email] = await client.queue("emails").create()
# Push message
await mail_q.push({"to": "test@test.com"})
# Subscribe
async def handle_email(msg: Email) -> None:
    print(msg)

await mail_q.subscribe(handle_email)
# Delete queue
await mail_q.delete()

3. PUB/SUB

# Define topic (no need to create, auto-created on first publish)
alerts: NexoTopic[Alert] = client.pubsub("system-alerts")
# Subscribe
async def on_alert(msg: Alert) -> None:
    print(msg)

await alerts.subscribe(on_alert)
# Publish
await alerts.publish({"level": "high"})

4. STREAM

# Create topic
stream: NexoStream[UserEvent] = await client.stream("user-events").create()
# Publisher
await stream.publish({"type": "login", "userId": "u1"})
# Consumer (must specify group)
async def on_event(msg: UserEvent, meta: StreamMessageMeta) -> None:
    print(f"User {msg['userId']} performed {msg['type']}")

await stream.subscribe("analytics", on_event)
# Delete topic
await stream.delete()

Callbacks for Queue, Pub/Sub, and Stream can be sync def or async async def — the SDK handles both.

Binary Payloads

All Nexo brokers (Store, Queue, Stream, PubSub) natively support raw binary data (bytes).
Bypassing JSON serialization drastically reduces Latency, increases Throughput, and saves Bandwidth.

Perfect for: Video chunks, Images, Protobuf/MsgPack, Encrypted blobs.

# Send 1MB raw bytes (30% smaller than JSON/Base64)
heavy_payload = b"\x00" * (1024 * 1024)

# 1. STREAM
stream: NexoStream[bytes] = client.stream("cctv-archive")
await stream.publish(heavy_payload)
# 2. PUBSUB
audio_topic: NexoTopic[bytes] = client.pubsub("live-audio-call")
audio_topic.publish(heavy_payload)
# 3. STORE
await client.store.map.set("user:avatar:1", heavy_payload)
# 4. QUEUE
queue: NexoQueue[bytes] = client.queue("pdf-processing")
await queue.push(heavy_payload)

License

MIT

Links

Author

Built by Emanuel Epifani.

Project links

Data verified by PyPI on Jul 27, 2026
Data provided by the project maintainers, verified at the time the release was uploaded to PyPI.

Key dates

PyPI data
Data sourced directly from PyPI's database.
  • Released:
Newer release available (5.0.3)

1 maintainer

PyPI data
Data sourced directly from PyPI's database.
Avatar for emanuelepifani from gravatar.com emanuelepifani

Credits

Author: Emanuele Pifani

GitHub Statistics

Data verified by PyPI on Jul 27, 2026
The GitHub source repository was provided by the project maintainers and verified by PyPI at the time of upload. Stars, forks, and open issues/PRs are derived from that repository and have not been independently verified.

License expression

MIT
View SPDX License List

Requires

Python >=3.10

Tags

microservices event-driven message-broker queue job-queue stream event-streaming event-sourcing pubsub realtime store key-value-store python high-performance asyncio

Classifiers

Report project as malware

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

nexo_client-5.0.0.tar.gz (18.7 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

nexo_client-5.0.0-py3-none-any.whl (22.4 kB view details)

Uploaded Python 3

File details

Details for the file nexo_client-5.0.0.tar.gz.

File metadata

  • Download URL: nexo_client-5.0.0.tar.gz
  • Upload date:
  • Size: 18.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.14

File hashes

Hashes for nexo_client-5.0.0.tar.gz
Algorithm Hash digest
SHA256 c5f1e181698dea5a9543b9b7bc152098064e9371cda74023bf7579d2ac3d7771
MD5 eb17f3c29747c5e61c758c89a0c6cc6e
BLAKE2b-256 51d2dd8116959a7035ec7ae8df127d0310074f1c407c5bf05abb0c93e8077355

See more details on using hashes here.

Provenance

The following attestation bundles were made for nexo_client-5.0.0.tar.gz:

Publisher: release.yml on emanuel-epifani/nexo

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file nexo_client-5.0.0-py3-none-any.whl.

File metadata

  • Download URL: nexo_client-5.0.0-py3-none-any.whl
  • Upload date:
  • Size: 22.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.14

File hashes

Hashes for nexo_client-5.0.0-py3-none-any.whl
Algorithm Hash digest
SHA256 3385640fe2990907416ea6c1350cc7b5664f887021e15387470133f04b7688a4
MD5 0e9cf866c1bb0d6692366d96e271c221
BLAKE2b-256 1f7f591e3ac9f6ad89b071fa7e55ce7fbe65cabc592719972f1f91226fdbd04d

See more details on using hashes here.

Provenance

The following attestation bundles were made for nexo_client-5.0.0-py3-none-any.whl:

Publisher: release.yml on emanuel-epifani/nexo

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

5.0.3

2 files

5.0.2

2 files

5.0.1

2 files

This release

5.0.0 This release

2 files

4.1.5

2 files

4.1.4

2 files

4.1.3

2 files

4.1.2

2 files

4.1.1

2 files

4.1.0

2 files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page