Registry / data / nominal-streaming

nominal-streaming

JSON →
library0.9.1pypypi✓ verified 79d ago

Python bindings for the Nominal Rust streaming client, providing high-performance real-time data streaming with typed schemas. Current version 0.9.0, release cadence is irregular.

pip install nominal-streaming
INSTALL
IMPORT
SIG · NOMINAL-STREAMING
N
nominal-streaming
datapythonv0.9.1
Install
1.9s avg
Import
Disk
25MB
Pass rate
8/ 10
Env Coverage8 / 10
glibc
3.93.13
musl
3.93.13
Install & Compatibility
Where this runs
tested against v0.9.1 · pip install
no network on importno background threads
Install × environment matrix
Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux
musl
glibc
py 3.10
✓ —
✓ 1.9s
py 3.11
✓ —
✓ 2s
py 3.12
✓ —
✓ 1.8s
py 3.13
✓ —
✓ 1.7s
py 3.9
✕ build_error
✕ build_error
25MB installed
● package 25MB
Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

NominalDatasetStream
from nominal_streaming import NominalDatasetStream
from nominal_streaming import StreamingClient
PyNominalStreamOpts
from nominal_streaming import PyNominalStreamOpts
nominal_dataset_stream
from nominal_streaming import nominal_dataset_stream

Open a stream, write a data point, and read it back.

import os from nominal_streaming import StreamingClient, StreamSchema, DataPoint # Replace with your credentials url = os.environ.get('NOMINAL_URL', 'grpc://localhost:50051') api_key = os.environ.get('NOMINAL_API_KEY', '') client = StreamingClient(url, api_key=api_key) # Define a schema schema = StreamSchema([ ("timestamp", "int64"), ("value", "float64"), ]) # Open a stream stream = client.open_stream("my-stream", schema) # Write one data point stream.write(DataPoint(timestamp=123456789, value=42.0)) # Read back for dp in stream.read(start=0): print(dp) break stream.close()
Debug
Known issues
breakingThe import path changed from `nominal.streaming` to `nominal_streaming` in version 0.9.0. Old code will fail with ImportError.
fix
Change 'from nominal.streaming import ...' to 'from nominal_streaming import ...'.
affects: <0.9.0
breakingThe `StreamingClient` constructor no longer accepts `username`/`password`; use `api_key`. Authentication method changed.
fix
Replace `StreamingClient(url, username='...', password='...')` with `StreamingClient(url, api_key='...')`.
affects: <0.9.0
gotcha`StreamSchema` field types are strings, not Python types. Using `int` or `float` will cause a runtime TypeError.
fix
Use string type names: "int64", "float64", "string", etc. See docs for full list.
affects: All
breakingThe `read()` method now returns an iterator of `DataPoint` objects, not raw protobuf messages.
fix
Update code expecting protobuf objects to use `.timestamp`, `.value`, etc.
affects: <0.9.0
Upgrade
Version history
0.9.1latest on PyPI · released May 16, 2026
Audit
Dependencies
grpciorequiredRequired for gRPC communication with Nominal server.
protobufrequiredProtocol Buffers for message serialization.
nominalrequiredCore Nominal SDK for authentication and resource management.
Agent activity
4 hits · last 30 days
node
4
Resources
nominal-streaming — pip install nominal-streaming · libregistry