vallenae.io.TrfDatabase.listen

TrfDatabase.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. “TRAI >= 100”

Yields:

New feature records

Return type:

Iterable[FeatureRecord]