{"library":"nominal-streaming","title":"Nominal Streaming Client","description":"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.","language":"python","status":"active","last_verified":"Fri May 01","install":{"commands":["pip install nominal-streaming"],"cli":null},"imports":["from nominal_streaming import StreamingClient","from nominal_streaming import StreamSchema","from nominal_streaming import DataPoint"],"auth":{"required":false,"env_vars":[]},"quickstart":{"code":"import os\nfrom nominal_streaming import StreamingClient, StreamSchema, DataPoint\n\n# Replace with your credentials\nurl = os.environ.get('NOMINAL_URL', 'grpc://localhost:50051')\napi_key = os.environ.get('NOMINAL_API_KEY', '')\n\nclient = StreamingClient(url, api_key=api_key)\n\n# Define a schema\nschema = StreamSchema([\n    (\"timestamp\", \"int64\"),\n    (\"value\", \"float64\"),\n])\n\n# Open a stream\nstream = client.open_stream(\"my-stream\", schema)\n\n# Write one data point\nstream.write(DataPoint(timestamp=123456789, value=42.0))\n\n# Read back\nfor dp in stream.read(start=0):\n    print(dp)\n    break\n\nstream.close()","lang":"python","description":"Open a stream, write a data point, and read it back.","tag":null,"tag_description":null,"last_tested":null,"results":[]},"compatibility":null}