singer_sdk.RecordSink#

class singer_sdk.RecordSink#

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.