singer_sdk.batch.BaseBatcher#

class singer_sdk.batch.BaseBatcher#

Base Record Batcher.

__init__(tap_name: str, stream_name: str, batch_config: BatchConfig) None#

Initialize the batcher.

Parameters:
  • tap_name – The name of the tap.

  • stream_name – The name of the stream.

  • batch_config – The batch configuration.

abstract get_batches(records: Iterator[dict]) Iterator[list[str]]#

Yield manifest of batches.

Parameters:

records – The records to batch.

Raises:

NotImplementedError – If the method is not implemented.