singer_sdk.RecordSink

class singer_sdk.RecordSink(target: singer_sdk.plugin_base.PluginBase, stream_name: str, schema: Dict, key_properties: Optional[List[str]])

Base class for singleton record writers.

process_batch(context: dict) → None

Do nothing and return immediately.

The RecordSink class does not support batching.

This method may not be overridden.

Parameters

context – Stream partition or context dictionary.

abstract process_record(record: dict, context: dict) → None

Load the latest record from the stream.

This method must be overridden.

Implementations should permanently serialize each record to the target prior to returning.

If duplicates are merged/skipped instead of being loaded, merges can be tracked via tally_duplicate_merged().

Parameters

• record – Individual record in the stream.

• context – Stream partition or context dictionary.

start_batch(context: dict) → None

Do nothing and return immediately.

The RecordSink class does not support batching.

This method may not be overridden.

Parameters

context – Stream partition or context dictionary.