{"id":24119,"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.","status":"active","version":"0.9.0","language":"python","source_language":"en","source_url":"https://github.com/nominal-io/nominal-streaming","tags":["streaming","real-time","grpc","data"],"install":[{"cmd":"pip install nominal-streaming","lang":"bash","label":"Install from PyPI"}],"dependencies":[{"reason":"Required for gRPC communication with Nominal server.","package":"grpcio","optional":false},{"reason":"Protocol Buffers for message serialization.","package":"protobuf","optional":false},{"reason":"Core Nominal SDK for authentication and resource management.","package":"nominal","optional":false}],"imports":[{"wrong":"from nominal_streaming import StreamingClient","symbol":"NominalDatasetStream","correct":"from nominal_streaming import NominalDatasetStream"},{"symbol":"PyNominalStreamOpts","correct":"from nominal_streaming import PyNominalStreamOpts"},{"symbol":"nominal_dataset_stream","correct":"from nominal_streaming import nominal_dataset_stream"}],"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."},"warnings":[{"fix":"Change 'from nominal.streaming import ...' to 'from nominal_streaming import ...'.","message":"The import path changed from `nominal.streaming` to `nominal_streaming` in version 0.9.0. Old code will fail with ImportError.","severity":"breaking","affected_versions":"<0.9.0"},{"fix":"Replace `StreamingClient(url, username='...', password='...')` with `StreamingClient(url, api_key='...')`.","message":"The `StreamingClient` constructor no longer accepts `username`/`password`; use `api_key`. Authentication method changed.","severity":"breaking","affected_versions":"<0.9.0"},{"fix":"Use string type names: \"int64\", \"float64\", \"string\", etc. See docs for full list.","message":"`StreamSchema` field types are strings, not Python types. Using `int` or `float` will cause a runtime TypeError.","severity":"gotcha","affected_versions":"All"},{"fix":"Update code expecting protobuf objects to use `.timestamp`, `.value`, etc.","message":"The `read()` method now returns an iterator of `DataPoint` objects, not raw protobuf messages.","severity":"breaking","affected_versions":"<0.9.0"}],"env_vars":null,"search_vec":"'0.9.0':26 'bind':5 'cadenc':28 'client':3,11 'current':24 'data':19,36 'grpc':35 'high':14 'high-perform':13 'irregular':30 'nomin':1,8 'perform':15 'provid':12 'python':4 'real':17,33 'real-tim':16,32 'releas':27 'rust':9 'schema':23 'stream':2,10,20,31 'time':18,34 'type':22 'version':25","created_at":"2026-05-01T08:11:23.683399+00:00","updated_at":"2026-05-01T08:11:23.683399+00:00","problems":null,"ecosystem":"pypi","meta_description":null,"install_score":null,"quickstart_score":null,"quickstart_tag":null,"pypi_latest":"0.9.1","cli_name":"","cli_version":null,"type":"library","homepage":"https://nominal.io","github":"https://github.com/nominal-io/nominal-streaming","docs":null,"changelog":null,"pypi":"https://pypi.org/project/nominal-streaming/","npm":null,"openapi_spec":null,"status_page":null,"smithery":null,"categories":["data","database"],"base_url":null,"auth_type":null,"provenance":{"verified_status":"passing","verified_at":"2026-07-03","last_verified":"2026-07-03","next_check":"2026-08-02","install_tag":null}}