singer_sdk.batch.BaseBatcher¶

class singer_sdk.batch.BaseBatcher[source]¶

Base Record Batcher.

__init__(tap_name, stream_name, batch_config)[source]¶

Initialize the batcher.

Parameters:

tap_name (str) – The name of the tap.
stream_name (str) – The name of the stream.
batch_config (BatchConfig) – The batch configuration.

Return type:

None

abstract get_batches(records)[source]¶

Yield manifest of batches.

Parameters:: records (Iterator[dict]) – The records to batch.
Raises:: NotImplementedError – If the method is not implemented.
Return type:: Iterator[list[str]]