vallenae.io.PriDatabase.listen

PriDatabase.listen(existing=False, wait=False, query_filter=None)[source]

Listen to database changes and return new records.

Parameters:

  • existing (bool) – Return already existing records

  • wait (bool) – Wait for new records even if no acquisition (writer) is active. Otherwise the function returns after all records are read.

  • query_filter (Optional[str]) – Optional query filter provided as SQL clause, e.g. “Time >= 100 AND Chan == 2”

Yields:

New hit/marker/parametric/status data records

Return type:

Iterable[Union[HitRecord, MarkerRecord, ParametricRecord, StatusRecord]]