singer_sdk.RecordSink#

class singer_sdk.RecordSink[source]#

Base class for singleton record writers.

final process_batch(context)[source]#

Do nothing and return immediately.

The RecordSink class does not support batching.

This method may not be overridden.

Parameters:

context (dict) – Stream partition or context dictionary.

Return type:

None

abstract process_record(record, context)[source]#

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 (dict) – Individual record in the stream.

  • context (dict) – Stream partition or context dictionary.

Return type:

None

final start_batch(context)[source]#

Do nothing and return immediately.

The RecordSink class does not support batching.

This method may not be overridden.

Parameters:

context (dict) – Stream partition or context dictionary.

Return type:

None