NominalCorePublisher#

class NominalCorePublisher(
dataset_rid: str,
batch_size: int | None = None,
max_wait: timedelta | None = None,
file_fallback: Path | None = None,
profile: str | None = None,
api_key: str | None = None,
)[source]#

Bases: object

Stream Measurement/Command data to a Nominal Core dataset.

Omitted optional args fall through to the Nominal Core Python API defaults.

Parameters:

  • dataset_rid – Target dataset RID.

  • batch_size – Max items per write batch.

  • max_wait – Max time a batch can age before being flushed.

  • file_fallback – .avro path used when connectivity is intermittent.

  • profile – Named profile from the on-disk config (defaults to "default").

  • api_key – Inline API key; falls back to on-disk credentials when omitted. See https://docs.nominal.io/core/sdk/python-client/authentication#using-the-api-key

Methods

close

publish