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,

)

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

publish(

data: Measurement | Command,

**kwargs,

)

close()